File tree Expand file tree Collapse file tree 1 file changed +12
-0
lines changed
rocketmq-broker/src/processor/processor_service Expand file tree Collapse file tree 1 file changed +12
-0
lines changed Original file line number Diff line number Diff line change @@ -967,51 +967,63 @@ impl PopCheckPointWrapper {
967967 }
968968 }
969969
970+ #[ inline]
970971 pub fn get_revive_queue_id ( & self ) -> i32 {
971972 self . revive_queue_id
972973 }
973974
975+ #[ inline]
974976 pub fn get_revive_queue_offset ( & self ) -> i64 {
975977 self . revive_queue_offset . load ( Ordering :: SeqCst ) as i64
976978 }
977979
980+ #[ inline]
978981 pub fn is_ck_stored ( & self ) -> bool {
979982 self . ck_stored . load ( Ordering :: SeqCst )
980983 }
981984
985+ #[ inline]
982986 pub fn set_revive_queue_offset ( & self , revive_queue_offset : i64 ) {
983987 self . revive_queue_offset
984988 . store ( revive_queue_offset as i32 , Ordering :: SeqCst ) ;
985989 }
986990
991+ #[ inline]
987992 pub fn get_ck ( & self ) -> & Arc < PopCheckPoint > {
988993 & self . ck
989994 }
990995
996+ #[ inline]
991997 pub fn get_bits ( & self ) -> & AtomicI32 {
992998 & self . bits
993999 }
9941000
1001+ #[ inline]
9951002 pub fn get_to_store_bits ( & self ) -> & AtomicI32 {
9961003 & self . to_store_bits
9971004 }
9981005
1006+ #[ inline]
9991007 pub fn get_next_begin_offset ( & self ) -> i64 {
10001008 self . next_begin_offset
10011009 }
10021010
1011+ #[ inline]
10031012 pub fn get_lock_key ( & self ) -> & CheetahString {
10041013 & self . lock_key
10051014 }
10061015
1016+ #[ inline]
10071017 pub fn get_merge_key ( & self ) -> & CheetahString {
10081018 & self . merge_key
10091019 }
10101020
1021+ #[ inline]
10111022 pub fn is_just_offset ( & self ) -> bool {
10121023 self . just_offset
10131024 }
10141025
1026+ #[ inline]
10151027 pub fn set_ck_stored ( & self , ck_stored : bool ) {
10161028 self . ck_stored . store ( ck_stored, Ordering :: SeqCst ) ;
10171029 }
You can’t perform that action at this time.
0 commit comments