diff --git a/ledger/src/blockstore/blockstore_purge.rs b/ledger/src/blockstore/blockstore_purge.rs index fec06319b0..3e39609969 100644 --- a/ledger/src/blockstore/blockstore_purge.rs +++ b/ledger/src/blockstore/blockstore_purge.rs @@ -178,6 +178,10 @@ impl Blockstore { & self .db .delete_range_cf::(&mut write_batch, from_slot, to_slot) + .is_ok() + & self + .db + .delete_range_cf::(&mut write_batch, from_slot, to_slot) .is_ok(); let mut w_active_transaction_status_index = self.active_transaction_status_index.write().unwrap(); @@ -287,6 +291,10 @@ impl Blockstore { && self .perf_samples_cf .compact_range(from_slot, to_slot) + .unwrap_or(false) + && self + .block_height_cf + .compact_range(from_slot, to_slot) .unwrap_or(false); compact_timer.stop(); if !result { diff --git a/ledger/src/blockstore_db.rs b/ledger/src/blockstore_db.rs index 7504005d9c..f197aebe33 100644 --- a/ledger/src/blockstore_db.rs +++ b/ledger/src/blockstore_db.rs @@ -340,6 +340,8 @@ impl Rocks { BlockHeight::NAME, get_cf_options::(&access_type, &oldest_slot), ); + // Don't forget to add to both run_purge_with_stats() and + // compact_storage() in ledger/src/blockstore/blockstore_purge.rs!! let cfs = vec![ (SlotMeta::NAME, meta_cf_descriptor),