add some trace log

starcoinorg · Aug 31, 2024 · a5a21d7 · a5a21d7
1 parent 1d77248
commit a5a21d7
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 12 deletions.
diff --git a/sync/src/parallel/sender.rs b/sync/src/parallel/sender.rs
@@ -68,11 +68,6 @@ impl DagBlockSender {
                         || block.header.parents_hash().contains(header_id)
                     {
                         executor.state = ExecuteState::Executing(block.id());
-                        info!(
-                            "send the block {:?} to the executor: {:p}",
-                            block.id(),
-                            &executor
-                        );
                         match executor.sender_to_executor.try_send(block.clone()) {
                             Ok(_) => (),
                             Err(e) => match e {
@@ -134,11 +129,6 @@ impl DagBlockSender {
                 handle: executor.start_to_execute()?,
             };
 
-            info!(
-                "send the block {:?} to the executor: {:p}",
-                block.id(),
-                &executor
-            );
             sender_to_worker.send(block).await?;
             self.executors.push(executor);
 
@@ -180,7 +170,6 @@ impl DagBlockSender {
                 true
             }
         });
-        info!("sync workers count: {:?}", self.executors.len());
         anyhow::Ok(())
     }
 

diff --git a/sync/src/tasks/block_sync_task.rs b/sync/src/tasks/block_sync_task.rs
@@ -395,24 +395,31 @@ where
         block_header: BlockHeader,
         absent_blocks: &mut Vec<HashValue>,
     ) -> Result<()> {
+        info!("check the parents{:?} exists", block_header.id());
         let parents = block_header.parents_hash();
         if parents.is_empty() {
             return Ok(());
         }
         for parent in parents {
             if self.chain.has_dag_block(parent)? {
+                info!("parent {:?} exists", parent);
                 continue;
             }
             match self.local_store.get_dag_sync_block(parent)? {
                 Some(block) => {
+                    info!("parent {:?} in local, save in sync dag store", parent);
                     match self.sync_dag_store.get_dag_sync_block(block.block.header().number(), block.block.header().id()) {
-                        Ok(_) => (),
+                        Ok(_) => {
+                            info!("parent {:?} already in local, save in sync dag store", parent);
+                        }
                         Err(_) => {
+                            info!("parent {:?} goes to be saved in local, save in sync dag store", parent);
                             self.sync_dag_store.save_block(block.block)?;
                         }
                     }
                 }
                 None => {
+                    info!("parent {:?} not in local, fetch from remote", parent);
                     if absent_blocks.contains(&parent) {
                         continue;
                     }