Mercurial > lbo > hg > leveldb-rs

changeset 258:584c1b892ede

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
table_builder and related: Check table_builder methods for errors in tests.
author Lewin Bormann <lbo@spheniscida.de>
date Tue, 19 Sep 2017 17:02:57 +0200
parents 464b4a3e87d2
children 7438d34192ee
files src/table_builder.rs src/table_cache.rs src/table_reader.rs
diffstat 3 files changed, 12 insertions(+), 10 deletions(-) [+]
line wrap: on
line diff
--- a/src/table_builder.rs	Tue Sep 19 17:01:56 2017 +0200
+++ b/src/table_builder.rs	Tue Sep 19 17:02:57 2017 +0200
@@ -243,6 +243,7 @@
         footer.encode(&mut buf);
 
         self.offset += self.dst.write(&buf[..])?;
+        self.dst.flush()?;
         Ok(self.offset)
     }
 }
@@ -278,12 +279,12 @@
         let data2 = vec![("abd", "def"), ("abf", "dee"), ("ccd", "asa"), ("dcd", "a00")];
 
         for i in 0..data.len() {
-            b.add(&data[i].0.as_bytes(), &data[i].1.as_bytes());
-            b.add(&data2[i].0.as_bytes(), &data2[i].1.as_bytes());
+            b.add(&data[i].0.as_bytes(), &data[i].1.as_bytes()).unwrap();
+            b.add(&data2[i].0.as_bytes(), &data2[i].1.as_bytes()).unwrap();
         }
 
         assert!(b.filter_block.is_some());
-        b.finish();
+        b.finish().unwrap();
     }
 
     #[test]
@@ -298,7 +299,8 @@
         let data = vec![("abc", "def"), ("abc", "dee"), ("bcd", "asa"), ("bsr", "a00")];
 
         for &(k, v) in data.iter() {
-            b.add(k.as_bytes(), v.as_bytes());
+            b.add(k.as_bytes(), v.as_bytes()).unwrap();
         }
+        b.finish().unwrap();
     }
 }
--- a/src/table_cache.rs	Tue Sep 19 17:01:56 2017 +0200
+++ b/src/table_cache.rs	Tue Sep 19 17:02:57 2017 +0200
@@ -111,9 +111,9 @@
         let data = vec![("abc", "def"), ("abd", "dee"), ("bcd", "asa"), ("bsr", "a00")];
 
         for &(k, v) in data.iter() {
-            b.add(k.as_bytes(), v.as_bytes());
+            b.add(k.as_bytes(), v.as_bytes()).unwrap();
         }
-        b.finish();
+        b.finish().unwrap();
     }
 
     #[test]
--- a/src/table_reader.rs	Tue Sep 19 17:01:56 2017 +0200
+++ b/src/table_reader.rs	Tue Sep 19 17:02:57 2017 +0200
@@ -431,10 +431,10 @@
             let mut b = TableBuilder::new_raw(opt, &mut d);
 
             for &(k, v) in data.iter() {
-                b.add(k.as_bytes(), v.as_bytes());
+                b.add(k.as_bytes(), v.as_bytes()).unwrap();
             }
 
-            b.finish();
+            b.finish().unwrap();
 
         }
 
@@ -465,10 +465,10 @@
             let mut b = TableBuilder::new(opt, &mut d);
 
             for &(ref k, ref v) in data.iter() {
-                b.add(k.as_slice(), v.as_bytes());
+                b.add(k.as_slice(), v.as_bytes()).unwrap();
             }
 
-            b.finish();
+            b.finish().unwrap();
         }
 
         let size = d.len();