(Ledger-Tool) Add command --purge-older-slots

ledger-tool/src/main.rs

@@ -1491,6 +1491,19 @@ fn main() {
                     .help("Target db"),
             )
         )
+        .subcommand(
+            SubCommand::with_name("purge-older-slots")
+            .about("Purge the slots that is older than or equal to the specified slot")
+            .arg(
+                Arg::with_name("ending_slot")
+                    .long("ending-slot")
+                    .value_name("SLOT")
+                    .takes_value(true)
+                    .required(true)
+                    .help("The latest slot to be purged.  Anything that is older than \
+                           this slot will be purged.")
+            )
+        )
         .subcommand(
             SubCommand::with_name("slot")
             .about("Print the contents of one or more slots")
@@ -2192,6 +2205,31 @@ fn main() {
                     }
                 }
             }
+            ("purge-older-slots", Some(arg_matches)) => {
+                let ending_slot = value_t_or_exit!(arg_matches, "ending_slot", Slot);
+                let blockstore = open_blockstore(
+                    &ledger_path,
+                    AccessType::Primary,
+                    wal_recovery_mode,
+                    &shred_storage_type,
+                    force_update_to_open,
+                );
+                match blockstore.run_purge(
+                    0, // from_slot
+                    ending_slot,
+                    PurgeType::CompactionFilter,
+                ) {
+                    Ok(columns_purged) => {
+                        if !columns_purged {
+                            eprintln!(
+                                "Internal error.  The purge process on some \
+                                      columns might not be successful."
+                            );
+                        }
+                    }
+                    Err(_) => eprintln!("Internal error. Failed to submit the purge request.",),
+                }
+            }
             ("genesis", Some(arg_matches)) => {
                 let genesis_config = open_genesis_config_by(&ledger_path, arg_matches);
                 let print_accouunts = arg_matches.is_present("accounts");

ledger/src/blockstore/blockstore_purge.rs

@@ -136,12 +136,11 @@ impl Blockstore {
         }
     }
 
-    pub(crate) fn run_purge(
-        &self,
-        from_slot: Slot,
-        to_slot: Slot,
-        purge_type: PurgeType,
-    ) -> Result<bool> {
+    /// Purge any slots within the specified slot range for all slot-based columns.
+    ///
+    /// Note that `from_slot` is 0, any sst-file with a slot-range completely older
+    /// than `to_slot` will be deleted immediately.
+    pub fn run_purge(&self, from_slot: Slot, to_slot: Slot, purge_type: PurgeType) -> Result<bool> {
         self.run_purge_with_stats(from_slot, to_slot, purge_type, &mut PurgeStats::default())
     }