MCPcopy Create free account

hub / github.com/Tencent/phxqueue / functions

Functions1,319 in github.com/Tencent/phxqueue

⨍ Functions 1,319◇ Types & classes 330
↓ 1 callersFunctionTestGetLockInfo
phxqueue/test/test_lock_main.cpp:29
↓ 1 callersMethodThreadRun
phxqueue/comm/utils/benchmark_util.cpp:133
↓ 1 callersMethodUpdate
phxqueue/scheduler/schedulermgr.h:61
↓ 1 callersMethodUpdateConsumeStat
phxqueue/consumer/freqman.cpp:102
↓ 1 callersMethodUpdateDeuqueStat
phxqueue/store/storemeta.cpp:227
↓ 1 callersMethodValid
phxqueue/lock/lockdb.cpp:491
↓ 1 callersMethodWait
phxqueue/producer/batchhelper.cpp:59
↓ 1 callersMethodWait
phxqueue/comm/notifierpool.cpp:76
↓ 1 callersMethodWriteCheckpoint
phxqueue/lock/lockmgr.cpp:204
↓ 1 callersMethodcursor
phxqueue/scheduler/schedulermgr.h:103
↓ 1 callersMethodlast_instance_id
phxqueue/lock/lockmgr.cpp:299
↓ 1 callersFunctionrdtsc
phxqueue/comm/utils/other_util.cpp:35
↓ 1 callersMethodset_last_active_time
phxqueue/scheduler/schedulermgr.h:131
Method GetInstance
phxqueue/comm/utils/time_util.cpp:76
Method GetNextIntervalTimeMs
phxqueue/comm/utils/time_util.cpp:91
Method MsSleep
phxqueue/comm/utils/time_util.cpp:172
Method NextIntervalSleepMs
phxqueue/comm/utils/time_util.cpp:122
Method PoissonDistribution
phxqueue/comm/utils/time_util.cpp:65
Method RealtimeChangeBaseIntervalMs
phxqueue/comm/utils/time_util.cpp:114
Method Rebuild
phxqueue/comm/utils/time_util.cpp:81
Method SetMaxIntervalTimeMs
phxqueue/comm/utils/time_util.cpp:162
Method SetMinIntervalTimeMs
phxqueue/comm/utils/time_util.cpp:167
Method ~PoissonDistribution
phxqueue/comm/utils/time_util.cpp:73
MethodAcquireLock
phxqueue_phxrpc/scheduler/scheduler.cpp:43
MethodAcquireLock
phxqueue_phxrpc/app/scheduler/phxrpc_scheduler.cpp:35
MethodAcquireLock
phxqueue_phxrpc/app/lock/phxrpc_lock_tool.cpp:47
MethodAcquireLock
phxqueue_phxrpc/app/lock/phxrpc_lock_service.cpp:43
MethodAcquireLock
phxqueue_phxrpc/app/lock/phxrpc_lock_dispatcher.cpp:120
MethodAcquireLock
phxqueue_phxrpc/app/lock/lock_service_impl.cpp:48
MethodAcquireLock
phxqueue_phxrpc/app/lock/phxrpc_lock_stub.cpp:53
MethodAcquireLock
phxqueue_phxrpc/app/lock/lock_tool_impl.cpp:63
MethodAcquireLock
phxqueue_phxrpc/consumer/consumer.cpp:98
MethodAcquireLock
phxqueue/test/simplescheduler.cpp:72
MethodAcquireLock
phxqueue/lock/lockdb.cpp:130
MethodAdd
phxqueue_phxrpc/producer/producer.cpp:33
MethodAdd
phxqueue_phxrpc/app/store/phxrpc_store_tool.cpp:41
MethodAdd
phxqueue_phxrpc/app/store/store_tool_impl.cpp:49
MethodAdd
phxqueue_phxrpc/app/store/phxrpc_store_dispatcher.cpp:83
MethodAdd
phxqueue_phxrpc/app/store/phxrpc_store_stub.cpp:46
MethodAdd
phxqueue_phxrpc/app/store/phxrpc_store_service.cpp:38
MethodAdd
phxqueue_phxrpc/app/store/store_service_impl.cpp:36
MethodAdd
phxqueue_phxrpc/consumer/consumer.cpp:64
MethodAdd
phxqueue/store/basemgr.cpp:66
MethodAdd
phxqueue/test/simpleproducer.cpp:37
MethodAdjustMasterRate
phxqueue/scheduler/keepmasterthread.cpp:101
MethodAdjustMasterRate
phxqueue/store/keepmasterthread.cpp:137
MethodAdjustMasterRate
phxqueue/lock/keepmasterthread.cpp:125
MethodAdjustScale
phxqueue/scheduler/schedulermgr.cpp:742
MethodAfterAdd
Callback after Add.
phxqueue/producer/producer.h:104
MethodAfterAdd
Callback after the pull thread finished add items to Store.
phxqueue/consumer/consumer.h:149
MethodAfterBatchHandle
Callback after the worker routine finish batch handle.
phxqueue/consumer/consumer.h:182
MethodAfterConsume
phxqueue/consumer/consumer.cpp:1000
MethodAfterGet
Callback after the pull thread finished get items from Store.
phxqueue/consumer/consumer.h:143
MethodAfterHandle
Callback after the worker routine finished handle.
phxqueue/consumer/consumer.h:165
MethodAfterLock
phxqueue/test/simpleconsumer.cpp:144
MethodAfterLock
Callback after the pull thread finished lock process.
phxqueue/consumer/consumer.h:134
MethodBaseConfig
phxqueue_phxrpc/config/baseconfig.h:29
MethodBaseConfig
phxqueue/config/baseconfig.h:30
MethodBaseMgr
phxqueue/store/basemgr.cpp:49
MethodBaseMgrImpl
phxqueue/store/basemgr.cpp:40
MethodBatchHandle
Batch handle implement. arg idx within [0, ConsumerOption::nbatch_handler).
phxqueue/consumer/consumer.h:175
MethodBatchHandleRoutineFunc
phxqueue/consumer/consumer.cpp:336
FunctionBatchHandleRoutineRun
phxqueue/consumer/consumer.cpp:375
MethodBatchHandleTaskFinish
phxqueue/consumer/consumer.cpp:291
MethodBatchHelper
phxqueue/producer/batchhelper.cpp:215
MethodBatchHelperImpl
phxqueue/producer/batchhelper.cpp:199
MethodBatchTask
phxqueue/producer/batchhelper.cpp:84
MethodBeforeAdd
Callback before Add.
phxqueue/producer/producer.h:101
MethodBeforeAdd
Callback before the pull thread start add items to Store.
phxqueue/consumer/consumer.h:146
MethodBeforeBatchHandle
Callback before the worker routine start batch handle.
phxqueue/consumer/consumer.h:168
MethodBeforeFork
Callback before worker fork.
phxqueue/consumer/consumer.h:102
MethodBeforeGet
Callback before the pull thread start get items from Store.
phxqueue/consumer/consumer.h:140
MethodBeforeHandle
Callback before the worker routine start handle.
phxqueue/consumer/consumer.h:162
MethodBeforeLock
phxqueue/test/simpleconsumer.cpp:139
MethodBeforeLock
Callback before the pull thread start lock process.
phxqueue/consumer/consumer.h:131
MethodBeforeRunNode
Callback before the paxos processing starts, to modify phxpaxos::Options.
phxqueue/store/store.h:85
MethodBeforeRunNode
Callback before the paxos processing starts, to modify phxpaxos::Options.
phxqueue/lock/lock.h:102
MethodBenchMark
phxqueue/comm/utils/benchmark_util.cpp:112
MethodBreakPointFactory
phxqueue/plugin/breakpointfactory.h:67
MethodBuildTopicScaleResponse
phxqueue/scheduler/schedulermgr.cpp:562
MethodBuildTopicScaleString
phxqueue/scheduler/schedulermgr.cpp:575
MethodCheckAddRequest
phxqueue/store/store.cpp:348
MethodCheckConsumerConfig
phxqueue/test/check_config.cpp:214
MethodCheckGetRequest
phxqueue/store/store.cpp:382
MethodCheckGlobalConfig
phxqueue/test/check_config.cpp:67
MethodCheckImbalance
phxqueue/scheduler/schedulermgr.cpp:701
MethodCheckLockConfig
phxqueue/test/check_config.cpp:268
MethodCheckMaster
phxqueue/store/store.cpp:397
MethodCheckMaster
phxqueue/lock/lock.cpp:401
MethodCheckMaxLoop
phxqueue/consumer/consumer.cpp:923
MethodCheckMem
phxqueue/consumer/consumer.cpp:950
MethodCheckPointStat
phxqueue/store/checkpointstat.cpp:61
MethodCheckPointStatImpl
phxqueue/store/checkpointstat.cpp:49
MethodCheckPointStatMgr
phxqueue/store/checkpointstat.cpp:149
MethodCheckPointStatMgrImpl
phxqueue/store/checkpointstat.cpp:141
MethodCheckRequestComm
phxqueue/store/store.cpp:304
MethodCheckSchedulerConfig
phxqueue/test/check_config.cpp:264
MethodCheckStoreConfig
phxqueue/test/check_config.cpp:226
MethodCheckTopicConfig
phxqueue/test/check_config.cpp:70
MethodChildRun
phxqueue/consumer/consumer.cpp:480
← previousnext →501–600 of 1,319, ranked by callers