MCPcopy Create free account

hub / github.com/Tencent/phxqueue / functions

Functions1,319 in github.com/Tencent/phxqueue

⨍ Functions 1,319◇ Types & classes 330
↓ 1 callersMethodOnNrCleanKey
phxqueue/comm/breakpoint.h:451
↓ 1 callersMethodOnNrKey
phxqueue/comm/breakpoint.h:450
↓ 1 callersMethodOnPaxosAcquireLock
phxqueue/comm/breakpoint.h:397
↓ 1 callersMethodOnPaxosAdd
phxqueue/comm/breakpoint.h:122
↓ 1 callersMethodOnPreviewAdjustChange
phxqueue/comm/breakpoint.h:353
↓ 1 callersMethodOnPreviewAdjustUnchange
phxqueue/comm/breakpoint.h:354
↓ 1 callersMethodOnProcLack
phxqueue/comm/breakpoint.h:102
↓ 1 callersMethodOnProcUsed
phxqueue/comm/breakpoint.h:94
↓ 1 callersMethodOnProcUsedExceed
phxqueue/comm/breakpoint.h:97
↓ 1 callersMethodOnProcess
phxqueue/comm/breakpoint.h:38
↓ 1 callersMethodOnProcessFail
phxqueue/comm/breakpoint.h:39
↓ 1 callersMethodOnProcessSucc
phxqueue/comm/breakpoint.h:40
↓ 1 callersMethodOnPropose
phxqueue/comm/breakpoint.h:398
↓ 1 callersMethodOnProposeCleanErr
phxqueue/comm/breakpoint.h:448
↓ 1 callersMethodOnProposeCleanSucc
phxqueue/comm/breakpoint.h:447
↓ 1 callersMethodOnProposeErr
phxqueue/comm/breakpoint.h:399
↓ 1 callersMethodOnProposeErrOther
phxqueue/comm/breakpoint.h:403
↓ 1 callersMethodOnProposeErrResult
phxqueue/comm/breakpoint.h:404
↓ 1 callersMethodOnProposeErrTimeout
phxqueue/comm/breakpoint.h:400
↓ 1 callersMethodOnProposeErrTooManyThreadWaitingReject
phxqueue/comm/breakpoint.h:401
↓ 1 callersMethodOnProposeErrValueSizeTooLarge
phxqueue/comm/breakpoint.h:402
↓ 1 callersMethodOnProposeMasterErr
phxqueue/comm/breakpoint.h:463
↓ 1 callersMethodOnProposeMasterSucc
phxqueue/comm/breakpoint.h:462
↓ 1 callersMethodOnProposeSucc
phxqueue/comm/breakpoint.h:405
↓ 1 callersMethodOnRawAdd
phxqueue/comm/breakpoint.h:242
↓ 1 callersMethodOnRawAddFail
phxqueue/comm/breakpoint.h:239
↓ 1 callersMethodOnRawAddSucc
phxqueue/comm/breakpoint.h:244
↓ 1 callersMethodOnRawGetLockInfoFail
phxqueue/comm/breakpoint.h:371
↓ 1 callersMethodOnRawGetLockInfoSucc
phxqueue/comm/breakpoint.h:372
↓ 1 callersMethodOnReloadConsumerConfigFail
phxqueue/comm/breakpoint.h:329
↓ 1 callersMethodOnReloadConsumerConfigSucc
phxqueue/comm/breakpoint.h:330
↓ 1 callersMethodOnRunSync
Callback after the sync process fork.
phxqueue/consumer/consumer.h:114
↓ 1 callersMethodOnScaleHash
phxqueue/comm/breakpoint.h:95
↓ 1 callersMethodOnSelectAndAdd
phxqueue/comm/breakpoint.h:231
↓ 1 callersMethodOnSelectAndAddFail
phxqueue/comm/breakpoint.h:228
↓ 1 callersMethodOnSelectAndAddSucc
phxqueue/comm/breakpoint.h:240
↓ 1 callersMethodOnSkipHandle
phxqueue/comm/breakpoint.h:83
↓ 1 callersMethodOnSkipLock
phxqueue/comm/breakpoint.h:104
↓ 1 callersMethodOnSkipUpdateLoad
phxqueue/comm/breakpoint.h:313
↓ 1 callersMethodOnSleepAfterGet
phxqueue/comm/breakpoint.h:48
↓ 1 callersMethodOnSubDistribute
phxqueue/comm/breakpoint.h:268
↓ 1 callersMethodOnSync
phxqueue/comm/breakpoint.h:93
↓ 1 callersMethodOnSyncFail
phxqueue/comm/breakpoint.h:99
↓ 1 callersMethodOnSyncSucc
phxqueue/comm/breakpoint.h:98
↓ 1 callersMethodOnTaskDispatch
phxqueue/comm/breakpoint.h:75
↓ 1 callersMethodOnTaskDispatchFinish
phxqueue/comm/breakpoint.h:77
↓ 1 callersMethodOnTopicIDInvalid
phxqueue/comm/breakpoint.h:232
↓ 1 callersMethodOnUpdateLiveFail
phxqueue/comm/breakpoint.h:338
↓ 1 callersMethodOnUpdateLiveSucc
phxqueue/comm/breakpoint.h:339
↓ 1 callersMethodOnUpdateStickyLoad
phxqueue/comm/breakpoint.h:309
↓ 1 callersMethodOnUseCustomQueueSelector
phxqueue/comm/breakpoint.h:234
↓ 1 callersMethodOnUseCustomStoreSelector
phxqueue/comm/breakpoint.h:237
↓ 1 callersMethodOnUseDefaultQueueSelector
phxqueue/comm/breakpoint.h:233
↓ 1 callersMethodOnUseDefaultStoreSelector
phxqueue/comm/breakpoint.h:236
↓ 1 callersMethodOnValidTopicID
phxqueue/comm/breakpoint.h:247
↓ 1 callersMethodOnWriteCheckpoint
phxqueue/comm/breakpoint.h:420
↓ 1 callersMethodOnWriteRestartCheckpoint
phxqueue/comm/breakpoint.h:424
↓ 1 callersMethodPhxEcho
phxqueue_phxrpc/app/scheduler/scheduler_client.cpp:65
↓ 1 callersMethodPhxEcho
phxqueue_phxrpc/app/scheduler/scheduler_client_uthread.cpp:66
↓ 1 callersMethodPhxEcho
phxqueue_phxrpc/app/store/store_client.cpp:61
↓ 1 callersMethodPhxEcho
phxqueue_phxrpc/app/lock/lock_client.cpp:65
↓ 1 callersMethodPickNodeByKey
phxqueue/comm/utils/hash_util.h:57
↓ 1 callersMethodPrepareWait
phxqueue/producer/batchhelper.cpp:54
↓ 1 callersMethodProcess
phxqueue_phxrpc/test/test_rpc_config.cpp:29
↓ 1 callersMethodProcessAllBatchHandleTasks
phxqueue/consumer/consumer.cpp:408
↓ 1 callersMethodProcessAllHandleTasks
phxqueue/consumer/consumer.cpp:398
↓ 1 callersMethodProtoAdd
phxqueue_phxrpc/app/store/store_client.cpp:148
↓ 1 callersMethodProtoGet
phxqueue_phxrpc/app/store/store_client.cpp:184
↓ 1 callersMethodProtoGetAddrScale
phxqueue_phxrpc/app/scheduler/scheduler_client.cpp:133
↓ 1 callersMethodPushBack
phxqueue/store/storemeta.cpp:158
↓ 1 callersMethodRawAcquireLock
phxqueue/scheduler/scheduler.cpp:211
↓ 1 callersMethodRawAdd
phxqueue/producer/producer.cpp:378
↓ 1 callersMethodRawGetLockInfo
phxqueue/scheduler/scheduler.cpp:188
↓ 1 callersFunctionRecursiveCopyDir
phxqueue/comm/utils/file_util.cpp:302
↓ 1 callersFunctionRecursiveRemoveDir
phxqueue/comm/utils/file_util.cpp:267
↓ 1 callersFunctionRemoveFile
phxqueue/comm/utils/file_util.cpp:177
↓ 1 callersMethodRenewMaster
phxqueue/scheduler/schedulermgr.cpp:201
↓ 1 callersFunctionResetFastRandomSeed
phxqueue/comm/utils/other_util.cpp:59
↓ 1 callersMethodRun
phxqueue/producer/batchhelper.cpp:239
↓ 1 callersMethodRunSync
phxqueue/consumer/hblock.cpp:275
↓ 1 callersFunctionSchedulerRun
phxqueue/test/test_scheduler_main.cpp:96
↓ 1 callersMethodSeekToFirst
phxqueue/lock/lockdb.cpp:471
↓ 1 callersMethodSelectAndAdd
phxqueue/producer/producer.cpp:301
↓ 1 callersFunctionShowUsage
phxqueue_phxrpc/test/test_producer_echo_main.cpp:26
↓ 1 callersFunctionShowUsage
phxqueue_phxrpc/test/producer_benchmark_main.cpp:26
↓ 1 callersMethodSizeGT
phxqueue/store/storemeta.cpp:245
↓ 1 callersMethodSkipGet
phxqueue/store/store.cpp:580
↓ 1 callersMethodSkipHandle
phxqueue/consumer/consumer.cpp:873
↓ 1 callersMethodStat
phxqueue/comm/utils/memory_util.cpp:28
↓ 1 callersMethodStat
phxqueue/comm/utils/benchmark_util.cpp:122
↓ 1 callersFunctionStoreRun
phxqueue/test/test_store_main.cpp:73
↓ 1 callersFunctionStrSplitList
phxqueue_phxrpc/comm/ini2pb.cpp:32
↓ 1 callersFunctionStrSplitList
phxqueue/comm/utils/string_util.cpp:28
↓ 1 callersFunctionSubIDs2Mask
phxqueue/producer/producer.cpp:75
↓ 1 callersMethodSyncCursorID
phxqueue/store/syncctrl.cpp:327
↓ 1 callersMethodTaskDispatch
phxqueue/consumer/consumer.cpp:235
↓ 1 callersMethodTaskFunc
phxqueue_phxrpc/test/producer_benchmark.cpp:35
↓ 1 callersFunctionTestAcquireLock
phxqueue/test/test_lock_main.cpp:54
↓ 1 callersFunctionTestAdd
phxqueue/test/test_store_main.cpp:33
↓ 1 callersFunctionTestGetAddrScale
phxqueue/test/test_scheduler_main.cpp:30
← previousnext →401–500 of 1,319, ranked by callers