changeset 496:6ee8f9d6116e

rustfmt
author Lewin Bormann <lbo@spheniscida.de>
date Sun, 06 Oct 2019 11:17:56 +0200
parents 8b8d885da925
children 0d93c476675f
files src/db_impl.rs
diffstat 1 files changed, 17 insertions(+), 17 deletions(-) [+]
line wrap: on
line diff
--- a/src/db_impl.rs	Sun Oct 06 11:16:55 2019 +0200
+++ b/src/db_impl.rs	Sun Oct 06 11:17:56 2019 +0200
@@ -70,14 +70,14 @@
             let log = open_info_log(opt.env.as_ref().as_ref(), name);
             opt.log = Some(share(log));
         }
-	let path = name.canonicalize().unwrap_or(name.to_owned());
+        let path = name.canonicalize().unwrap_or(name.to_owned());
 
         let cache = share(TableCache::new(&name, opt.clone(), opt.max_open_files - 10));
         let vset = VersionSet::new(&name, opt.clone(), cache.clone());
 
         DB {
             name: name.to_owned(),
-	    path: path,
+            path: path,
             lock: None,
             internal_cmp: Rc::new(Box::new(InternalKeyCmp(opt.cmp.clone()))),
             fpol: InternalFilterPolicy::new(opt.filter_policy.clone()),
@@ -143,26 +143,26 @@
         ve.set_last_seq(0);
 
         {
-            let manifest = manifest_file_name(&self.name, 1);
+            let manifest = manifest_file_name(&self.path, 1);
             let manifest_file = self.opt.env.open_writable_file(Path::new(&manifest))?;
             let mut lw = LogWriter::new(manifest_file);
             lw.add_record(&ve.encode())?;
             lw.flush()?;
         }
-        set_current_file(&self.opt.env, &self.name, 1)
+        set_current_file(&self.opt.env, &self.path, 1)
     }
 
     /// recover recovers from the existing state on disk. If the wrapped result is `true`, then
     /// log_and_apply() should be called after recovery has finished.
     fn recover(&mut self, ve: &mut VersionEdit) -> Result<bool> {
-        if self.opt.error_if_exists && self.opt.env.exists(&self.name.as_ref()).unwrap_or(false) {
+        if self.opt.error_if_exists && self.opt.env.exists(&self.path.as_ref()).unwrap_or(false) {
             return err(StatusCode::AlreadyExists, "database already exists");
         }
 
-        let _ = self.opt.env.mkdir(Path::new(&self.name));
+        let _ = self.opt.env.mkdir(Path::new(&self.path));
         self.acquire_lock()?;
 
-        if let Err(e) = read_current_file(&self.opt.env, &self.name) {
+        if let Err(e) = read_current_file(&self.opt.env, &self.path) {
             if e.code == StatusCode::NotFound && self.opt.create_if_missing {
                 self.initialize_db()?;
             } else {
@@ -179,7 +179,7 @@
 
         // Recover from all log files not in the descriptor.
         let mut max_seq = 0;
-        let filenames = self.opt.env.children(&self.name)?;
+        let filenames = self.opt.env.children(&self.path)?;
         let mut expected = self.vset.borrow().live_files();
         let mut log_files = vec![];
 
@@ -227,7 +227,7 @@
         is_last: bool,
         ve: &mut VersionEdit,
     ) -> Result<(bool, SequenceNumber)> {
-        let filename = log_file_name(&self.name, log_num);
+        let filename = log_file_name(&self.path, log_num);
         let logfile = self.opt.env.open_sequential_file(Path::new(&filename))?;
         // Use the user-supplied comparator; it will be wrapped inside a MemtableKeyCmp.
         let cmp: Rc<Box<dyn Cmp>> = self.opt.cmp.clone();
@@ -296,7 +296,7 @@
     /// delete_obsolete_files removes files that are no longer needed from the file system.
     fn delete_obsolete_files(&mut self) -> Result<()> {
         let files = self.vset.borrow().live_files();
-        let filenames = self.opt.env.children(Path::new(&self.name))?;
+        let filenames = self.opt.env.children(Path::new(&self.path))?;
         for name in filenames {
             if let Ok((num, typ)) = parse_file_name(&name) {
                 match typ {
@@ -330,7 +330,7 @@
                     let _ = self.cache.borrow_mut().evict(num);
                 }
                 log!(self.opt.log, "Deleting file type={:?} num={}", typ, num);
-                if let Err(e) = self.opt.env.delete(&self.name.join(&name)) {
+                if let Err(e) = self.opt.env.delete(&self.path.join(&name)) {
                     log!(self.opt.log, "Deleting file num={} failed: {}", num, e);
                 }
             }
@@ -340,7 +340,7 @@
 
     /// acquire_lock acquires the lock file.
     fn acquire_lock(&mut self) -> Result<()> {
-        let lock_r = self.opt.env.lock(Path::new(&lock_file_name(&self.name)));
+        let lock_r = self.opt.env.lock(Path::new(&lock_file_name(&self.path)));
         match lock_r {
             Ok(lockfile) => {
                 self.lock = Some(lockfile);
@@ -562,7 +562,7 @@
             let logf = self
                 .opt
                 .env
-                .open_writable_file(Path::new(&log_file_name(&self.name, logn)));
+                .open_writable_file(Path::new(&log_file_name(&self.path, logn)));
             if logf.is_err() {
                 self.vset.borrow_mut().reuse_file_number(logn);
                 Err(logf.err().unwrap())
@@ -679,7 +679,7 @@
             };
             let mut state = CompactionState::new(compaction, smallest);
             if let Err(e) = self.do_compaction_work(&mut state) {
-                state.cleanup(&self.opt.env, &self.name);
+                state.cleanup(&self.opt.env, &self.path);
                 log!(self.opt.log, "Compaction work failed: {}", e);
             }
             self.install_compaction_results(state)?;
@@ -722,7 +722,7 @@
         let start_ts = self.opt.env.micros();
         let num = self.vset.borrow_mut().new_file_number();
         log!(self.opt.log, "Start write of L0 table {:06}", num);
-        let fmd = build_table(&self.name, &self.opt, memt.iter(), num)?;
+        let fmd = build_table(&self.path, &self.opt, memt.iter(), num)?;
         log!(self.opt.log, "L0 table {:06} has {} bytes", num, fmd.size);
 
         // Wrote empty table.
@@ -742,7 +742,7 @@
             let _ = self
                 .opt
                 .env
-                .delete(Path::new(&table_file_name(&self.name, num)));
+                .delete(Path::new(&table_file_name(&self.path, num)));
             return Err(e);
         }
 
@@ -839,7 +839,7 @@
                 let mut fmd = FileMetaData::default();
                 fmd.num = fnum;
 
-                let fname = table_file_name(&self.name, fnum);
+                let fname = table_file_name(&self.path, fnum);
                 let f = self.opt.env.open_writable_file(Path::new(&fname))?;
                 let f = Box::new(BufWriter::new(f));
                 cs.builder = Some(TableBuilder::new(self.opt.clone(), f));