Flush objects memtable after pruning (MystenLabs#7550)

Author: sadhansood

crates/sui-core/src/authority/authority_store_pruner.rs

@@ -147,6 +147,11 @@ impl AuthorityStorePruner {
                         info!("Starting pruning of objects table");
                         let num_pruned = Self::prune_objects(num_versions_to_retain, perpetual_db.clone());
                         info!("Finished pruning with total object versions pruned = {}", num_pruned);
+                        if let Ok(()) = perpetual_db.objects.flush() {
+                            info!("Completed flushing objects table");
+                        } else {
+                            error!("Failed to flush objects table");
+                        }
                         let start = Instant::now();
                         let min_key = ObjectKey(ObjectID::ZERO, SequenceNumber::MIN);
                         let max_key = ObjectKey(ObjectID::MAX, SequenceNumber::MAX);

crates/typed-store/src/rocks/mod.rs

@@ -340,6 +340,10 @@ impl RocksDB {
         delegate_call!(self.flush())
     }
 
+    pub fn flush_cf(&self, cf: &impl AsColumnFamilyRef) -> Result<(), rocksdb::Error> {
+        delegate_call!(self.flush_cf(cf))
+    }
+
     pub fn set_options_cf(
         &self,
         cf: &impl AsColumnFamilyRef,
@@ -539,6 +543,10 @@ impl<K, V> DBMap<K, V> {
         self.rocksdb.iterator_cf(&self.cf(), IteratorMode::Start)
     }
 
+    pub fn flush(&self) -> Result<(), rocksdb::Error> {
+        self.rocksdb.flush_cf(&self.cf())
+    }
+
     pub fn set_options(&self, opts: &[(&str, &str)]) -> Result<(), rocksdb::Error> {
         self.rocksdb.set_options_cf(&self.cf(), opts)
     }