wip

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");

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": {

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());
         }
     }
 }