*: Fix more clippy warnings.

Cargo.toml

@@ -25,3 +25,4 @@ path = "test/test.rs"
 
 [dependencies]
 libc = "0.1.8"
+clippy = "*"

src/ffi.rs

@@ -67,19 +67,19 @@ pub fn new_cache(capacity: size_t) -> DBCache {
 
 #[repr(C)]
 pub enum DBCompressionType {
-    DBNoCompression = 0,
-    DBSnappyCompression = 1,
-    DBZlibCompression = 2,
-    DBBz2Compression = 3,
-    DBLz4Compression = 4,
-    DBLz4hcCompression = 5,
+    DBNo = 0,
+    DBSnappy = 1,
+    DBZlib = 2,
+    DBBz2 = 3,
+    DBLz4 = 4,
+    DBLz4hc = 5,
 }
 
 #[repr(C)]
 pub enum DBCompactionStyle {
-    DBLevelCompaction = 0,
-    DBUniversalCompaction = 1,
-    DBFifoCompaction = 2,
+    DBLevel = 0,
+    DBUniversal = 1,
+    DBFifo = 2,
 }
 
 #[repr(C)]

src/lib.rs

@@ -12,6 +12,9 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 //
+#![feature(plugin)]
+
+#![plugin(clippy)]
 pub use ffi as rocksdb_ffi;
 pub use ffi::{DBCompactionStyle, DBComparator, new_bloom_filter};
 pub use rocksdb::{DB, DBIterator, DBVector, Direction, IteratorMode, Writable,

src/main.rs

@@ -144,7 +144,7 @@ fn main() {
 #[cfg(test)]
 mod tests {
     use rocksdb::{BlockBasedOptions, DB, Options};
-    use rocksdb::DBCompactionStyle::DBUniversalCompaction;
+    use rocksdb::DBCompactionStyle::DBUniversal;
 
     fn tuned_for_somebody_elses_disk(path: &str,
                                      opts: &mut Options,
@@ -163,7 +163,7 @@ mod tests {
         opts.set_min_write_buffer_number_to_merge(4);
         opts.set_level_zero_stop_writes_trigger(2000);
         opts.set_level_zero_slowdown_writes_trigger(0);
-        opts.set_compaction_style(DBUniversalCompaction);
+        opts.set_compaction_style(DBUniversal);
         opts.set_max_background_compactions(4);
         opts.set_max_background_flushes(4);
         opts.set_filter_deletes(false);

src/merge_operator.rs

@@ -128,9 +128,10 @@ impl MergeOperands {
 impl<'a> Iterator for &'a mut MergeOperands {
     type Item = &'a [u8];
     fn next(&mut self) -> Option<&'a [u8]> {
-        match self.cursor == self.num_operands {
-            true => None,
-            false => unsafe {
+        if self.cursor == self.num_operands {
+            None
+        } else {
+            unsafe {
                 let base = self.operands_list as usize;
                 let base_len = self.operands_list_len as usize;
                 let spacing = mem::size_of::<*const *const u8>();
@@ -142,7 +143,7 @@ impl<'a> Iterator for &'a mut MergeOperands {
                 self.cursor += 1;
                 Some(mem::transmute(slice::from_raw_parts(*(ptr as *const *const u8)
                         as *const u8, len)))
-            },
+            }
         }
     }
 
@@ -160,13 +161,10 @@ fn test_provided_merge(new_key: &[u8],
                        -> Vec<u8> {
     let nops = operands.size_hint().0;
     let mut result: Vec<u8> = Vec::with_capacity(nops);
-    match existing_val {
-        Some(v) => {
-            for e in v {
-                result.push(*e);
-            }
+    if let Some(v) = existing_val {
+        for e in v {
+            result.push(*e);
         }
-        None => (),
     }
     for op in operands {
         for e in op {

src/rocksdb.rs

@@ -111,10 +111,7 @@ pub enum IteratorMode<'a> {
 
 
 impl DBIterator {
-    fn new<'b>(db: &DB,
-               readopts: &'b ReadOptions,
-               mode: IteratorMode)
-               -> DBIterator {
+    fn new(db: &DB, readopts: &ReadOptions, mode: IteratorMode) -> DBIterator {
         unsafe {
             let iterator = rocksdb_ffi::rocksdb_create_iterator(db.inner,
                                                                 readopts.inner);
@@ -249,19 +246,18 @@ impl DB {
             Err(_) => {
                 return Err("Failed to convert path to CString when opening \
                             rocksdb"
-                               .to_string())
+                               .to_owned())
             }
         };
         let cpath_ptr = cpath.as_ptr();
 
         let ospath = Path::new(path);
-        match fs::create_dir_all(&ospath) {
-            Err(e) => {
-                return Err(format!("Failed to create rocksdb directory: \
-                                      {:?}",
-                                   e))
-            }
-            Ok(_) => (),
+
+        if let Err(e) = fs::create_dir_all(&ospath) {
+            return Err(format!("Failed to create rocksdb directory: \
+                                src/rocksdb.rs:                              \
+                                {:?}",
+                               e));
         }
 
         let mut err: *const i8 = 0 as *const i8;
@@ -318,15 +314,15 @@ impl DB {
                                                                copts, handles, err_ptr);
             }
 
-            for handle in cfhandles.iter() {
+            for handle in &cfhandles {
                 if handle.0.is_null() {
                     return Err("Received null column family handle from DB."
-                                   .to_string());
+                                   .to_owned());
                 }
             }
 
             for (n, h) in cfs_v.iter().zip(cfhandles) {
-                cf_map.insert(n.to_string(), h);
+                cf_map.insert((*n).to_owned(), h);
             }
         }
 
@@ -334,7 +330,7 @@ impl DB {
             return Err(error_message(err));
         }
         if db.0.is_null() {
-            return Err("Could not initialize database.".to_string());
+            return Err("Could not initialize database.".to_owned());
         }
 
         Ok(DB {
@@ -392,7 +388,7 @@ impl DB {
         if !err.is_null() {
             return Err(error_message(err));
         }
-        return Ok(());
+        Ok(())
     }
 
     pub fn write(&self, batch: WriteBatch) -> Result<(), String> {
@@ -407,7 +403,7 @@ impl DB {
                             a fairly trivial call, and its failure may be \
                             indicative of a mis-compiled or mis-loaded \
                             rocksdb library."
-                               .to_string());
+                               .to_owned());
             }
 
             let val_len: size_t = 0;
@@ -416,7 +412,7 @@ impl DB {
             let err_ptr: *mut *const i8 = &mut err;
             let val =
                 rocksdb_ffi::rocksdb_get(self.inner,
-                                         readopts.clone(),
+                                         readopts,
                                          key.as_ptr(),
                                          key.len() as size_t,
                                          val_len_ptr,
@@ -425,9 +421,10 @@ impl DB {
             if !err.is_null() {
                 return Err(error_message(err));
             }
-            match val.is_null() {
-                true => Ok(None),
-                false => Ok(Some(DBVector::from_c(val, val_len))),
+            if val.is_null() {
+                Ok(None)
+            } else {
+                Ok(Some(DBVector::from_c(val, val_len)))
             }
         }
     }
@@ -443,7 +440,7 @@ impl DB {
                             a fairly trivial call, and its failure may be \
                             indicative of a mis-compiled or mis-loaded \
                             rocksdb library."
-                               .to_string());
+                               .to_owned());
             }
 
             let val_len: size_t = 0;
@@ -452,7 +449,7 @@ impl DB {
             let err_ptr: *mut *const i8 = &mut err;
             let val =
                 rocksdb_ffi::rocksdb_get_cf(self.inner,
-                                            readopts.clone(),
+                                            readopts,
                                             cf,
                                             key.as_ptr(),
                                             key.len() as size_t,
@@ -462,9 +459,10 @@ impl DB {
             if !err.is_null() {
                 return Err(error_message(err));
             }
-            match val.is_null() {
-                true => Ok(None),
-                false => Ok(Some(DBVector::from_c(val, val_len))),
+            if val.is_null() {
+                Ok(None)
+            } else {
+                Ok(Some(DBVector::from_c(val, val_len)))
             }
         }
     }
@@ -478,7 +476,7 @@ impl DB {
             Err(_) => {
                 return Err("Failed to convert path to CString when opening \
                             rocksdb"
-                               .to_string())
+                               .to_owned())
             }
         };
         let cname_ptr = cname.as_ptr();
@@ -490,7 +488,7 @@ impl DB {
                                                           opts.inner,
                                                           cname_ptr as *const _,
                                                           err_ptr);
-            self.cfs.insert(name.to_string(), cf_handler);
+            self.cfs.insert(name.to_owned(), cf_handler);
             cf_handler
         };
         if !err.is_null() {
@@ -502,7 +500,7 @@ impl DB {
     pub fn drop_cf(&mut self, name: &str) -> Result<(), String> {
         let cf = self.cfs.get(name);
         if cf.is_none() {
-            return Err(format!("Invalid column family: {}", name).to_string());
+            return Err(format!("Invalid column family: {}", name).clone());
         }
 
         let mut err: *const i8 = 0 as *const i8;
@@ -720,7 +718,7 @@ impl Drop for WriteBatch {
 impl Drop for DB {
     fn drop(&mut self) {
         unsafe {
-            for (_, cf) in self.cfs.iter() {
+            for cf in self.cfs.values() {
                 rocksdb_ffi::rocksdb_column_family_handle_destroy(*cf);
             }
             rocksdb_ffi::rocksdb_close(self.inner);
@@ -861,7 +859,7 @@ impl DBVector {
         }
     }
 
-    pub fn to_utf8<'a>(&'a self) -> Option<&'a str> {
+    pub fn to_utf8(&self) -> Option<&str> {
         from_utf8(self.deref()).ok()
     }
 }

src/rocksdb_options.rs

@@ -136,12 +136,12 @@ impl Options {
         }
     }
 
-    pub fn add_merge_operator<'a>(&mut self,
-                                  name: &str,
-                                  merge_fn: fn(&[u8],
-                                               Option<&[u8]>,
-                                               &mut MergeOperands)
-                                               -> Vec<u8>) {
+    pub fn add_merge_operator(&mut self,
+                              name: &str,
+                              merge_fn: fn(&[u8],
+                                           Option<&[u8]>,
+                                           &mut MergeOperands)
+                                           -> Vec<u8>) {
         let cb = Box::new(MergeOperatorCallback {
             name: CString::new(name.as_bytes()).unwrap(),
             merge_fn: merge_fn,
@@ -159,9 +159,9 @@ impl Options {
         }
     }
 
-    pub fn add_comparator<'a>(&mut self,
-                              name: &str,
-                              compare_fn: fn(&[u8], &[u8]) -> i32) {
+    pub fn add_comparator(&mut self,
+                          name: &str,
+                          compare_fn: fn(&[u8], &[u8]) -> i32) {
         let cb = Box::new(ComparatorCallback {
             name: CString::new(name.as_bytes()).unwrap(),
             f: compare_fn,
@@ -193,13 +193,10 @@ impl Options {
 
     pub fn set_use_fsync(&mut self, useit: bool) {
         unsafe {
-            match useit {
-                true => {
-                    rocksdb_ffi::rocksdb_options_set_use_fsync(self.inner, 1)
-                }
-                false => {
-                    rocksdb_ffi::rocksdb_options_set_use_fsync(self.inner, 0)
-                }
+            if useit {
+                rocksdb_ffi::rocksdb_options_set_use_fsync(self.inner, 1)
+            } else {
+                rocksdb_ffi::rocksdb_options_set_use_fsync(self.inner, 0)
             }
         }
     }
@@ -212,13 +209,12 @@ impl Options {
 
     pub fn set_disable_data_sync(&mut self, disable: bool) {
         unsafe {
-            match disable {
-                true =>
-                    rocksdb_ffi::rocksdb_options_set_disable_data_sync(
-                        self.inner, 1),
-                false =>
-                    rocksdb_ffi::rocksdb_options_set_disable_data_sync(
-                        self.inner, 0),
+            if disable {
+                rocksdb_ffi::rocksdb_options_set_disable_data_sync(self.inner,
+                                                                   1);
+            } else {
+                rocksdb_ffi::rocksdb_options_set_disable_data_sync(self.inner,
+                                                                   0);
             }
         }
     }