From 7c49376d85fd48ac250ca21250900baf539a2808 Mon Sep 17 00:00:00 2001 From: Cody Wang Date: Tue, 3 Jun 2025 10:07:47 -0400 Subject: [PATCH 1/3] modify logging --- crates/op-rbuilder/src/builders/flashblocks/payload.rs | 5 ++++- crates/op-rbuilder/src/builders/flashblocks/wspub.rs | 2 +- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/crates/op-rbuilder/src/builders/flashblocks/payload.rs b/crates/op-rbuilder/src/builders/flashblocks/payload.rs index 8c37bbb35..412286c9c 100644 --- a/crates/op-rbuilder/src/builders/flashblocks/payload.rs +++ b/crates/op-rbuilder/src/builders/flashblocks/payload.rs @@ -303,10 +303,13 @@ where // Continue with flashblock building tracing::info!( target: "payload_builder", - "Building flashblock idx={} target_gas={} taget_da={}", + "Building flashblock block_number={} idx={} target_gas={} gas_used={} taget_da={} da_used={}", + ctx.block_number(), flashblock_count, total_gas_per_batch, + info.cumulative_gas_used, total_da_per_batch.unwrap_or(0), + info.cumulative_da_bytes_used, ); let flashblock_build_start_time = Instant::now(); let state = StateProviderDatabase::new(&state_provider); diff --git a/crates/op-rbuilder/src/builders/flashblocks/wspub.rs b/crates/op-rbuilder/src/builders/flashblocks/wspub.rs index a31ad3be7..3a738c8e5 100644 --- a/crates/op-rbuilder/src/builders/flashblocks/wspub.rs +++ b/crates/op-rbuilder/src/builders/flashblocks/wspub.rs @@ -187,7 +187,7 @@ async fn broadcast_loop( sent.fetch_add(1, Ordering::Relaxed); metrics.messages_sent_count.increment(1); - tracing::info!("Broadcasted payload: {:?}", payload); + tracing::debug!("Broadcasted payload: {:?}", payload); if let Err(e) = stream.send(Message::Text(payload)).await { tracing::debug!("Closing flashblocks subscription for {peer_addr}: {e}"); break; // Exit the loop if sending fails From 9ce1542c63eea76d2919f77c2e598d7b47d3ae20 Mon Sep 17 00:00:00 2001 From: Cody Wang Date: Tue, 3 Jun 2025 10:16:58 -0400 Subject: [PATCH 2/3] more --- crates/op-rbuilder/src/builders/flashblocks/payload.rs | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/crates/op-rbuilder/src/builders/flashblocks/payload.rs b/crates/op-rbuilder/src/builders/flashblocks/payload.rs index 412286c9c..277055f1a 100644 --- a/crates/op-rbuilder/src/builders/flashblocks/payload.rs +++ b/crates/op-rbuilder/src/builders/flashblocks/payload.rs @@ -293,9 +293,10 @@ where if flashblock_count >= self.config.flashblocks_per_block() { tracing::info!( target: "payload_builder", - "Skipping flashblock reached target={} idx={}", + "Skipping flashblock reached target={} idx={} block_number={}", self.config.flashblocks_per_block(), - flashblock_count + flashblock_count, + ctx.block_number(), ); continue; } From 8219d368c5f377e2822259b0c5fe7fc72a26896b Mon Sep 17 00:00:00 2001 From: Cody Wang Date: Tue, 3 Jun 2025 11:47:29 -0400 Subject: [PATCH 3/3] structure logs --- .../src/builders/flashblocks/payload.rs | 22 +++++++++---------- 1 file changed, 11 insertions(+), 11 deletions(-) diff --git a/crates/op-rbuilder/src/builders/flashblocks/payload.rs b/crates/op-rbuilder/src/builders/flashblocks/payload.rs index 277055f1a..61c742816 100644 --- a/crates/op-rbuilder/src/builders/flashblocks/payload.rs +++ b/crates/op-rbuilder/src/builders/flashblocks/payload.rs @@ -293,10 +293,10 @@ where if flashblock_count >= self.config.flashblocks_per_block() { tracing::info!( target: "payload_builder", - "Skipping flashblock reached target={} idx={} block_number={}", - self.config.flashblocks_per_block(), - flashblock_count, - ctx.block_number(), + target = self.config.flashblocks_per_block(), + flashblock_count = flashblock_count, + block_number = ctx.block_number(), + "Skipping flashblock reached target", ); continue; } @@ -304,13 +304,13 @@ where // Continue with flashblock building tracing::info!( target: "payload_builder", - "Building flashblock block_number={} idx={} target_gas={} gas_used={} taget_da={} da_used={}", - ctx.block_number(), - flashblock_count, - total_gas_per_batch, - info.cumulative_gas_used, - total_da_per_batch.unwrap_or(0), - info.cumulative_da_bytes_used, + block_number = ctx.block_number(), + flashblock_count = flashblock_count, + target_gas = total_gas_per_batch, + gas_used = info.cumulative_gas_used, + target_da = total_da_per_batch.unwrap_or(0), + da_used = info.cumulative_da_bytes_used, + "Building flashblock", ); let flashblock_build_start_time = Instant::now(); let state = StateProviderDatabase::new(&state_provider);