MCPcopy Create free account

hub / github.com/Tencent/phxqueue / functions

Functions1,319 in github.com/Tencent/phxqueue

MethodOnIMMaster
phxqueue/comm/breakpoint.h:187
MethodOnIMMaster
phxqueue/comm/breakpoint.h:474
MethodOnInit
phxqueue/comm/breakpoint.h:139
MethodOnInit
phxqueue/comm/breakpoint.h:279
MethodOnInit
phxqueue/comm/breakpoint.h:301
MethodOnInit
phxqueue/comm/breakpoint.h:325
MethodOnInit
phxqueue/comm/breakpoint.h:367
MethodOnInitErrTopic
phxqueue/comm/breakpoint.h:140
MethodOnLock
phxqueue/comm/breakpoint.h:101
MethodOnLockSucc
phxqueue/comm/breakpoint.h:106
MethodOnMaxLoopCheck
phxqueue/comm/breakpoint.h:57
MethodOnReadRestartCheckpoint
phxqueue/comm/breakpoint.h:423
MethodOnSnatchMaster
phxqueue/comm/breakpoint.h:197
MethodOnTaskWait
phxqueue/comm/breakpoint.h:76
MethodOnValidPubID
phxqueue/comm/breakpoint.h:248
MethodOperation
phxqueue/scheduler/schedulermgr.h:160
MethodPBHandler
phxqueue/comm/handler.h:46
MethodParseContent
phxqueue_phxrpc/comm/iniparser.cpp:58
MethodParseContent
phxqueue_phxrpc/comm/fileconfig.h:35
MethodParseField
phxqueue_phxrpc/comm/ini2pb.cpp:47
MethodParseMessage
phxqueue_phxrpc/comm/ini2pb.cpp:185
MethodPaxosAcquireLock
ret: RET_OK if acquired, others if not acquired
phxqueue/lock/lock.cpp:441
MethodPaxosAdd
phxqueue/store/store.cpp:483
MethodPaxosInit
phxqueue/store/store.cpp:199
MethodPaxosInit
phxqueue/lock/lock.cpp:312
MethodPhxBatchEcho
phxqueue_phxrpc/app/scheduler/scheduler_client.cpp:85
MethodPhxBatchEcho
phxqueue_phxrpc/app/scheduler/scheduler_client_uthread.cpp:86
MethodPhxBatchEcho
phxqueue_phxrpc/app/store/store_client.cpp:81
MethodPhxBatchEcho
phxqueue_phxrpc/app/lock/lock_client.cpp:85
MethodPhxEcho
phxqueue_phxrpc/app/scheduler/phxrpc_scheduler_tool.cpp:35
MethodPhxEcho
phxqueue_phxrpc/app/scheduler/scheduler_service_impl.cpp:31
MethodPhxEcho
phxqueue_phxrpc/app/scheduler/scheduler_tool_impl.cpp:32
MethodPhxEcho
phxqueue_phxrpc/app/scheduler/phxrpc_scheduler_stub.cpp:37
MethodPhxEcho
phxqueue_phxrpc/app/scheduler/phxrpc_scheduler_dispatcher.cpp:45
MethodPhxEcho
phxqueue_phxrpc/app/scheduler/phxrpc_scheduler_service.cpp:31
MethodPhxEcho
phxqueue_phxrpc/app/store/phxrpc_store_tool.cpp:35
MethodPhxEcho
phxqueue_phxrpc/app/store/store_tool_impl.cpp:33
MethodPhxEcho
phxqueue_phxrpc/app/store/phxrpc_store_dispatcher.cpp:46
MethodPhxEcho
phxqueue_phxrpc/app/store/phxrpc_store_stub.cpp:38
MethodPhxEcho
phxqueue_phxrpc/app/store/phxrpc_store_service.cpp:32
MethodPhxEcho
phxqueue_phxrpc/app/store/store_service_impl.cpp:30
MethodPhxEcho
phxqueue_phxrpc/app/lock/phxrpc_lock_tool.cpp:35
MethodPhxEcho
phxqueue_phxrpc/app/lock/phxrpc_lock_service.cpp:31
MethodPhxEcho
phxqueue_phxrpc/app/lock/phxrpc_lock_dispatcher.cpp:46
MethodPhxEcho
phxqueue_phxrpc/app/lock/lock_service_impl.cpp:31
MethodPhxEcho
phxqueue_phxrpc/app/lock/phxrpc_lock_stub.cpp:37
MethodPhxEcho
phxqueue_phxrpc/app/lock/lock_tool_impl.cpp:32
MethodPhxRpcScheduler
phxqueue_phxrpc/app/scheduler/phxrpc_scheduler.cpp:23
MethodProcess
phxqueue/test/check_config.cpp:32
MethodProcess
phxqueue/test/test_configfactory.cpp:25
MethodProcess
phxqueue/test/test_producer.cpp:28
MethodProcess
phxqueue/test/test_log.cpp:31
MethodProcess
phxqueue/consumer/consumer.cpp:566
FunctionProcessRoutineRun
phxqueue/producer/batchhelper.cpp:296
MethodProducer
phxqueue_phxrpc/producer/producer.cpp:23
MethodProducer
phxqueue/producer/producer.cpp:41
MethodProducerBP
phxqueue/comm/breakpoint.h:224
MethodProducerBenchMark
phxqueue_phxrpc/test/producer_benchmark.cpp:24
MethodProducerOption
phxqueue/producer/produceroption.h:25
MethodProducerSubBP
phxqueue/comm/breakpoint.h:265
MethodProposeCleanLock
phxqueue/lock/cleanthread.cpp:312
MethodProposeMaster
phxqueue/lock/keepmasterthread.cpp:404
MethodPut
phxqueue/comm/resourcepool.h:49
MethodPut
phxqueue/comm/notifierpool.cpp:120
MethodPutAddrToCache
phxqueue/comm/masterclient.cpp:33
MethodQueueNeedReplay
phxqueue/store/keepsyncthread.cpp:368
MethodQueueSelector
phxqueue/producer/selector.h:28
MethodQueueSelectorDefault
phxqueue/producer/selector.cpp:42
MethodRWLock
phxqueue/comm/utils/concurrent_util.h:52
MethodReadCheckpoint
phxqueue/lock/lockmgr.cpp:177
MethodReadConfig
phxqueue_phxrpc/config/baseconfig.h:62
MethodReadConfig
phxqueue/config/lockconfig.cpp:41
MethodReadConfig
phxqueue/config/storeconfig.cpp:41
MethodReadConfig
phxqueue/config/schedulerconfig.cpp:41
MethodReadConfig
phxqueue/config/globalconfig.cpp:55
MethodReadConfig
phxqueue/config/baseconfig.h:72
MethodReadConfig
phxqueue/config/consumerconfig.cpp:40
MethodReadConfig
phxqueue/config/topicconfig.cpp:51
MethodReadRestartCheckpoint
phxqueue/lock/lockmgr.cpp:229
MethodRebuild
phxqueue/config/lockconfig.cpp:74
MethodRebuild
phxqueue/config/storeconfig.cpp:78
MethodRebuild
phxqueue/config/schedulerconfig.cpp:72
MethodRebuild
phxqueue/config/globalconfig.cpp:71
MethodRebuild
phxqueue/config/consumerconfig.cpp:75
MethodRebuild
phxqueue/config/topicconfig.cpp:131
MethodReloadConsumerConfig
phxqueue/scheduler/schedulermgr.cpp:437
MethodReloadSchedConfig
phxqueue/scheduler/schedulermgr.cpp:363
MethodReloadTopicConfig
phxqueue/scheduler/schedulermgr.cpp:369
MethodRemoveCache
phxqueue/comm/masterclient.cpp:47
FunctionRemoveDir2
phxqueue/comm/utils/file_util.cpp:399
MethodReplay
phxqueue/store/keepsyncthread.cpp:413
MethodReportBacklog
phxqueue/store/keepsyncthread.cpp:578
MethodReportDelayStat
phxqueue/store/keepsyncthread.cpp:618
MethodResStat
phxqueue/comm/utils/benchmark_util.cpp:184
MethodReset
phxqueue/scheduler/schedulermgr.h:125
MethodResetTimeByInode
phxqueue_phxrpc/comm/fileloader.cpp:84
MethodResourcePoll
phxqueue/comm/resourcepool.h:29
MethodRestoreUserCookies
phxqueue_phxrpc/consumer/consumer.h:50
MethodRestoreUserCookies
phxqueue/test/simpleconsumer.cpp:63
FunctionRoutineRunFunc
phxqueue/comm/utils/benchmark_util.cpp:60
← previousnext →901–1,000 of 1,319, ranked by callers