Method GetCheckPoint

phxqueue/store/checkpointstat.cpp:104–112

}

comm::RetCode CheckPointStat::GetCheckPoint(uint64_t &cp) {
    cp = -1;

    lock_guard<mutex> lock_guard(impl_->lock);

    CheckPointStatItem_t *item = impl_->buf;
    if (item->magic == CHECKPOINTSTAT_MAGIC) cp = item->cp;
    return comm::RetCode::RET_OK;
}

comm::RetCode CheckPointStat::UpdateCheckPointAndFlush(const uint64_t cp) {
    lock_guard<mutex> lock_guard(impl_->lock);