Skip to content

Commit

Permalink
add trace log
Browse files Browse the repository at this point in the history
  • Loading branch information
jackzhhuang committed Aug 31, 2024
1 parent dcb9704 commit bbdcc20
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion sync/src/parallel/sender.rs
Original file line number Diff line number Diff line change
Expand Up @@ -103,6 +103,8 @@ impl DagBlockSender {
anyhow::format_err!("failed to decode for the block in parallel!")
})?;

info!("worker now process block: id: {:?}", block.id());

// Finding the executing state is the priority
if self.dispatch_to_worker(&block).await? {
self.flush_executor_state(notify).await?;
Expand All @@ -129,9 +131,10 @@ impl DagBlockSender {
handle: executor.start_to_execute()?,
};

let id = block.id();
info!("now create a new worker for block: {:?}", block.id());
sender_to_worker.send(block).await?;
info!("now finish to create a new worker for block: {:?}", block.id());
info!("now finish to create a new worker for block: {:?}", id);
self.executors.push(executor);

self.flush_executor_state(notify).await?;
Expand Down

0 comments on commit bbdcc20

Please sign in to comment.