Skip to content

Commit 580f921

Browse files
committed
Add a comment and log
1 parent c0c4459 commit 580f921

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

beacon_node/lighthouse_network/src/rpc/mod.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -244,6 +244,7 @@ impl<Id: ReqId, E: EthSpec> RPC<Id, E> {
244244
request.substream_id,
245245
event.clone(),
246246
) {
247+
// Response is logged and queued internally in the response limiter.
247248
return;
248249
}
249250
}

beacon_node/lighthouse_network/src/rpc/response_limiter.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -64,6 +64,7 @@ impl<E: EthSpec> ResponseLimiter<E> {
6464
) -> bool {
6565
// First check that there are not already other responses waiting to be sent.
6666
if let Some(queue) = self.delayed_responses.get_mut(&(peer_id, protocol)) {
67+
debug!(self.log, "Response rate limiting since there are already other responses waiting to be sent"; "protocol" => %protocol, "peer_id" => %peer_id);
6768
queue.push_back(QueuedResponse {
6869
peer_id,
6970
connection_id,

0 commit comments

Comments
 (0)