diff options
| author | Paul Masurel <paul.masurel@gmail.com> | 2018-06-22 14:27:46 +0900 |
|---|---|---|
| committer | Paul Masurel <paul.masurel@gmail.com> | 2018-06-22 14:27:46 +0900 |
| commit | 8ccbfdea5d17565809378577fba691e3aa6b28f9 (patch) | |
| tree | 485b5ee6fb2bd3b4091f779de793c40f4b57bd22 /src/indexer/delete_queue.rs | |
| parent | badfce3a2366c4af848aa6a5286d29a6420272f1 (diff) | |
Preparing for release
Diffstat (limited to 'src/indexer/delete_queue.rs')
| -rw-r--r-- | src/indexer/delete_queue.rs | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/src/indexer/delete_queue.rs b/src/indexer/delete_queue.rs index 4c2597f..f921b75 100644 --- a/src/indexer/delete_queue.rs +++ b/src/indexer/delete_queue.rs @@ -52,7 +52,8 @@ impl DeleteQueue { // // Past delete operations are not accessible. pub fn cursor(&self) -> DeleteCursor { - let last_block = self.inner + let last_block = self + .inner .read() .expect("Read lock poisoned when opening delete queue cursor") .last_block @@ -92,7 +93,8 @@ impl DeleteQueue { // be some unflushed operations. // fn flush(&self) -> Option<Arc<Block>> { - let mut self_wlock = self.inner + let mut self_wlock = self + .inner .write() .expect("Failed to acquire write lock on delete queue writer"); @@ -132,7 +134,8 @@ impl From<DeleteQueue> for NextBlock { impl NextBlock { fn next_block(&self) -> Option<Arc<Block>> { { - let next_read_lock = self.0 + let next_read_lock = self + .0 .read() .expect("Failed to acquire write lock in delete queue"); if let InnerNextBlock::Closed(ref block) = *next_read_lock { @@ -141,7 +144,8 @@ impl NextBlock { } let next_block; { - let mut next_write_lock = self.0 + let mut next_write_lock = self + .0 .write() .expect("Failed to acquire write lock in delete queue"); match *next_write_lock { |