From ba3c9e4c7fa27930829fce6afccd046fff57a682 Mon Sep 17 00:00:00 2001
From: hanabi1224 <harlowmoo@gmail.com>
Date: Wed, 10 Jun 2026 23:37:09 +0800
Subject: [PATCH] fix: more server logs for snapshot export

---
 src/chain/mod.rs     | 13 +++++++++++++
 src/db/car/forest.rs |  9 +++++++--
 2 files changed, 20 insertions(+), 2 deletions(-)

diff --git a/src/chain/mod.rs b/src/chain/mod.rs
index 2acb40b0b058..011bd55744a5 100644
--- a/src/chain/mod.rs
+++ b/src/chain/mod.rs
@@ -25,6 +25,7 @@ use multihash_derive::MultihashDigest as _;
 use nunny::Vec as NonEmpty;
 use sha2::digest::{self, Digest};
 use std::io::{Read, Seek, SeekFrom};
+use std::time::Instant;
 use tokio::io::{AsyncWrite, AsyncWriteExt, BufWriter};
 
 pub struct ExportOptions<S> {
@@ -146,6 +147,13 @@ async fn export_to_forest_car<D: Digest, S: CidHashSetLike + Send + Sync + 'stat
         anyhow::bail!("message receipts must be included when events are included");
     }
 
+    let start = Instant::now();
+    tracing::info!(
+        "Exporting snapshot, epoch={}, depth={lookup_depth}, prefix_frames={}",
+        tipset.epoch(),
+        prefix_data_frames.as_ref().map(|v| v.len()).unwrap_or(0)
+    );
+
     let stateroot_lookup_limit = tipset.epoch() - lookup_depth;
 
     // Wrap writer in optional checksum calculator
@@ -182,5 +190,10 @@ async fn export_to_forest_car<D: Digest, S: CidHashSetLike + Send + Sync + 'stat
 
     let digest = writer.finalize().map_err(|e| Error::Other(e.to_string()))?;
 
+    tracing::info!(
+        "Exported snapshot, took {}",
+        humantime::format_duration(start.elapsed())
+    );
+
     Ok(digest)
 }
diff --git a/src/db/car/forest.rs b/src/db/car/forest.rs
index b6bd90276af7..adaa7f3cb99c 100644
--- a/src/db/car/forest.rs
+++ b/src/db/car/forest.rs
@@ -333,21 +333,26 @@ impl Encoder {
 
         // Write seekable zstd and collect a mapping of CIDs to frame_offset+data_offset.
         let mut builder = index::Builder::new();
+        let mut n_frames = 0;
         while let Some((cids, zstd_frame)) = stream.try_next().await? {
             builder.extend(cids.into_iter().map(|cid| (cid, offset as u64)));
             sink.write_all(&zstd_frame).await?;
-            offset += zstd_frame.len()
+            offset += zstd_frame.len();
+            n_frames += 1;
         }
 
+        tracing::info!("Finished writing {n_frames} zstd CAR frames");
+
         // Create index
         let writer = builder.into_writer();
         writer.write_zstd_skip_frames_into(&mut sink).await?;
-
+        tracing::info!("Finished writing zstd CAR index frames");
         // Write ForestCAR.zst footer, it's a valid ZSTD skip-frame
         let footer = ForestCarFooter {
             index: offset as u64 + ZSTD_SKIP_FRAME_LEN,
         };
         sink.write_all(&footer.to_le_bytes()).await?;
+        tracing::info!("Finished writing zstd CAR footer frame");
         Ok(())
     }