From 3506b6023d164a154730fe28c5253c8c3c154f45 Mon Sep 17 00:00:00 2001 From: mxsm Date: Sat, 4 Jan 2025 17:53:01 +0800 Subject: [PATCH] =?UTF-8?q?[ISSUE=20#2087]=F0=9F=90=9BFix=20ReferenceResou?= =?UTF-8?q?rce#hold=20not=20correct?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/log_file/mapped_file/default_mapped_file_impl.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/rocketmq-store/src/log_file/mapped_file/default_mapped_file_impl.rs b/rocketmq-store/src/log_file/mapped_file/default_mapped_file_impl.rs index 021e5d1c..67bb9cf5 100644 --- a/rocketmq-store/src/log_file/mapped_file/default_mapped_file_impl.rs +++ b/rocketmq-store/src/log_file/mapped_file/default_mapped_file_impl.rs @@ -809,10 +809,10 @@ impl ReferenceResource { #[inline] pub fn hold(&self) -> bool { if self.is_available() { - if self.ref_count.fetch_add(1, Ordering::Relaxed) + 1 > 0 { + if self.ref_count.fetch_add(1, Ordering::SeqCst) > 0 { return true; } else { - self.ref_count.fetch_sub(1, Ordering::Relaxed); + self.ref_count.fetch_sub(1, Ordering::SeqCst); } } false