Method reopen

crates/engine/src/relational_db.rs:2025–2057

Re-open the database, after ensuring that all data has been flushed to disk (if the database was created via [`Self::durable`]).

(self)

        /// Re-open the database, after ensuring that all data has been flushed
        /// to disk (if the database was created via [`Self::durable`]).
        pub fn reopen(self) -> Result<Self, DBError> {
            if let Some(rt) = self.runtime() {
                rt.block_on(self.db.shutdown());
            }
            drop(self.db);

            if let Some(DurableState {
                durability,
                rt,
                replica_dir,
            }) = self.durable
            {
                rt.block_on(durability.close());
                drop(durability);
                // Enter the runtime so that `Self::durable_internal` can spawn a `SnapshotWorker`.
                let _rt = rt.enter();
                let (db, handle) = Self::durable_internal(&replica_dir, rt.handle().clone(), self.want_snapshot_repo)?;
                let durable = DurableState {
                    durability: handle,
                    rt,
                    replica_dir,
                };

                Ok(Self {
                    db: Arc::new(db),
                    durable: Some(durable),
                    ..self
                })
            } else {
                let db = Self::in_memory_internal().map(Arc::new)?;
                Ok(Self { db, ..self })
            }
        }

        pub fn with_row_count(self, row_count: RowCountFn) -> Self {
            let db = Arc::into_inner(self.db).expect("TestDB::db should be unique");