Skip to content

Commit c13e069

Browse files
authored
Revise logging when queue is full (#7324)
1 parent 5527125 commit c13e069

File tree

1 file changed

+5
-5
lines changed

1 file changed

+5
-5
lines changed

beacon_node/beacon_processor/src/work_reprocessing_queue.rs

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -452,7 +452,7 @@ impl<S: SlotClock> ReprocessQueue<S> {
452452
if self.early_block_debounce.elapsed() {
453453
warn!(
454454
queue_size = MAXIMUM_QUEUED_BLOCKS,
455-
msg = "check system clock",
455+
msg = "system resources may be saturated",
456456
"Early blocks queue is full"
457457
);
458458
}
@@ -500,7 +500,7 @@ impl<S: SlotClock> ReprocessQueue<S> {
500500
if self.rpc_block_debounce.elapsed() {
501501
warn!(
502502
queue_size = MAXIMUM_QUEUED_BLOCKS,
503-
msg = "check system clock",
503+
msg = "system resources may be saturated",
504504
"RPC blocks queue is full"
505505
);
506506
}
@@ -540,7 +540,7 @@ impl<S: SlotClock> ReprocessQueue<S> {
540540
if self.attestation_delay_debounce.elapsed() {
541541
error!(
542542
queue_size = MAXIMUM_QUEUED_ATTESTATIONS,
543-
msg = "check system clock",
543+
msg = "system resources may be saturated",
544544
"Aggregate attestation delay queue is full"
545545
);
546546
}
@@ -572,7 +572,7 @@ impl<S: SlotClock> ReprocessQueue<S> {
572572
if self.attestation_delay_debounce.elapsed() {
573573
error!(
574574
queue_size = MAXIMUM_QUEUED_ATTESTATIONS,
575-
msg = "check system clock",
575+
msg = "system resources may be saturated",
576576
"Attestation delay queue is full"
577577
);
578578
}
@@ -606,7 +606,7 @@ impl<S: SlotClock> ReprocessQueue<S> {
606606
if self.lc_update_delay_debounce.elapsed() {
607607
error!(
608608
queue_size = MAXIMUM_QUEUED_LIGHT_CLIENT_UPDATES,
609-
msg = "check system clock",
609+
msg = "system resources may be saturated",
610610
"Light client updates delay queue is full"
611611
);
612612
}

0 commit comments

Comments
 (0)