MCPcopy Create free account
hub / github.com/Tencent/phxqueue / GetMetaQueue

Method GetMetaQueue

phxqueue/store/basemgr.cpp:445–451  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

443}
444
445StoreMetaQueue *BaseMgr::GetMetaQueue(const int queue_id) {
446 if (queue_id >= impl_->store->GetStoreOption()->nqueue) {
447 QLErr("queue_id %d invalid. nqueue %d", queue_id, impl_->store->GetStoreOption()->nqueue);
448 return nullptr;
449 }
450 return &impl_->meta_queues[queue_id];
451}
452
453
454} // namespace store

Callers 3

GetBackLogByCursorIDMethod · 0.80
SyncCursorIDMethod · 0.80
MakeCheckPointMethod · 0.80

Calls 1

GetStoreOptionMethod · 0.80

Tested by

no test coverage detected