Revert "remove logging"

This reverts commit a2cacfe.

Author: sokra

turbopack/crates/turbo-persistence/src/compaction/selector.rs

@@ -283,6 +283,11 @@ mod tests {
 
         for _ in 0..100 {
             let coverage = total_coverage(&containers, (0, 10000));
+            println!(
+                "{containers:#?} coverage: {}, items: {}",
+                coverage,
+                containers.len()
+            );
 
             if coverage > 10.0 {
                 let config = CompactConfig {
@@ -291,9 +296,13 @@ mod tests {
                 };
                 let jobs = get_compaction_jobs(&containers, &config);
                 if !jobs.is_empty() {
+                    println!("{jobs:?}");
+
                     do_compact(&mut containers, jobs);
                     number_of_compactions += 1;
                 }
+            } else {
+                println!("No compaction needed");
             }
 
             // Modify warm keys
@@ -306,6 +315,7 @@ mod tests {
                 swap(&mut warm_keys[i], &mut keys[j]);
             }
         }
+        println!("Number of compactions: {}", number_of_compactions);
 
         assert!(containers.len() < 40);
         let coverage = total_coverage(&containers, (0, 10000));

turbopack/crates/turbo-persistence/src/write_batch.rs

@@ -174,6 +174,8 @@ impl<K: StoreKey + Send + Sync, const FAMILIES: usize> WriteBatch<K, FAMILIES> {
         let mut new_blob_files = Vec::new();
         let shared_error = Mutex::new(Ok(()));
 
+        println!("finish write batch");
+
         // First, we flush all thread local collectors to the global collectors.
         scope(|scope| {
             let mut collectors = [const { Vec::new() }; FAMILIES];
@@ -203,6 +205,8 @@ impl<K: StoreKey + Send + Sync, const FAMILIES: usize> WriteBatch<K, FAMILIES> {
             }
         });
 
+        println!("flushed thread local collectors");
+
         // Now we reduce the global collectors in parallel
         let shared_new_sst_files = Mutex::new(&mut new_sst_files);
 
@@ -231,6 +235,8 @@ impl<K: StoreKey + Send + Sync, const FAMILIES: usize> WriteBatch<K, FAMILIES> {
                 anyhow::Ok(())
             })?;
 
+        println!("flushed collectors");
+
         shared_error.into_inner()?;
         let seq = self.current_sequence_number.load(Ordering::SeqCst);
         new_sst_files.sort_by_key(|(seq, _)| *seq);