From 80c0356fac504c35a98d8efe99a523f380254566 Mon Sep 17 00:00:00 2001 From: Sergio Chouhy Date: Tue, 17 Feb 2026 20:57:05 -0300 Subject: [PATCH] wip --- sequencer_core/src/block_settlement_client.rs | 5 ++++ .../configs/debug/sequencer_config.json | 4 +-- sequencer_runner/src/lib.rs | 28 +++++++++++++------ 3 files changed, 26 insertions(+), 11 deletions(-) diff --git a/sequencer_core/src/block_settlement_client.rs b/sequencer_core/src/block_settlement_client.rs index 16afa9c1..c6822e0c 100644 --- a/sequencer_core/src/block_settlement_client.rs +++ b/sequencer_core/src/block_settlement_client.rs @@ -28,6 +28,11 @@ pub trait BlockSettlementClientTrait: Clone { /// Create and sign a transaction for inscribing data. fn create_inscribe_tx(&self, block: &Block) -> Result<(SignedMantleTx, MsgId)> { let inscription_data = borsh::to_vec(block)?; + log::info!( + "The size of the block {} is {} bytes", + block.header.block_id, + inscription_data.len() + ); let verifying_key_bytes = self.bedrock_signing_key().public_key().to_bytes(); let verifying_key = Ed25519PublicKey::from_bytes(&verifying_key_bytes).expect("valid ed25519 public key"); diff --git a/sequencer_runner/configs/debug/sequencer_config.json b/sequencer_runner/configs/debug/sequencer_config.json index 4ac8e15b..aee66f42 100644 --- a/sequencer_runner/configs/debug/sequencer_config.json +++ b/sequencer_runner/configs/debug/sequencer_config.json @@ -5,8 +5,8 @@ "is_genesis_random": true, "max_num_tx_in_block": 20, "mempool_max_size": 1000, - "block_create_timeout_millis": 12000, - "retry_pending_blocks_timeout_millis": 6000, + "block_create_timeout_millis": 2000, + "retry_pending_blocks_timeout_millis": 500, "port": 3040, "bedrock_config": { "backoff": { diff --git a/sequencer_runner/src/lib.rs b/sequencer_runner/src/lib.rs index 74ebae49..358bd37f 100644 --- a/sequencer_runner/src/lib.rs +++ b/sequencer_runner/src/lib.rs @@ -1,4 +1,9 @@ -use std::{net::SocketAddr, path::PathBuf, sync::Arc, time::Duration}; +use std::{ + net::SocketAddr, + path::PathBuf, + sync::Arc, + time::{Duration, Instant}, +}; use actix_web::dev::ServerHandle; use anyhow::{Context as _, Result}; @@ -7,12 +12,15 @@ use common::rpc_primitives::RpcConfig; use futures::{FutureExt as _, never::Never}; #[cfg(not(feature = "standalone"))] use log::warn; -use log::{error, info}; +use log::{debug, error, info, warn}; #[cfg(feature = "standalone")] use sequencer_core::SequencerCoreWithMockClients as SequencerCore; -use sequencer_core::config::SequencerConfig; #[cfg(not(feature = "standalone"))] use sequencer_core::{SequencerCore, block_settlement_client::BlockSettlementClientTrait as _}; +use sequencer_core::{ + SequencerCore, block_settlement_client::BlockSettlementClientTrait as _, + config::SequencerConfig, +}; use sequencer_rpc::new_http_server; use tokio::{sync::Mutex, task::JoinHandle}; @@ -176,20 +184,21 @@ async fn retry_pending_blocks_loop( (pending_blocks, client) }; - if let Some(block) = pending_blocks - .iter() - .min_by_key(|block| block.header.block_id) - { + for block in &pending_blocks { info!( "Resubmitting pending block with id {}", block.header.block_id ); - // TODO: We could cache the inscribe tx for each pending block to avoid re-creating - // it on every retry. + // TODO: We could cache the inscribe tx for each pending block to avoid re-creating it + // on every retry. + let now = Instant::now(); let (tx, _msg_id) = block_settlement_client .create_inscribe_tx(block) .context("Failed to create inscribe tx for pending block")?; + debug!(">>>> Create inscribe: {:?}", now.elapsed()); + + let now = Instant::now(); if let Err(e) = block_settlement_client .submit_inscribe_tx_to_bedrock(tx) .await @@ -199,6 +208,7 @@ async fn retry_pending_blocks_loop( block.header.block_id ); } + debug!(">>>> Post: {:?}", now.elapsed()); } } }