| 54 | |
| 55 | |
| 56 | comm::RetCode BaseMgr::Init() { |
| 57 | //locks_.reset(new Mutex[conf_->GetIDCNum() * conf_->GetQueueNum()]); |
| 58 | impl_->meta_queues.reset(new StoreMetaQueue[impl_->store->GetStoreOption()->nqueue]); |
| 59 | |
| 60 | //delay_stat_.reset(new DelayStat(topic_id_, conf_->GetQueueNum())); |
| 61 | |
| 62 | return comm::RetCode::RET_OK; |
| 63 | } |
| 64 | |
| 65 | |
| 66 | comm::RetCode BaseMgr::Add(const uint64_t cursor_id, const comm::proto::AddRequest &req) { |
nothing calls this directly
no test coverage detected