| 309 | } |
| 310 | |
| 311 | comm::RetCode SyncCtrl::GetBackLogByCursorID(const int queue_id, |
| 312 | const uint64_t cursor_id, int &backlog) { |
| 313 | backlog = 0; |
| 314 | |
| 315 | auto meta_queue(impl_->store->GetBaseMgr()->GetMetaQueue(queue_id)); |
| 316 | if (!meta_queue) { |
| 317 | QLErr("GetMetaQueue fail. queue_id %d", queue_id); |
| 318 | return comm::RetCode::RET_ERR_RANGE_QUEUE; |
| 319 | } |
| 320 | if (-1 == cursor_id) backlog = meta_queue->Size(); |
| 321 | else backlog = meta_queue->SizeGT(StoreMeta(cursor_id)); |
| 322 | |
| 323 | return comm::RetCode::RET_OK; |
| 324 | } |
| 325 | |
| 326 | |
| 327 | comm::RetCode SyncCtrl::SyncCursorID(const proto::SyncCtrlInfo &sync_ctrl_info) { |
no test coverage detected