MCPcopy Create free account

hub / github.com/Tencent/phxqueue / functions

Functions1,319 in github.com/Tencent/phxqueue

⨍ Functions 1,319◇ Types & classes 330
MethodCleanLock
phxqueue/lock/cleanthread.cpp:130
MethodCleanThread
phxqueue/lock/cleanthread.cpp:53
MethodCleanThreadImpl
phxqueue/lock/cleanthread.cpp:43
MethodClearAllConsumeStat
phxqueue/consumer/freqman.cpp:166
MethodClearCursorID
phxqueue/store/syncctrl.cpp:275
MethodClearInvalidSubIDs
phxqueue/consumer/hblock.cpp:181
MethodClearSyncCtrl
phxqueue/store/syncctrl.cpp:200
MethodClearSyncCtrl
phxqueue/store/keepsyncthread.cpp:111
MethodCompressBuffer
phxqueue_phxrpc/producer/producer.cpp:28
MethodCompressBuffer
phxqueue_phxrpc/consumer/consumer.cpp:47
MethodCompressBuffer
phxqueue/test/simpleconsumer.cpp:66
MethodCompressBuffer
phxqueue/test/simpleproducer.cpp:30
MethodConfigFactory
phxqueue_phxrpc/plugin/configfactory.cpp:38
MethodConfigFactory
phxqueue/plugin/configfactory.h:32
MethodConfigFactoryImpl
phxqueue_phxrpc/plugin/configfactory.cpp:31
MethodConsistenHash
phxqueue/comm/utils/hash_util.h:33
MethodConsume
phxqueue/consumer/consumer.cpp:840
MethodConsumeThreadRun
phxqueue/consumer/consumer.cpp:416
MethodConsumer
phxqueue_phxrpc/consumer/consumer.cpp:36
MethodConsumer
phxqueue/consumer/consumer.cpp:88
MethodConsumerBP
phxqueue/comm/breakpoint.h:32
MethodConsumerConfig
phxqueue_phxrpc/config/consumerconfig.h:26
MethodConsumerConfig
phxqueue/config/consumerconfig.cpp:34
MethodConsumerConfigImpl
phxqueue/config/consumerconfig.cpp:28
MethodConsumerConsumeBP
phxqueue/comm/breakpoint.h:70
MethodConsumerHeartBeatLockBP
phxqueue/comm/breakpoint.h:90
MethodConsumerImpl
phxqueue/consumer/consumer.cpp:58
MethodConsumerInfo
phxqueue/scheduler/schedulermgr.h:116
MethodConsumerOption
phxqueue/consumer/consumeroption.h:26
MethodConsumerServerConfig
phxqueue_phxrpc/consumer/consumerserverconfig.h:29
FunctionCopyDir2
phxqueue/comm/utils/file_util.cpp:468
FunctionCopyFile2
phxqueue/comm/utils/file_util.cpp:347
MethodCustomGetRequest
phxqueue/consumer/consumer.cpp:994
MethodDaemonThreadRun
phxqueue/producer/batchhelper.cpp:320
MethodDecidePubIDOnEnqueue
If argument pub_id of Producer::Enqueue use default value, Producer need this implement to determine the real pub_id.
phxqueue/producer/producer.h:98
MethodDefaultHandlerFactory
phxqueue/comm/handler.h:75
FunctionDispatch
phxqueue_phxrpc/app/scheduler/scheduler_main.cpp:71
FunctionDispatch
phxqueue_phxrpc/app/store/store_main.cpp:76
FunctionDispatch
phxqueue_phxrpc/app/lock/lock_main.cpp:79
FunctionDispatchRoutineRun
phxqueue/consumer/consumer.cpp:352
FunctionDispatchTickRun
phxqueue/producer/batchhelper.cpp:254
MethodDispose
phxqueue/scheduler/scheduler.cpp:99
MethodDispose
phxqueue/scheduler/schedulermgr.cpp:83
MethodDispose
phxqueue/lock/lockmgr.cpp:157
MethodDispose
phxqueue/lock/lockdb.cpp:115
MethodDistubePendingQueues
phxqueue/consumer/hblock.cpp:195
FunctionDoCopyDir2
phxqueue/comm/utils/file_util.cpp:448
MethodDoLock
phxqueue/consumer/hblock.cpp:628
MethodDoRun
phxqueue/scheduler/keepmasterthread.cpp:70
MethodDoRun
phxqueue/scheduler/loadbalancethread.cpp:69
MethodDoRun
phxqueue/store/keepmasterthread.cpp:77
MethodDoRun
phxqueue/store/keepsyncthread.cpp:79
MethodDoRun
phxqueue/lock/cleanthread.cpp:77
MethodDoRun
phxqueue/lock/keepmasterthread.cpp:77
MethodDumpCheckPoint
phxqueue/store/keepsyncthread.cpp:256
MethodEchoHandler
phxqueue_phxrpc/test/echo_handler.h:27
MethodEraseFrontUntill
phxqueue/store/storemeta.cpp:203
MethodExecute
phxqueue/store/storesm.cpp:49
MethodExecute
phxqueue/lock/locksm.cpp:150
MethodExecuteForCheckpoint
phxqueue/store/storesm.h:44
MethodExecuteForCheckpoint
phxqueue/lock/locksm.cpp:199
FunctionExtractFilePath
phxqueue/comm/utils/file_util.cpp:156
MethodFactoryList
phxqueue/comm/handler.h:87
MethodFastRand
phxqueue/comm/utils/other_util.cpp:75
MethodFileConfig
phxqueue_phxrpc/comm/fileconfig.cpp:39
MethodFileLoader
phxqueue_phxrpc/comm/fileloader.cpp:54
MethodFileLoaderImpl
phxqueue_phxrpc/comm/fileloader.cpp:42
MethodFillConfig
phxqueue/config/baseconfig.h:39
MethodFlush
phxqueue/store/syncctrl.cpp:292
MethodForkAndRun
phxqueue/comm/multiproc.cpp:27
MethodFreqMan
phxqueue/consumer/freqman.cpp:76
MethodGet
phxqueue_phxrpc/app/store/phxrpc_store_tool.cpp:47
MethodGet
phxqueue_phxrpc/app/store/phxrpc_store_dispatcher.cpp:120
MethodGet
phxqueue_phxrpc/app/store/phxrpc_store_stub.cpp:54
MethodGet
phxqueue_phxrpc/app/store/phxrpc_store_service.cpp:44
MethodGet
phxqueue_phxrpc/app/store/store_service_impl.cpp:47
MethodGet
phxqueue_phxrpc/consumer/consumer.cpp:52
MethodGet
phxqueue/store/basemgr.cpp:156
MethodGet
phxqueue/consumer/consumer.cpp:167
MethodGet
phxqueue/comm/resourcepool.h:37
MethodGet
phxqueue/comm/notifierpool.cpp:103
MethodGetAddrFromCache
phxqueue/comm/masterclient.cpp:37
MethodGetAddrScale
phxqueue_phxrpc/app/scheduler/phxrpc_scheduler_tool.cpp:41
MethodGetAddrScale
phxqueue_phxrpc/app/scheduler/scheduler_client_uthread.cpp:114
MethodGetAddrScale
phxqueue_phxrpc/app/scheduler/scheduler_service_impl.cpp:37
MethodGetAddrScale
phxqueue_phxrpc/app/scheduler/scheduler_tool_impl.cpp:48
MethodGetAddrScale
phxqueue_phxrpc/app/scheduler/phxrpc_scheduler_stub.cpp:45
MethodGetAddrScale
phxqueue_phxrpc/app/scheduler/phxrpc_scheduler_dispatcher.cpp:82
MethodGetAddrScale
phxqueue_phxrpc/app/scheduler/phxrpc_scheduler_service.cpp:37
MethodGetAddrScale
phxqueue_phxrpc/consumer/consumer.cpp:76
MethodGetAddrScale
phxqueue/scheduler/scheduler.cpp:172
MethodGetAddrScale
phxqueue/scheduler/schedulermgr.cpp:109
MethodGetAddrScale
phxqueue/consumer/hblock.cpp:321
MethodGetAllLocalQueue
phxqueue/store/keepsyncthread.cpp:622
MethodGetAllQueues
phxqueue/consumer/hblock.cpp:446
MethodGetAllTopicConfig
phxqueue/config/globalconfig.cpp:150
MethodGetAllValue
phxqueue_phxrpc/comm/iniparser.cpp:130
MethodGetCandidateAddrs
phxqueue/scheduler/schedulermasterclient.h:44
MethodGetCandidateAddrs
phxqueue/store/storemasterclient.h:44
MethodGetCandidateAddrs
phxqueue/lock/lockmasterclient.h:51
← previousnext →601–700 of 1,319, ranked by callers