Method ClearCursorID

phxqueue/store/syncctrl.cpp:275–290

comm::RetCode SyncCtrl::ClearCursorID(const int sub_id, const int queue_id) {
    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]);
    memset(&item, 0, sizeof(item));

    return comm::RetCode::RET_OK;
}

comm::RetCode SyncCtrl::Flush(const int sub_id, const int queue_id) {
    auto opt(impl_->store->GetStoreOption());