Method GetCursorID

phxqueue/store/syncctrl.cpp:173–198

}

comm::RetCode SyncCtrl::GetCursorID(const int sub_id, const int queue_id,
                                    uint64_t &cursor_id, const bool is_prev) const {
    cursor_id = -1;

    auto opt = impl_->store->GetStoreOption();

    if (!sub_id || sub_id > opt->nsub || queue_id >= opt->nqueue)
        return comm::RetCode::RET_ERR_ARG;

    size_t idx;
    GetIdx(opt->nsub, sub_id, queue_id, idx);

    lock_guard<mutex> lock_guard(impl_->locks[idx]);

    auto &&item(impl_->buf[idx]);

    if (is_prev) {
        if (item.prev_magic != SYNCCTRL_MAGIC) return comm::RetCode::RET_ERR_CURSOR_NOT_FOUND;
        cursor_id = item.prev_cursor_id;
    } else {
        if (item.next_magic != SYNCCTRL_MAGIC) return comm::RetCode::RET_ERR_CURSOR_NOT_FOUND;
        cursor_id = item.next_cursor_id;
    }

    return comm::RetCode::RET_OK;
}

void SyncCtrl::ClearSyncCtrl() {
    if (!impl_->buf) {