Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/Tencent/phxqueue
/ functions
Functions
1,319 in github.com/Tencent/phxqueue
⨍
Functions
1,319
◇
Types & classes
330
↓ 1 callers
Method
OnBaseMgrGet
phxqueue/comm/breakpoint.h:135
↓ 1 callers
Method
OnBaseMgrGetFail
phxqueue/comm/breakpoint.h:136
↓ 1 callers
Method
OnBaseMgrGetSucc
phxqueue/comm/breakpoint.h:137
↓ 1 callers
Method
OnBatchHandleRoutineFunc
phxqueue/comm/breakpoint.h:82
↓ 1 callers
Method
OnBatchPropose
phxqueue/comm/breakpoint.h:123
↓ 1 callers
Method
OnBatchProposeErr
phxqueue/comm/breakpoint.h:124
↓ 1 callers
Method
OnBatchProposeErrOther
phxqueue/comm/breakpoint.h:128
↓ 1 callers
Method
OnBatchProposeErrTimeout
phxqueue/comm/breakpoint.h:125
↓ 1 callers
Method
OnBatchProposeErrTooManyThreadWaitingReject
phxqueue/comm/breakpoint.h:126
↓ 1 callers
Method
OnBatchProposeErrValueSizeTooLarge
phxqueue/comm/breakpoint.h:127
↓ 1 callers
Method
OnBatchProposeSucc
phxqueue/comm/breakpoint.h:129
↓ 1 callers
Method
OnBatchRawAdd
phxqueue/comm/breakpoint.h:254
↓ 1 callers
Method
OnBatchRawAddSucc
phxqueue/comm/breakpoint.h:255
↓ 1 callers
Method
OnBatchStat
phxqueue/comm/breakpoint.h:257
↓ 1 callers
Method
OnBuildTopicScaleResponseFail
phxqueue/comm/breakpoint.h:311
↓ 1 callers
Method
OnBuildTopicScaleResponseSucc
phxqueue/comm/breakpoint.h:310
↓ 1 callers
Method
OnCheckImbalanceFail
phxqueue/comm/breakpoint.h:347
↓ 1 callers
Method
OnCheckImbalanceSucc
phxqueue/comm/breakpoint.h:348
↓ 1 callers
Method
OnChildRun
Callback after worker fork.
phxqueue/consumer/consumer.h:105
↓ 1 callers
Method
OnConsume
phxqueue/comm/breakpoint.h:61
↓ 1 callers
Method
OnConsumeSucc
phxqueue/comm/breakpoint.h:62
↓ 1 callers
Method
OnConsumeThreadRun
Callback after the consume thread start.
phxqueue/consumer/consumer.h:121
↓ 1 callers
Method
OnConsumeThreadRunEnd
phxqueue/comm/breakpoint.h:74
↓ 1 callers
Method
OnConsumerAdd
phxqueue/comm/breakpoint.h:332
↓ 1 callers
Method
OnConsumerChange
phxqueue/comm/breakpoint.h:334
↓ 1 callers
Method
OnConsumerNewDie
phxqueue/comm/breakpoint.h:341
↓ 1 callers
Method
OnConsumerNewLive
phxqueue/comm/breakpoint.h:342
↓ 1 callers
Method
OnConsumerNotFound
phxqueue/comm/breakpoint.h:308
↓ 1 callers
Method
OnConsumerRemove
phxqueue/comm/breakpoint.h:333
↓ 1 callers
Method
OnCountLimit
phxqueue/comm/breakpoint.h:252
↓ 1 callers
Method
OnCrcCheckPass
phxqueue/comm/breakpoint.h:173
↓ 1 callers
Method
OnCrcCheckUnpass
phxqueue/comm/breakpoint.h:174
↓ 1 callers
Method
OnCursorIDChange
phxqueue/comm/breakpoint.h:162
↓ 1 callers
Method
OnCursorIDNotFound
phxqueue/comm/breakpoint.h:161
↓ 1 callers
Method
OnDropAll
phxqueue/comm/breakpoint.h:50
↓ 1 callers
Method
OnDynamicMode
phxqueue/comm/breakpoint.h:336
↓ 1 callers
Method
OnEnqueue
phxqueue/comm/breakpoint.h:227
↓ 1 callers
Method
OnEnqueueSucc
phxqueue/comm/breakpoint.h:229
↓ 1 callers
Method
OnExecute
phxqueue/comm/breakpoint.h:496
↓ 1 callers
Method
OnExecuteForCheckpoint
phxqueue/comm/breakpoint.h:498
↓ 1 callers
Method
OnExecuteForCheckpointNoSync
phxqueue/comm/breakpoint.h:504
↓ 1 callers
Method
OnExecuteForCheckpointSync
phxqueue/comm/breakpoint.h:501
↓ 1 callers
Method
OnGetAddrScaleFail
phxqueue/comm/breakpoint.h:284
↓ 1 callers
Method
OnGetAddrScaleSucc
phxqueue/comm/breakpoint.h:283
↓ 1 callers
Method
OnGetCheckMasterPass
phxqueue/comm/breakpoint.h:134
↓ 1 callers
Method
OnGetCheckMasterUnpass
phxqueue/comm/breakpoint.h:133
↓ 1 callers
Method
OnGetCheckpointState
phxqueue/comm/breakpoint.h:508
↓ 1 callers
Method
OnGetFail
phxqueue/comm/breakpoint.h:45
↓ 1 callers
Method
OnGetItemBeforeCheckPoint
phxqueue/comm/breakpoint.h:176
↓ 1 callers
Method
OnGetItemFromStoreMetaQueue
phxqueue/comm/breakpoint.h:175
↓ 1 callers
Method
OnGetItemTooBig
phxqueue/comm/breakpoint.h:169
↓ 1 callers
Method
OnGetItemsByCursorIDFail
phxqueue/comm/breakpoint.h:164
↓ 1 callers
Method
OnGetLastItemNotChosenInPaxos
phxqueue/comm/breakpoint.h:165
↓ 1 callers
Method
OnGetLockInfo
phxqueue/comm/breakpoint.h:393
↓ 1 callers
Method
OnGetLockInfoCheckMasterPass
phxqueue/comm/breakpoint.h:395
↓ 1 callers
Method
OnGetLockInfoFail
phxqueue/comm/breakpoint.h:287
↓ 1 callers
Method
OnGetLockInfoRequestInvalid
phxqueue/comm/breakpoint.h:394
↓ 1 callers
Method
OnGetLockInfoSucc
phxqueue/comm/breakpoint.h:286
↓ 1 callers
Method
OnGetLoopReachMaxTime
phxqueue/comm/breakpoint.h:177
↓ 1 callers
Method
OnGetMeanLoadFail
phxqueue/comm/breakpoint.h:344
↓ 1 callers
Method
OnGetMeanLoadSucc
phxqueue/comm/breakpoint.h:345
↓ 1 callers
Method
OnGetNoItem
phxqueue/comm/breakpoint.h:47
↓ 1 callers
Method
OnGetNoMoreItem
phxqueue/comm/breakpoint.h:163
↓ 1 callers
Method
OnGetNoMoreItemBeforeATime
phxqueue/comm/breakpoint.h:166
↓ 1 callers
Method
OnGetQueueDelayFail
phxqueue/comm/breakpoint.h:41
↓ 1 callers
Method
OnGetQueueIDFail
phxqueue/comm/breakpoint.h:235
↓ 1 callers
Method
OnGetRequestInvalid
phxqueue/comm/breakpoint.h:132
↓ 1 callers
Method
OnGetRespSizeExceed
phxqueue/comm/breakpoint.h:168
↓ 1 callers
Method
OnGetSizeTooSmall
phxqueue/comm/breakpoint.h:51
↓ 1 callers
Method
OnGetSkip
phxqueue/comm/breakpoint.h:167
↓ 1 callers
Method
OnGetStoreIDFail
phxqueue/comm/breakpoint.h:238
↓ 1 callers
Method
OnGetWithItem
phxqueue/comm/breakpoint.h:49
↓ 1 callers
Method
OnHandle
phxqueue/comm/breakpoint.h:80
↓ 1 callers
Method
OnHandleEnd
phxqueue/comm/breakpoint.h:81
↓ 1 callers
Method
OnHandleRoutineFunc
phxqueue/comm/breakpoint.h:79
↓ 1 callers
Method
OnIMNotMaster
phxqueue/comm/breakpoint.h:305
↓ 1 callers
Method
OnInitErrBaseMgr
phxqueue/comm/breakpoint.h:141
↓ 1 callers
Method
OnInitErrCPMgr
phxqueue/comm/breakpoint.h:143
↓ 1 callers
Method
OnInitErrPaxos
phxqueue/comm/breakpoint.h:144
↓ 1 callers
Method
OnInitErrSyncCtrl
phxqueue/comm/breakpoint.h:142
↓ 1 callers
Method
OnInitSucc
phxqueue/comm/breakpoint.h:145
↓ 1 callers
Method
OnItemInResp
phxqueue/comm/breakpoint.h:171
↓ 1 callers
Method
OnItemSizeTooLarge
phxqueue/comm/breakpoint.h:249
↓ 1 callers
Method
OnKeepMaster
phxqueue/comm/breakpoint.h:370
↓ 1 callers
Method
OnKeepMasterThreadRun
phxqueue/scheduler/scheduler.cpp:238
↓ 1 callers
Method
OnLoadBalance
phxqueue/comm/breakpoint.h:328
↓ 1 callers
Method
OnLoadCheckpointState
phxqueue/comm/breakpoint.h:509
↓ 1 callers
Method
OnLockFail
phxqueue/comm/breakpoint.h:107
↓ 1 callers
Method
OnLoop
phxqueue/comm/breakpoint.h:42
↓ 1 callers
Method
OnLoopBreak
phxqueue/comm/breakpoint.h:43
↓ 1 callers
Method
OnMakeAddRequests
phxqueue/comm/breakpoint.h:246
↓ 1 callers
Method
OnMakeAddRequestsSucc
phxqueue/comm/breakpoint.h:250
↓ 1 callers
Method
OnMakeHandleBucket
phxqueue/comm/breakpoint.h:78
↓ 1 callers
Method
OnMasterClientCallFail
phxqueue/comm/breakpoint.h:243
↓ 1 callers
Method
OnMaxLoopCheckPass
phxqueue/comm/breakpoint.h:59
↓ 1 callers
Method
OnMaxLoopCheckUnpass
phxqueue/comm/breakpoint.h:58
↓ 1 callers
Method
OnMemCheck
phxqueue/comm/breakpoint.h:53
↓ 1 callers
Method
OnMemCheckPass
phxqueue/comm/breakpoint.h:55
↓ 1 callers
Method
OnMemCheckUnpass
phxqueue/comm/breakpoint.h:54
↓ 1 callers
Method
OnNoLockTarget
phxqueue/comm/breakpoint.h:103
← previous
next →
301–400 of 1,319, ranked by callers