update rocksdb and add largest_seqno to MemtableInfo (#723)

* update rocksdb

Signed-off-by: 5kbpers <[email protected]>

Author: 5kbpers

librocksdb_sys/crocksdb/c.cc

@@ -2353,6 +2353,10 @@ uint64_t crocksdb_memtableinfo_earliest_seqno(
     const crocksdb_memtableinfo_t* info) {
   return info->rep.earliest_seqno;
 }
+uint64_t crocksdb_memtableinfo_largest_seqno(
+    const crocksdb_memtableinfo_t* info) {
+  return info->rep.largest_seqno;
+}
 uint64_t crocksdb_memtableinfo_num_entries(
     const crocksdb_memtableinfo_t* info) {
   return info->rep.num_entries;

librocksdb_sys/crocksdb/crocksdb/c.h

@@ -934,6 +934,8 @@ crocksdb_memtableinfo_first_seqno(const crocksdb_memtableinfo_t*);
 extern C_ROCKSDB_LIBRARY_API uint64_t
 crocksdb_memtableinfo_earliest_seqno(const crocksdb_memtableinfo_t*);
 extern C_ROCKSDB_LIBRARY_API uint64_t
+crocksdb_memtableinfo_largest_seqno(const crocksdb_memtableinfo_t*);
+extern C_ROCKSDB_LIBRARY_API uint64_t
 crocksdb_memtableinfo_num_entries(const crocksdb_memtableinfo_t*);
 extern C_ROCKSDB_LIBRARY_API uint64_t
 crocksdb_memtableinfo_num_deletes(const crocksdb_memtableinfo_t*);

librocksdb_sys/rocksdb

@@ -2299,6 +2299,7 @@ extern "C" {
     ) -> *const c_char;
     pub fn crocksdb_memtableinfo_first_seqno(info: *const DBMemTableInfo) -> u64;
     pub fn crocksdb_memtableinfo_earliest_seqno(info: *const DBMemTableInfo) -> u64;
+    pub fn crocksdb_memtableinfo_largest_seqno(info: *const DBMemTableInfo) -> u64;
     pub fn crocksdb_memtableinfo_num_entries(info: *const DBMemTableInfo) -> u64;
     pub fn crocksdb_memtableinfo_num_deletes(info: *const DBMemTableInfo) -> u64;
 

librocksdb_sys/src/lib.rs

@@ -243,6 +243,9 @@ impl MemTableInfo {
     pub fn earliest_seqno(&self) -> u64 {
         unsafe { crocksdb_ffi::crocksdb_memtableinfo_earliest_seqno(&self.0) }
     }
+    pub fn largest_seqno(&self) -> u64 {
+        unsafe { crocksdb_ffi::crocksdb_memtableinfo_largest_seqno(&self.0) }
+    }
     pub fn num_entries(&self) -> u64 {
         unsafe { crocksdb_ffi::crocksdb_memtableinfo_num_entries(&self.0) }
     }

src/event_listener.rs

@@ -41,6 +41,18 @@ impl Drop for EventCounter {
 }
 
 impl EventListener for EventCounter {
+    fn on_memtable_sealed(&self, info: &MemTableInfo) {
+        assert!(!info.cf_name().is_empty());
+        assert_ne!(info.largest_seqno(), 0);
+        assert!(info.earliest_seqno() <= info.largest_seqno());
+    }
+
+    fn on_flush_begin(&self, info: &FlushJobInfo) {
+        assert!(!info.cf_name().is_empty());
+        assert_ne!(info.largest_seqno(), 0);
+        assert!(info.smallest_seqno() <= info.largest_seqno());
+    }
+
     fn on_flush_completed(&self, info: &FlushJobInfo) {
         assert!(!info.cf_name().is_empty());
         assert!(info.file_path().exists());