We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0891111 commit 9cca75bCopy full SHA for 9cca75b
1 file changed
chain/src/application.rs
@@ -125,11 +125,13 @@ impl<E: Clock + Storage + Metrics> Reporter for Application<E> {
125
126
async fn report(&mut self, activity: Self::Activity) {
127
if let Update::Block(block, ack_rx) = activity {
128
+ // Cache the finalized block in memory and enqueue its digest
129
+ // before acking so the consumer can recover it across restarts.
130
if let Some(backfiller) = &self.backfiller {
- // Cache the finalized block in memory and enqueue its digest
- // before acking so the consumer can recover it across restarts.
131
backfiller.record(&block).await;
132
}
133
+
134
+ // Acknowledge the block.
135
info!(height = %block.height(), "finalized block");
136
ack_rx.acknowledge();
137
0 commit comments