Add DeleteBlobFiles API for titan (#541)

* add deleteblobfiles API for titan
Signed-off-by: Connor1996 <zbk602423539@gmail.com>

librocksdb_sys/crocksdb/c.cc

@@ -6310,6 +6310,60 @@ void ctitandb_delete_files_in_ranges_cf(
                         cf->rep, &ranges[0], num_ranges, include_end));
 }
 
+void ctitandb_delete_blob_files_in_range(crocksdb_t* db, const char* start_key,
+                                         size_t start_key_len,
+                                         const char* limit_key,
+                                         size_t limit_key_len,
+                                         unsigned char include_end,
+                                         char** errptr) {
+  Slice a, b;
+  RangePtr range(
+      start_key ? (a = Slice(start_key, start_key_len), &a) : nullptr,
+      limit_key ? (b = Slice(limit_key, limit_key_len), &b) : nullptr);
+
+  SaveError(errptr,
+            static_cast<TitanDB*>(db->rep)->DeleteBlobFilesInRanges(
+                db->rep->DefaultColumnFamily(), &range, 1, include_end));
+}
+
+void ctitandb_delete_blob_files_in_range_cf(
+    crocksdb_t* db, crocksdb_column_family_handle_t* column_family,
+    const char* start_key, size_t start_key_len, const char* limit_key,
+    size_t limit_key_len, unsigned char include_end, char** errptr) {
+  Slice a, b;
+  RangePtr range(
+      start_key ? (a = Slice(start_key, start_key_len), &a) : nullptr,
+      limit_key ? (b = Slice(limit_key, limit_key_len), &b) : nullptr);
+
+  SaveError(errptr, static_cast<TitanDB*>(db->rep)->DeleteBlobFilesInRanges(
+                        column_family->rep, &range, 1, include_end));
+}
+
+void ctitandb_delete_blob_files_in_ranges_cf(
+    crocksdb_t* db, crocksdb_column_family_handle_t* cf,
+    const char* const* start_keys, const size_t* start_keys_lens,
+    const char* const* limit_keys, const size_t* limit_keys_lens,
+    size_t num_ranges, unsigned char include_end, char** errptr) {
+  std::vector<Slice> starts(num_ranges);
+  std::vector<Slice> limits(num_ranges);
+  std::vector<RangePtr> ranges(num_ranges);
+  for (auto i = 0; i < num_ranges; i++) {
+    const Slice* start = nullptr;
+    if (start_keys[i]) {
+      starts[i] = Slice(start_keys[i], start_keys_lens[i]);
+      start = &starts[i];
+    }
+    const Slice* limit = nullptr;
+    if (limit_keys[i]) {
+      limits[i] = Slice(limit_keys[i], limit_keys_lens[i]);
+      limit = &limits[i];
+    }
+    ranges[i] = RangePtr(start, limit);
+  }
+  SaveError(errptr, static_cast<TitanDB*>(db->rep)->DeleteBlobFilesInRanges(
+                        cf->rep, &ranges[0], num_ranges, include_end));
+}
+
 /* RocksDB Cloud */
 #ifdef USE_CLOUD
 struct crocksdb_cloud_envoptions_t {

librocksdb_sys/crocksdb/crocksdb/c.h

@@ -2532,6 +2532,22 @@ extern C_ROCKSDB_LIBRARY_API void ctitandb_delete_files_in_ranges_cf(
     const char* const* limit_keys, const size_t* limit_keys_lens,
     size_t num_ranges, unsigned char include_end, char** errptr);
 
+extern C_ROCKSDB_LIBRARY_API void ctitandb_delete_blob_files_in_range(
+    crocksdb_t* db, const char* start_key, size_t start_key_len,
+    const char* limit_key, size_t limit_key_len, unsigned char include_end,
+    char** errptr);
+
+extern C_ROCKSDB_LIBRARY_API void ctitandb_delete_blob_files_in_range_cf(
+    crocksdb_t* db, crocksdb_column_family_handle_t* column_family,
+    const char* start_key, size_t start_key_len, const char* limit_key,
+    size_t limit_key_len, unsigned char include_end, char** errptr);
+
+extern C_ROCKSDB_LIBRARY_API void ctitandb_delete_blob_files_in_ranges_cf(
+    crocksdb_t* db, crocksdb_column_family_handle_t* cf,
+    const char* const* start_keys, const size_t* start_keys_lens,
+    const char* const* limit_keys, const size_t* limit_keys_lens,
+    size_t num_ranges, unsigned char include_end, char** errptr);
+
 /* RocksDB Cloud */
 
 #ifdef USE_CLOUD

titan @ 46b3a5e4

-Subproject commit 9df8f051619fc6f5161a3f9e1e4fb01fe5332783
+Subproject commit 46b3a5e4b70e87e974fcc00d5e0fc4f4d8cb6982

librocksdb_sys/src/lib.rs

@@ -2543,6 +2543,36 @@ extern "C" {
         include_end: bool,
         errptr: *mut *mut c_char,
     );
+    pub fn ctitandb_delete_blob_files_in_range(
+        db: *mut DBInstance,
+        range_start_key: *const u8,
+        range_start_key_len: size_t,
+        range_limit_key: *const u8,
+        range_limit_key_len: size_t,
+        include_end: bool,
+        err: *mut *mut c_char,
+    );
+    pub fn ctitandb_delete_blob_files_in_range_cf(
+        db: *mut DBInstance,
+        cf: *mut DBCFHandle,
+        range_start_key: *const u8,
+        range_start_key_len: size_t,
+        range_limit_key: *const u8,
+        range_limit_key_len: size_t,
+        include_end: bool,
+        err: *mut *mut c_char,
+    );
+    pub fn ctitandb_delete_blob_files_in_ranges_cf(
+        db: *mut DBInstance,
+        cf: *mut DBCFHandle,
+        start_keys: *const *const u8,
+        start_keys_lens: *const size_t,
+        limit_keys: *const *const u8,
+        limit_keys_lens: *const size_t,
+        num_ranges: size_t,
+        include_end: bool,
+        errptr: *mut *mut c_char,
+    );
 }
 
 // RocksDB Cloud

src/rocksdb.rs

@@ -1446,6 +1446,79 @@ impl DB {
         Ok(())
     }
 
+    pub fn delete_blob_files_in_range(
+        &self,
+        start_key: &[u8],
+        end_key: &[u8],
+        include_end: bool,
+    ) -> Result<(), String> {
+        unsafe {
+            if self.is_titan() {
+                ffi_try!(ctitandb_delete_blob_files_in_range(
+                    self.inner,
+                    start_key.as_ptr(),
+                    start_key.len() as size_t,
+                    end_key.as_ptr(),
+                    end_key.len() as size_t,
+                    include_end
+                ));
+            }
+            Ok(())
+        }
+    }
+
+    pub fn delete_blob_files_in_range_cf(
+        &self,
+        cf: &CFHandle,
+        start_key: &[u8],
+        end_key: &[u8],
+        include_end: bool,
+    ) -> Result<(), String> {
+        unsafe {
+            if self.is_titan() {
+                ffi_try!(ctitandb_delete_blob_files_in_range_cf(
+                    self.inner,
+                    cf.inner,
+                    start_key.as_ptr(),
+                    start_key.len() as size_t,
+                    end_key.as_ptr(),
+                    end_key.len() as size_t,
+                    include_end
+                ));
+            }
+            Ok(())
+        }
+    }
+
+    pub fn delete_blob_files_in_ranges_cf(
+        &self,
+        cf: &CFHandle,
+        ranges: &[Range],
+        include_end: bool,
+    ) -> Result<(), String> {
+        unsafe {
+            if self.is_titan() {
+                let start_keys: Vec<*const u8> =
+                    ranges.iter().map(|x| x.start_key.as_ptr()).collect();
+                let start_keys_lens: Vec<_> = ranges.iter().map(|x| x.start_key.len()).collect();
+                let limit_keys: Vec<*const u8> =
+                    ranges.iter().map(|x| x.end_key.as_ptr()).collect();
+                let limit_keys_lens: Vec<_> = ranges.iter().map(|x| x.end_key.len()).collect();
+                ffi_try!(ctitandb_delete_blob_files_in_ranges_cf(
+                    self.inner,
+                    cf.inner,
+                    start_keys.as_ptr(),
+                    start_keys_lens.as_ptr(),
+                    limit_keys.as_ptr(),
+                    limit_keys_lens.as_ptr(),
+                    ranges.len(),
+                    include_end
+                ));
+            }
+        }
+        Ok(())
+    }
+
     pub fn get_property_value(&self, name: &str) -> Option<String> {
         self.get_property_value_cf_opt(None, name)
     }

tests/cases/test_titan.rs

@@ -287,6 +287,8 @@ fn test_titan_delete_files_in_ranges() {
 
     db.delete_files_in_ranges_cf(cf_handle, &ranges, false)
         .unwrap();
+    db.delete_blob_files_in_ranges_cf(cf_handle, &ranges, false)
+        .unwrap();
 
     // Check that ["key0", "key5"] have been deleted, but ["key6", "key8"] still exist.
     let mut readopts = ReadOptions::new();
@@ -305,6 +307,8 @@ fn test_titan_delete_files_in_ranges() {
     let ranges = vec![Range::new(b"key6", b"key8")];
     db.delete_files_in_ranges_cf(cf_handle, &ranges, true)
         .unwrap();
+    db.delete_blob_files_in_ranges_cf(cf_handle, &ranges, true)
+        .unwrap();
     let mut iter = db.iter();
     iter.seek(SeekKey::Start).unwrap();
     assert!(!iter.valid().unwrap());