[pipeline] debug

consensus/src/pipeline/pipeline_builder.rs

@@ -95,7 +95,7 @@ fn spawn_ready_fut<T: Send + Clone + 'static>(f: T) -> TaskFuture<T> {
 
 async fn wait_and_log_error<T, F: Future<Output = TaskResult<T>>>(f: F, msg: String) {
     if let Err(TaskError::InternalError(e)) = f.await {
-        warn!("{} failed: {}", msg, e);
+        error!("[Pipeline] {} failed: {}", msg, e);
     }
 }
 
@@ -630,6 +630,12 @@ impl PipelineBuilder {
         block: Arc<Block>,
     ) -> TaskResult<PostPreCommitResult> {
         let compute_result = pre_commit.await?;
+        info!(
+            "[Pipeline] Block {} {} {} pre_commit received in post_pre_commit",
+            block.id(),
+            block.epoch(),
+            block.round(),
+        );
         parent_post_pre_commit.await?;
 
         let _tracker = Tracker::new("post_pre_commit", &block);
@@ -716,7 +722,7 @@ impl PipelineBuilder {
             post_ledger_update_fut: _,
             commit_vote_fut: _,
             pre_commit_fut,
-            post_pre_commit_fut: _,
+            post_pre_commit_fut,
             commit_ledger_fut,
             post_commit_fut: _,
         } = all_futs;
@@ -732,6 +738,11 @@ impl PipelineBuilder {
             format!("{epoch} {round} {block_id} pre commit"),
         )
         .await;
+        wait_and_log_error(
+            post_pre_commit_fut,
+            format!("{epoch} {round} {block_id} post pre commit"),
+        )
+        .await;
         wait_and_log_error(
             commit_ledger_fut,
             format!("{epoch} {round} {block_id} commit ledger"),