set base compaction threads (#55)

librocksdb_sys/src/lib.rs

@@ -250,6 +250,8 @@ extern "C" {
     pub fn crocksdb_options_set_compression_per_level(options: *mut DBOptions,
                                                       level_values: *const DBCompressionType,
                                                       num_levels: size_t);
+    pub fn crocksdb_options_set_base_background_compactions(optinos: *mut DBOptions,
+                                                            base_bg_compactions: c_int);
     pub fn crocksdb_options_set_max_background_compactions(options: *mut DBOptions,
                                                            max_bg_compactions: c_int);
     pub fn crocksdb_options_set_max_background_flushes(options: *mut DBOptions,

src/rocksdb_options.rs

@@ -578,6 +578,12 @@ impl Options {
         }
     }
 
+    pub fn set_base_background_compactions(&mut self, n: c_int) {
+        unsafe {
+            crocksdb_ffi::crocksdb_options_set_base_background_compactions(self.inner, n);
+        }
+    }
+
     pub fn set_max_background_compactions(&mut self, n: c_int) {
         unsafe {
             crocksdb_ffi::crocksdb_options_set_max_background_compactions(self.inner, n);

tests/test_rocksdb_options.rs

@@ -308,3 +308,12 @@ fn test_writable_file_max_buffer_size() {
     opts.set_writable_file_max_buffer_size(1024 * 1024);
     DB::open(opts, path.path().to_str().unwrap()).unwrap();
 }
+
+#[test]
+fn test_set_base_background_compactions() {
+    let path = TempDir::new("_rust_rocksdb_base_background_compactions").expect("");
+    let mut opts = Options::new();
+    opts.create_if_missing(true);
+    opts.set_base_background_compactions(4);
+    DB::open(opts, path.path().to_str().unwrap()).unwrap();
+}