MCPcopy Create free account

hub / github.com/Tencent/phxqueue / functions

Functions1,319 in github.com/Tencent/phxqueue

⨍ Functions 1,319◇ Types & classes 330
↓ 3 callersMethodProtoGetLockInfo
phxqueue_phxrpc/app/lock/lock_client.cpp:153
↓ 3 callersMethodRead
phxqueue_phxrpc/app/scheduler/scheduler_server_config.cpp:27
↓ 3 callersMethodRead
phxqueue_phxrpc/comm/fileconfig.cpp:62
↓ 3 callersMethodSetKeepAlive
phxqueue_phxrpc/app/scheduler/phxrpc_scheduler_stub.cpp:33
↓ 3 callersMethodShouldSkip
phxqueue/config/topicconfig.cpp:466
↓ 3 callersFunctionShowUsage
phxqueue_phxrpc/test/consumer_main.cpp:34
↓ 3 callersFunctionShowUsage
phxqueue_phxrpc/app/scheduler/scheduler_main.cpp:87
↓ 3 callersFunctionShowUsage
phxqueue_phxrpc/app/store/store_main.cpp:92
↓ 3 callersFunctionShowUsage
phxqueue_phxrpc/app/lock/lock_main.cpp:95
↓ 3 callersFunctionSlice2String
phxqueue_phxrpc/comm/iniparser.cpp:46
↓ 3 callersFunctionStrTrim
phxqueue_phxrpc/comm/iniparser.cpp:50
↓ 2 callersFunctionAccessDir
phxqueue/comm/utils/file_util.cpp:480
↓ 2 callersMethodAcquireLock
ret: RET_OK if acquired, others if not acquired
phxqueue/lock/lock.cpp:162
↓ 2 callersFunctionAddrScalesToString
phxqueue/comm/utils/addr_util.cpp:63
↓ 2 callersFunctionClearConsumeStat
phxqueue/consumer/freqman.cpp:96
↓ 2 callersFunctionCoRead
phxqueue/comm/utils/co_util.cpp:63
↓ 2 callersFunctionCoWrite
phxqueue/comm/utils/co_util.cpp:33
↓ 2 callersFunctionCopyDir
phxqueue/comm/utils/file_util.cpp:233
↓ 2 callersMethodDelete
phxqueue/lock/lockdb.cpp:444
↓ 2 callersFunctionDoExecute
phxqueue/lock/locksm.cpp:35
↓ 2 callersMethodGet
phxqueue_phxrpc/app/store/store_tool_impl.cpp:64
↓ 2 callersMethodGetAddrScale
phxqueue/test/simpleconsumer.cpp:72
↓ 2 callersMethodGetAllFreqInfo
phxqueue/config/topicconfig.cpp:514
↓ 2 callersMethodGetAllPub
pub ********************/
phxqueue/config/topicconfig.cpp:224
↓ 2 callersMethodGetAllReplayInfo
phxqueue/config/topicconfig.cpp:519
↓ 2 callersMethodGetAllSub
sub ********************/
phxqueue/config/topicconfig.cpp:273
↓ 2 callersMethodGetNQueue
phxqueue/config/topicconfig.cpp:404
↓ 2 callersMethodGetQueueByLoopRank
phxqueue/config/topicconfig.cpp:435
↓ 2 callersMethodGetQueueByRank
phxqueue/config/topicconfig.cpp:416
↓ 2 callersMethodGetQueueDelay
phxqueue/config/topicconfig.cpp:393
↓ 2 callersMethodGetQueueInfoIDRankByPub
queue_info ********************/
phxqueue/config/topicconfig.cpp:310
↓ 2 callersMethodGetQueueInfoIDRankByPubID
phxqueue/config/topicconfig.cpp:324
↓ 2 callersMethodGetReq
phxqueue/producer/batchhelper.cpp:75
↓ 2 callersMethodGetStoreID
phxqueue/producer/selector.cpp:118
↓ 2 callersFunctionGetSubIDsByConsumerAddr
phxqueue/config/utils/sub_util.cpp:20
↓ 2 callersMethodGetSubIDsByPubID
phxqueue/config/topicconfig.cpp:259
↓ 2 callersMethodInit
phxqueue/consumer/hblock.cpp:83
↓ 2 callersMethodIsBufferUpdated
phxqueue/comm/handler.h:37
↓ 2 callersMethodLog
phxqueue/comm/logger.cpp:115
↓ 2 callersMethodNewConsumerConfig
phxqueue/plugin/configfactory.h:55
↓ 2 callersMethodNewGlobalConfig
phxqueue/plugin/configfactory.h:49
↓ 2 callersMethodNewStoreConfig
phxqueue/plugin/configfactory.h:58
↓ 2 callersMethodNewTopicConfig
phxqueue/plugin/configfactory.h:52
↓ 2 callersMethodOnAcquireLockFail
phxqueue/comm/breakpoint.h:290
↓ 2 callersMethodOnAcquireLockSucc
phxqueue/comm/breakpoint.h:289
↓ 2 callersMethodOnAdd
phxqueue/comm/breakpoint.h:117
↓ 2 callersMethodOnBatchRawAddFail
phxqueue/comm/breakpoint.h:256
↓ 2 callersMethodOnGetAddrScale
phxqueue/comm/breakpoint.h:282
↓ 2 callersMethodOnGetCheckpointInstanceID
phxqueue/comm/breakpoint.h:507
↓ 2 callersMethodOnGetSucc
phxqueue/comm/breakpoint.h:46
↓ 2 callersMethodOnLock
phxqueue/comm/breakpoint.h:36
↓ 2 callersMethodOnLockSucc
phxqueue/comm/breakpoint.h:37
↓ 2 callersMethodOnReadCheckpoint
phxqueue/comm/breakpoint.h:419
↓ 2 callersMethodOnSnatchMaster
phxqueue/comm/breakpoint.h:485
↓ 2 callersMethodOnUpdateCursorIDFail
phxqueue/comm/breakpoint.h:170
↓ 2 callersMethodProcess
phxqueue/producer/batchhelper.cpp:149
↓ 2 callersMethodRead
phxqueue_phxrpc/app/store/store_server_config.cpp:28
↓ 2 callersMethodRead
phxqueue_phxrpc/app/lock/lock_server_config.cpp:27
↓ 2 callersMethodReady
phxqueue/producer/batchhelper.cpp:132
↓ 2 callersFunctionRecursiveListDir
phxqueue/comm/utils/file_util.cpp:257
↓ 2 callersFunctionRemoveDir
phxqueue/comm/utils/file_util.cpp:219
↓ 2 callersMethodReset
phxqueue/scheduler/schedulermgr.h:88
↓ 2 callersMethodRun
phxqueue/scheduler/keepmasterthread.cpp:54
↓ 2 callersMethodRun
phxqueue/store/keepsyncthread.cpp:63
↓ 2 callersMethodSetIndex
phxqueue/store/storemeta.cpp:84
↓ 2 callersFunctionShowUsage
phxqueue_phxrpc/test/test_selector_main.cpp:38
↓ 2 callersFunctionShowUsage
phxqueue_phxrpc/test/config_check_main.cpp:39
↓ 2 callersMethodSize
phxqueue/store/storemeta.cpp:239
↓ 2 callersMethodStop
phxqueue/scheduler/keepmasterthread.cpp:62
↓ 2 callersMethodStop
phxqueue/store/keepsyncthread.cpp:71
↓ 2 callersMethodStop
phxqueue/lock/cleanthread.cpp:69
↓ 2 callersMethodUpdateCheckPointAndFlush
phxqueue/store/checkpointstat.cpp:114
↓ 2 callersMethodUpdateCrc
phxqueue/store/storemeta.cpp:92
↓ 2 callersMethodset_checkpoint
phxqueue/lock/lockmgr.h:40
↓ 2 callersMethodset_last_instance_id
phxqueue/lock/lockmgr.cpp:294
↓ 1 callersMethodAcquireLock
phxqueue_phxrpc/app/lock/lock_client.cpp:133
↓ 1 callersMethodAcquireLock
phxqueue/test/simpleconsumer.cpp:134
↓ 1 callersMethodAdd
phxqueue_phxrpc/app/store/store_client.cpp:108
↓ 1 callersMethodAdd
phxqueue/store/store.cpp:441
↓ 1 callersMethodAdd
phxqueue/test/simpleconsumer.cpp:52
↓ 1 callersMethodAddFactory
phxqueue/comm/handler.h:95
↓ 1 callersMethodAddTask
phxqueue/producer/batchhelper.cpp:121
↓ 1 callersFunctionAddrScaleToString
phxqueue/comm/utils/addr_util.cpp:59
↓ 1 callersMethodAdjustNextCursorID
phxqueue/store/syncctrl.cpp:120
↓ 1 callersMethodBack
phxqueue/store/storemeta.cpp:184
↓ 1 callersMethodBatchRawAdd
phxqueue/producer/batchhelper.cpp:344
↓ 1 callersFunctionCalHash
phxqueue/consumer/hblock.cpp:307
↓ 1 callersMethodCheckCrc
phxqueue/store/storemeta.cpp:101
↓ 1 callersMethodCleanForward
phxqueue/lock/lockdb.cpp:543
↓ 1 callersMethodClearDequeueStat
phxqueue/store/storemeta.cpp:262
↓ 1 callersFunctionCopyFile
phxqueue/comm/utils/file_util.cpp:190
↓ 1 callersFunctionDiffTimespecMS
phxqueue/comm/utils/benchmark_util.cpp:48
↓ 1 callersMethodDispatchBatchTask
phxqueue/producer/batchhelper.cpp:260
↓ 1 callersMethodDispose
phxqueue/lock/lock.cpp:136
↓ 1 callersMethodEraseFrontTill
phxqueue/store/storemeta.cpp:192
↓ 1 callersMethodFront
phxqueue/store/storemeta.cpp:176
↓ 1 callersFunctionGenRandomString
phxqueue_phxrpc/test/test_producer_echo_main.cpp:34
↓ 1 callersMethodGet
phxqueue/store/store.cpp:537
↓ 1 callersMethodGet
phxqueue/test/simpleconsumer.cpp:29
↓ 1 callersMethodGetAddrScale
phxqueue_phxrpc/app/scheduler/scheduler_client.cpp:113
← previousnext →101–200 of 1,319, ranked by callers