Commit ca977812 authored by siddontang's avatar siddontang

*: Address comment

parent eb27fcf7
...@@ -831,17 +831,19 @@ impl DB { ...@@ -831,17 +831,19 @@ impl DB {
sizes sizes
} }
pub fn delete_file_in_range(&self, r: Range) -> Result<(), String> { pub fn delete_file_in_range(&self,
start_key: &[u8],
end_key: &[u8])
-> Result<(), String> {
unsafe { unsafe {
let mut err: *const i8 = 0 as *const i8; let mut err: *const i8 = 0 as *const i8;
let err_ptr: *mut *const i8 = &mut err;
rocksdb_ffi::rocksdb_delete_file_in_range(self.inner, rocksdb_ffi::rocksdb_delete_file_in_range(self.inner,
r.start_key.as_ptr(), start_key.as_ptr(),
r.start_key.len() as size_t, start_key.len() as size_t,
r.end_key.as_ptr(), end_key.as_ptr(),
r.end_key.len() as size_t, end_key.len() as size_t,
err_ptr); &mut err);
if !err.is_null() { if !err.is_null() {
return Err(error_message(err)); return Err(error_message(err));
} }
...@@ -851,19 +853,19 @@ impl DB { ...@@ -851,19 +853,19 @@ impl DB {
pub fn delete_file_in_range_cf(&self, pub fn delete_file_in_range_cf(&self,
cf: DBCFHandle, cf: DBCFHandle,
r: Range) start_key: &[u8],
end_key: &[u8])
-> Result<(), String> { -> Result<(), String> {
unsafe { unsafe {
let mut err: *const i8 = 0 as *const i8; let mut err: *const i8 = 0 as *const i8;
let err_ptr: *mut *const i8 = &mut err;
rocksdb_ffi::rocksdb_delete_file_in_range_cf(self.inner, rocksdb_ffi::rocksdb_delete_file_in_range_cf(self.inner,
cf, cf,
r.start_key.as_ptr(), start_key.as_ptr(),
r.start_key.len() as size_t, start_key.len() as size_t,
r.end_key.as_ptr(), end_key.as_ptr(),
r.end_key.len() as size_t, end_key.len() as size_t,
err_ptr); &mut err);
if !err.is_null() { if !err.is_null() {
return Err(error_message(err)); return Err(error_message(err));
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment