diff --git a/src/storage/src/hummock/utils.rs b/src/storage/src/hummock/utils.rs index e2bf6de55700c..0e2e003a22369 100644 --- a/src/storage/src/hummock/utils.rs +++ b/src/storage/src/hummock/utils.rs @@ -184,7 +184,7 @@ pub struct PendingRequestCancelGuard { impl Drop for PendingRequestCancelGuard { fn drop(&mut self) { if let Some(limiter) = self.inner.take() { - // close rc before calling `try_recv`, it will make `MemoryTrackerImpl` which generates after dropping of `PendingRequestCancelGuard` drop in loop of `may_notify_waiters` in other thread. + // close rx before calling `try_recv`, it will make `MemoryTrackerImpl` which generates after dropping of `PendingRequestCancelGuard` drop in loop of `may_notify_waiters` in other thread. // If `MemoryTrackerImpl` send before this thread calling `close`, it can still be received by this thread. Once this thread receives the message, it need drop the message and update `total_size` in `MemoryTrackerImpl`'s drop. self.rx.close(); if let Ok(msg) = self.rx.try_recv() {