Update Titan (#299)

* add titan blob-run-mode

* checkout latest bug fix and titan stats

librocksdb_sys/crocksdb/c.cc

@@ -170,6 +170,7 @@ using rocksdb::titandb::TitanCFOptions;
 using rocksdb::titandb::TitanDB;
 using rocksdb::titandb::TitanDBOptions;
 using rocksdb::titandb::TitanOptions;
+using rocksdb::titandb::TitanBlobRunMode;
 
 using std::shared_ptr;
 
@@ -5103,4 +5104,9 @@ void ctitandb_options_set_sample_ratio(ctitandb_options_t* options,
   options->rep.sample_file_size_ratio = ratio;
 }
 
+void ctitandb_options_set_blob_run_mode(ctitandb_options_t* options,
+                                        int mode) {
+  options->rep.blob_run_mode = static_cast<TitanBlobRunMode>(mode);
+}
+
 }  // end extern "C"

titan @ ec440e2a

-Subproject commit c673677c138e2f652b5da332598300762588e4ab
+Subproject commit ec440e2a17dd41910f92453be3aaa7e9acc644b8

librocksdb_sys/src/lib.rs

@@ -272,6 +272,14 @@ pub enum DBRateLimiterMode {
     AllIo = 3,
 }
 
+#[derive(Copy, Clone, Debug, Eq, PartialEq)]
+#[repr(C)]
+pub enum DBTitanDBBlobRunMode {
+    Normal = 0,
+    ReadOnly = 1,
+    Fallback = 2,
+}
+
 pub fn error_message(ptr: *mut c_char) -> String {
     let c_str = unsafe { CStr::from_ptr(ptr) };
     let s = format!("{}", c_str.to_string_lossy());
@@ -1849,6 +1857,7 @@ extern "C" {
     pub fn ctitandb_options_set_discardable_ratio(opts: *mut DBTitanDBOptions, ratio: f64);
     pub fn ctitandb_options_set_sample_ratio(opts: *mut DBTitanDBOptions, ratio: f64);
     pub fn ctitandb_options_set_merge_small_file_threshold(opts: *mut DBTitanDBOptions, size: u64);
+    pub fn ctitandb_options_set_blob_run_mode(opts: *mut DBTitanDBOptions, t: DBTitanDBBlobRunMode);
 }
 
 #[cfg(test)]

src/lib.rs

@@ -28,7 +28,7 @@ pub use librocksdb_sys::{
     self as crocksdb_ffi, new_bloom_filter, CompactionPriority, CompactionReason,
     DBBottommostLevelCompaction, DBCompactionStyle, DBCompressionType, DBEntryType, DBInfoLogLevel,
     DBRateLimiterMode, DBRecoveryMode, DBStatisticsHistogramType, DBStatisticsTickerType,
-    WriteStallCondition,
+    DBTitanDBBlobRunMode, WriteStallCondition,
 };
 pub use merge_operator::MergeOperands;
 pub use metadata::{ColumnFamilyMetaData, LevelMetaData, SstFileMetaData};

src/titan.rs

@@ -2,7 +2,7 @@ use std::ffi::{CStr, CString};
 use std::ops::Deref;
 
 use crocksdb_ffi::{self, DBCompressionType, DBTitanBlobIndex, DBTitanDBOptions};
-use librocksdb_sys::ctitandb_encode_blob_index;
+use librocksdb_sys::{ctitandb_encode_blob_index, DBTitanDBBlobRunMode};
 use rocksdb::Cache;
 use rocksdb_options::LRUCacheOptions;
 use std::ops::DerefMut;
@@ -117,6 +117,12 @@ impl TitanDBOptions {
             crocksdb_ffi::ctitandb_options_set_merge_small_file_threshold(self.inner, size);
         }
     }
+
+    pub fn set_blob_run_mode(&mut self, t: DBTitanDBBlobRunMode) {
+        unsafe {
+            crocksdb_ffi::ctitandb_options_set_blob_run_mode(self.inner, t);
+        }
+    }
 }
 
 impl Drop for TitanDBOptions {