From 2d8fcea6995d5ce5f68ba05a3589d1322830243d Mon Sep 17 00:00:00 2001
From: Siddhesh Z <siddheshzope1023@gmail.com>
Date: Wed, 5 Mar 2025 22:03:11 +0530
Subject: [PATCH] =?UTF-8?q?[Enhancement=E2=9A=A1=EF=B8=8F]=20PopCheckPoint?=
 =?UTF-8?q?Wrapper=20method=20add=20#[inline]=20#2632?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../processor_service/pop_buffer_merge_service.rs    | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/rocketmq-broker/src/processor/processor_service/pop_buffer_merge_service.rs b/rocketmq-broker/src/processor/processor_service/pop_buffer_merge_service.rs
index 3c1bd9b02..9b1817866 100644
--- a/rocketmq-broker/src/processor/processor_service/pop_buffer_merge_service.rs
+++ b/rocketmq-broker/src/processor/processor_service/pop_buffer_merge_service.rs
@@ -967,51 +967,63 @@ impl PopCheckPointWrapper {
         }
     }
 
+    #[inline]
     pub fn get_revive_queue_id(&self) -> i32 {
         self.revive_queue_id
     }
 
+    #[inline]
     pub fn get_revive_queue_offset(&self) -> i64 {
         self.revive_queue_offset.load(Ordering::SeqCst) as i64
     }
 
+    #[inline]
     pub fn is_ck_stored(&self) -> bool {
         self.ck_stored.load(Ordering::SeqCst)
     }
 
+    #[inline]
     pub fn set_revive_queue_offset(&self, revive_queue_offset: i64) {
         self.revive_queue_offset
             .store(revive_queue_offset as i32, Ordering::SeqCst);
     }
 
+    #[inline]
     pub fn get_ck(&self) -> &Arc<PopCheckPoint> {
         &self.ck
     }
 
+    #[inline]
     pub fn get_bits(&self) -> &AtomicI32 {
         &self.bits
     }
 
+    #[inline]
     pub fn get_to_store_bits(&self) -> &AtomicI32 {
         &self.to_store_bits
     }
 
+    #[inline]
     pub fn get_next_begin_offset(&self) -> i64 {
         self.next_begin_offset
     }
 
+    #[inline]
     pub fn get_lock_key(&self) -> &CheetahString {
         &self.lock_key
     }
 
+    #[inline]
     pub fn get_merge_key(&self) -> &CheetahString {
         &self.merge_key
     }
 
+    #[inline]
     pub fn is_just_offset(&self) -> bool {
         self.just_offset
     }
 
+    #[inline]
     pub fn set_ck_stored(&self, ck_stored: bool) {
         self.ck_stored.store(ck_stored, Ordering::SeqCst);
     }