From 68c93d227ff38bb719a3acef1b513fd22fa10523 Mon Sep 17 00:00:00 2001 From: James Piechota Date: Sun, 14 Jul 2024 09:08:27 -0400 Subject: [PATCH] Remove some debugging output --- apps/arweave/src/ar_block_propagation_worker.erl | 5 ++--- apps/arweave/src/ar_http_iface_client.erl | 9 ++------- apps/arweave/src/ar_tx_emitter_worker.erl | 3 --- 3 files changed, 4 insertions(+), 13 deletions(-) diff --git a/apps/arweave/src/ar_block_propagation_worker.erl b/apps/arweave/src/ar_block_propagation_worker.erl index 7e72b5245..4ec1fdd5d 100644 --- a/apps/arweave/src/ar_block_propagation_worker.erl +++ b/apps/arweave/src/ar_block_propagation_worker.erl @@ -40,7 +40,6 @@ handle_cast({send_block, SendFun, RetryCount, From}, State) -> end; handle_cast({send_block2, Peer, SendAnnouncementFun, SendFun, RetryCount, From}, State) -> - ?LOG_DEBUG([{event, send_block2}, {peer, ar_util:format_peer(Peer)}]), case SendAnnouncementFun() of {ok, {{<<"412">>, _}, _, _, _, _}} when RetryCount > 0 -> ar_util:cast_after(2000, self(), @@ -92,8 +91,8 @@ handle_info(Info, State) -> ?LOG_WARNING([{event, unhandled_info}, {module, ?MODULE}, {info, Info}]), {noreply, State}. -terminate(_Reason, _State) -> - ?LOG_WARNING([{event, terminate}, {module, ?MODULE}]), +terminate(Reason, _State) -> + ?LOG_INFO([{event, terminate}, {module, ?MODULE}, {reason, Reason}]), ok. %%%=================================================================== diff --git a/apps/arweave/src/ar_http_iface_client.erl b/apps/arweave/src/ar_http_iface_client.erl index 535aa6486..665c01a6c 100644 --- a/apps/arweave/src/ar_http_iface_client.erl +++ b/apps/arweave/src/ar_http_iface_client.erl @@ -294,8 +294,7 @@ get_sync_record(Peer) -> get_sync_record(Peer, Start, Limit) -> Headers = [{<<"Content-Type">>, <<"application/etf">>}], - StartTime = erlang:monotonic_time(), - Response = handle_sync_record_response(ar_http:req(#{ + handle_sync_record_response(ar_http:req(#{ peer => Peer, method => get, path => "/data_sync_record/" ++ integer_to_list(Start) ++ "/" @@ -304,11 +303,7 @@ get_sync_record(Peer, Start, Limit) -> connect_timeout => 5000, limit => ?MAX_ETF_SYNC_RECORD_SIZE, headers => Headers - }), Start, Limit), - ElapsedTime = erlang:convert_time_unit(erlang:monotonic_time() - StartTime, native, millisecond), - ?LOG_DEBUG([{event, get_sync_record}, {peer, ar_util:format_peer(Peer)}, - {elapsed, ElapsedTime}]), - Response. + }), Start, Limit). get_chunk_binary(Peer, Offset, RequestedPacking) -> PackingBinary = diff --git a/apps/arweave/src/ar_tx_emitter_worker.erl b/apps/arweave/src/ar_tx_emitter_worker.erl index ffb829bc2..ee23596b7 100644 --- a/apps/arweave/src/ar_tx_emitter_worker.erl +++ b/apps/arweave/src/ar_tx_emitter_worker.erl @@ -54,9 +54,6 @@ handle_cast({emit, TXID, Peer, ReplyTo}, State) -> end, Reply = SendFun(), PropagationTimeUs = timer:now_diff(erlang:timestamp(), StartedAt), - ?LOG_DEBUG([{event, tx_propagated}, {txid, ar_util:encode(TXID)}, - {peer, ar_util:format_peer(Peer)}, {reply, Reply}, - {elapsed, PropagationTimeUs / 1000}]), record_propagation_status(Reply), record_propagation_rate(tx_propagated_size(TX), PropagationTimeUs) end,