fix CI fails

Author: yangweijian

librocksdb-sys/tests/ffi.rs

@@ -24,8 +24,8 @@
 )]
 
 use const_cstr::const_cstr;
+use haizhi_librocksdb_sys::*;
 use libc::*;
-use librocksdb_sys::*;
 use std::borrow::Cow;
 use std::env;
 use std::ffi::{CStr, CString};

src/checkpoint.rs

@@ -18,12 +18,12 @@
 //! [1]: https://github.com/facebook/rocksdb/wiki/Checkpoints
 
 use crate::AsColumnFamilyRef;
-use crate::{ffi, Error, DB};
-use libc::{c_char, int32_t};
+use crate::{ffi, Error};
+use libc::c_char;
 
 use crate::db::DBInner;
 use crate::ffi_util::to_cpath;
-use crate::{ColumnFamily, DBCommon, ThreadMode};
+use crate::{DBCommon, ThreadMode};
 use std::ffi::{CStr, CString};
 use std::fs::File;
 use std::io::{Read, Write};
@@ -215,13 +215,11 @@ impl<'db> Checkpoint<'db> {
         export_dir: P,
     ) -> Result<ExportImportFilesMetaData, Error> {
         let path = export_dir.as_ref();
-        let cpath = if let Ok(c) = CString::new(path.to_string_lossy().as_bytes()) {
-            c
-        } else {
-            return Err(Error::new(
-                "Failed to convert path to CString when creating DB checkpoint".to_owned(),
-            ));
-        };
+        let cpath = CString::new(path.to_string_lossy().as_bytes()).map_err(|err| {
+            Error::new(format!(
+                "Failed to convert path to CString when creating DB checkpoint: {err}"
+            ))
+        })?;
 
         let inner: *mut ffi::rocksdb_export_import_files_metadata_t;
 

src/db.rs

@@ -2036,7 +2036,7 @@ impl<T: ThreadMode, D: DBInner> DBCommon<T, D> {
                 true,
                 true,
                 files_size_error_margin,
-            ))
+            ));
         }
         Ok(sizes)
     }
@@ -2167,13 +2167,11 @@ impl<T: ThreadMode, D: DBInner> DBCommon<T, D> {
         opts: &Options,
         metadata: &ExportImportFilesMetaData,
     ) -> Result<*mut ffi::rocksdb_column_family_handle_t, Error> {
-        let cf_name = if let Ok(c) = CString::new(name.as_bytes()) {
-            c
-        } else {
-            return Err(Error::new(
-                "Failed to convert path to CString when creating cf".to_owned(),
-            ));
-        };
+        let cf_name = CString::new(name.as_bytes()).map_err(|err| {
+            Error::new(format!(
+                "Failed to convert path to CString when creating cf: {err}"
+            ))
+        })?;
         Ok(unsafe {
             ffi_try!(ffi::rocksdb_create_column_family_with_import(
                 self.inner.inner(),

src/properties.rs

@@ -15,18 +15,18 @@ macro_rules! property {
     };
 }
 
-/// "rocksdb.num-files-at-level<N>" - returns string containing the number
-/// of files at level <N>, where <N> is an ASCII representation of a
+/// "rocksdb.num-files-at-level`<N>`" - returns string containing the number
+/// of files at level `<N>`, where `<N>` is an ASCII representation of a
 /// level number (e.g., "0").
 pub fn num_files_at_level(level: usize) -> CString {
     unsafe { level_property("num-files-at-level", level) }
 }
 
-/// "rocksdb.compression-ratio-at-level<N>" - returns string containing the
-/// compression ratio of data at level <N>, where <N> is an ASCII
+/// "rocksdb.compression-ratio-at-level`<N>`" - returns string containing the
+/// compression ratio of data at level `<N>`, where `<N>` is an ASCII
 /// representation of a level number (e.g., "0"). Here, compression
 /// ratio is defined as uncompressed data size / compressed file size.
-/// Returns "-1.0" if no open files at level <N>.
+/// Returns "-1.0" if no open files at level `<N>`.
 pub fn compression_ratio_at_level(level: usize) -> CString {
     unsafe { level_property("compression-ratio-at-level", level) }
 }
@@ -45,7 +45,7 @@ pub const SSTABLES: &CStr = property!("sstables");
 pub const CFSTATS: &CStr = property!("CFSTATS");
 
 /// "rocksdb.cfstats-no-file-histogram" - returns a multi-line string with
-/// general columm family stats per-level over db's lifetime ("L<n>"),
+/// general columm family stats per-level over db's lifetime ("L`<n>`"),
 /// aggregated over db's lifetime ("Sum"), and aggregated over the
 /// interval since the last retrieval ("Int").
 /// It could also be used to return the stats in the format of the map.
@@ -192,7 +192,7 @@ pub const ESTIMATE_PENDING_COMPACTION_BYTES: &CStr = property!("estimate-pending
 /// of the aggregated table properties of the target column family.
 pub const AGGREGATED_TABLE_PROPERTIES: &CStr = property!("aggregated-table-properties");
 
-/// "rocksdb.aggregated-table-properties-at-level<N>", same as the previous
+/// "rocksdb.aggregated-table-properties-at-level`<N>`", same as the previous
 /// one but only returns the aggregated table properties of the
 /// specified level "N" at the target column family.
 pub fn aggregated_table_properties_at_level(level: usize) -> CString {

src/transactions/transaction_db.rs

@@ -300,8 +300,8 @@ impl<T: ThreadMode> TransactionDB<T> {
             let mut cnt = 0;
             let ptr = ffi::rocksdb_transactiondb_get_prepared_transactions(db, &mut cnt);
             let mut vec = vec![std::ptr::null_mut(); cnt];
-            std::ptr::copy_nonoverlapping(ptr, vec.as_mut_ptr(), cnt);
             if !ptr.is_null() {
+                std::ptr::copy_nonoverlapping(ptr, vec.as_mut_ptr(), cnt);
                 ffi::rocksdb_free(ptr as *mut c_void);
             }
             vec

tests/fail/iterator_outlive_db.stderr

@@ -6,6 +6,6 @@ error[E0597]: `db` does not live long enough
 6 |         let db = DB::open_default("foo").unwrap();
   |             -- binding `db` declared here
 7 |         db.iterator(IteratorMode::Start)
-  |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ borrowed value does not live long enough
+  |         ^^ borrowed value does not live long enough
 8 |     };
   |     - `db` dropped here while still borrowed

tests/fail/open_with_multiple_refs_as_single_threaded.stderr

@@ -2,20 +2,20 @@ error[E0596]: cannot borrow `*db_ref1` as mutable, as it is behind a `&` referen
  --> tests/fail/open_with_multiple_refs_as_single_threaded.rs:9:5
   |
 9 |     db_ref1.create_cf("cf1", &opts).unwrap();
-  |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `db_ref1` is a `&` reference, so the data it refers to cannot be borrowed as mutable
+  |     ^^^^^^^ `db_ref1` is a `&` reference, so the data it refers to cannot be borrowed as mutable
   |
 help: consider changing this to be a mutable reference
   |
 6 |     let db_ref1 = &mut db;
-  |                   ~~~~~~~
+  |                    +++
 
 error[E0596]: cannot borrow `*db_ref2` as mutable, as it is behind a `&` reference
   --> tests/fail/open_with_multiple_refs_as_single_threaded.rs:10:5
    |
 10 |     db_ref2.create_cf("cf2", &opts).unwrap();
-   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ `db_ref2` is a `&` reference, so the data it refers to cannot be borrowed as mutable
+   |     ^^^^^^^ `db_ref2` is a `&` reference, so the data it refers to cannot be borrowed as mutable
    |
 help: consider changing this to be a mutable reference
    |
 7  |     let db_ref2 = &mut db;
-   |                   ~~~~~~~
+   |                    +++

tests/fail/snapshot_outlive_db.stderr

@@ -6,6 +6,6 @@ error[E0597]: `db` does not live long enough
 6 |         let db = DB::open_default("foo").unwrap();
   |             -- binding `db` declared here
 7 |         db.snapshot()
-  |         ^^^^^^^^^^^^^ borrowed value does not live long enough
+  |         ^^ borrowed value does not live long enough
 8 |     };
   |     - `db` dropped here while still borrowed

tests/fail/snapshot_outlive_transaction.stderr

@@ -6,6 +6,6 @@ error[E0597]: `txn` does not live long enough
 7 |         let txn = db.transaction();
   |             --- binding `txn` declared here
 8 |         txn.snapshot()
-  |         ^^^^^^^^^^^^^^ borrowed value does not live long enough
+  |         ^^^ borrowed value does not live long enough
 9 |     };
   |     - `txn` dropped here while still borrowed

tests/fail/snapshot_outlive_transaction_db.stderr

@@ -6,6 +6,6 @@ error[E0597]: `db` does not live long enough
 6 |         let db = TransactionDB::<SingleThreaded>::open_default("foo").unwrap();
   |             -- binding `db` declared here
 7 |         db.snapshot()
-  |         ^^^^^^^^^^^^^ borrowed value does not live long enough
+  |         ^^ borrowed value does not live long enough
 8 |     };
   |     - `db` dropped here while still borrowed