WIP: logging

turbopack/crates/turbo-tasks-backend/src/backend/mod.rs

@@ -534,6 +534,8 @@ impl TurboTasksBackend {
 
 impl Backend for TurboTasksBackend {
     fn startup(&self, turbo_tasks: &dyn TurboTasksBackendApi<Self>) {
+        self.backing_storage.startup();
+
         // Continue all uncompleted operations
         // They can't be interrupted by a snapshot since the snapshotting job has not been scheduled
         // yet.

turbopack/crates/turbo-tasks-backend/src/backing_storage.rs

@@ -10,6 +10,7 @@ use crate::{
 };
 
 pub trait BackingStorage {
+    fn startup(&self);
     fn next_free_task_id(&self) -> TaskId;
     fn uncompleted_operations(&self) -> Vec<AnyOperation>;
     fn save_snapshot(

turbopack/crates/turbo-tasks-backend/src/lmdb_backing_storage.rs

@@ -11,7 +11,10 @@ use std::{
 };
 
 use anyhow::{anyhow, Context, Result};
-use lmdb::{Database, DatabaseFlags, Environment, EnvironmentFlags, Transaction, WriteFlags};
+use bincode::Options;
+use lmdb::{
+    Cursor, Database, DatabaseFlags, Environment, EnvironmentFlags, Transaction, WriteFlags,
+};
 use tracing::Span;
 use turbo_tasks::{backend::CachedTaskType, KeyValuePair, TaskId};
 
@@ -85,9 +88,29 @@ impl LmdbBackingStorage {
             restored_cache_entries: AtomicUsize::new(0),
         })
     }
+
+    fn display_db(&self) -> Result<String> {
+        use std::fmt::Write;
+        let mut result = String::new();
+        let tx = self.env.begin_ro_txn()?;
+        let mut cursor = tx.open_ro_cursor(self.data_db)?;
+        for (key, value) in cursor.iter() {
+            let task_id = u32::from_be_bytes(key.try_into()?);
+            let data: Vec<CachedDataItem> = bincode::deserialize(value)?;
+            write!(result, "### Task {task_id}\n{data:#?}\n\n")?;
+        }
+        Ok(result)
+    }
 }
 
 impl BackingStorage for LmdbBackingStorage {
+    fn startup(&self) {
+        println!(
+            "Database content:\n{}",
+            self.display_db().unwrap_or_default()
+        );
+    }
+
     fn next_free_task_id(&self) -> TaskId {
         fn get(this: &LmdbBackingStorage) -> Result<u32> {
             let tx = this.env.begin_rw_txn()?;
@@ -388,6 +411,7 @@ impl BackingStorage for LmdbBackingStorage {
             .inspect_err(|err| println!("Looking up data for {task_id} failed: {err:?}"))
             .unwrap_or_default();
         if !result.is_empty() {
+            println!("restored {task_id}");
             self.restored_tasks
                 .fetch_add(1, std::sync::atomic::Ordering::Relaxed);
         }

turbopack/crates/turbo-tasks/src/manager.rs

@@ -424,7 +424,7 @@ impl<B: Backend + 'static> TurboTasks<B> {
             event_background: Event::new(|| "TurboTasks::event_background".to_string()),
             program_start: Instant::now(),
         });
-        this.backend.startup(&*this);
+        TURBO_TASKS.sync_scope(this.pin(), || this.backend.startup(&*this));
         this
     }