fix format

Signed-off-by: Little-Wallace <[email protected]>
risingwavelabs · Dec 4, 2023 · 03ea2ad · 03ea2ad
1 parent 4fcabdb
commit 03ea2ad
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/src/storage/src/hummock/sstable/forward_sstable_iterator.rs b/src/storage/src/hummock/sstable/forward_sstable_iterator.rs
@@ -467,7 +467,7 @@ mod tests {
             cache_policy: CachePolicy::Fill(CachePriority::High),
             must_iterated_end_user_key: Some(Bound::Included(uk.clone())),
             max_preload_retry_times: 0,
-            prefetch_for_large_query: true,
+            prefetch_for_large_query: false,
         });
         let mut stats = StoreLocalStatistic::default();
         let mut sstable_iter = SstableIterator::create(

diff --git a/src/storage/src/hummock/utils.rs b/src/storage/src/hummock/utils.rs
@@ -629,7 +629,9 @@ impl LockTable {
             }
         };
         if let Some(notify) = notify {
+            println!("try lock");
             notify.notified().await;
+            println!("lock success");
         }
         LockGuard {
             key,
@@ -644,6 +646,8 @@ impl Drop for LockGuard {
         let que = locks.get_mut(&self.key).unwrap();
         if let Some(notify) = que.pop_front() {
             notify.notify_one();
+        } else {
+            locks.remove(&self.key);
         }
     }
 }