Skip to content

Commit

Permalink
Remove some debugging output
Browse files Browse the repository at this point in the history
  • Loading branch information
JamesPiechota committed Jul 14, 2024
1 parent 2e61c63 commit e39b4cc
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 13 deletions.
5 changes: 2 additions & 3 deletions apps/arweave/src/ar_block_propagation_worker.erl
Original file line number Diff line number Diff line change
Expand Up @@ -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(),
Expand Down Expand Up @@ -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.

%%%===================================================================
Expand Down
9 changes: 2 additions & 7 deletions apps/arweave/src/ar_http_iface_client.erl
Original file line number Diff line number Diff line change
Expand Up @@ -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) ++ "/"
Expand All @@ -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 =
Expand Down
3 changes: 0 additions & 3 deletions apps/arweave/src/ar_tx_emitter_worker.erl
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down

0 comments on commit e39b4cc

Please sign in to comment.