| 252 | } |
| 253 | |
| 254 | comm::RetCode LockMgr::WriteRestartCheckpoint(const GroupVector::size_type paxos_group_id, |
| 255 | const uint64_t restart_checkpoint) { |
| 256 | comm::LockMgrBP::GetThreadInstance()-> |
| 257 | OnWriteRestartCheckpoint(impl_->lock->GetTopicID(), |
| 258 | paxos_group_id, restart_checkpoint); |
| 259 | |
| 260 | if (phxpaxos::NoCheckpoint != restart_checkpoint) { |
| 261 | comm::RetCode ret{leveldb(paxos_group_id).Put(KEY_IGNORE_RESTART_CHECKPOINT, |
| 262 | to_string(restart_checkpoint) , true)}; |
| 263 | |
| 264 | if (comm::RetCode::RET_OK == ret) { |
| 265 | QLInfo("topic_id %d paxos_group_id %d restart_cp %llu ok", |
| 266 | impl_->lock->GetTopicID(), paxos_group_id, restart_checkpoint); |
| 267 | } else { |
| 268 | QLErr("topic_id %d paxos_group_id %d restart_cp %llu err %d", |
| 269 | impl_->lock->GetTopicID(), paxos_group_id, restart_checkpoint, ret); |
| 270 | } |
| 271 | |
| 272 | return ret; |
| 273 | } |
| 274 | |
| 275 | return comm::RetCode::RET_OK; |
| 276 | } |
| 277 | |
| 278 | LockDb &LockMgr::leveldb(const GroupVector::size_type paxos_group_id) { |
| 279 | return impl_->groups[paxos_group_id].leveldb; |
nothing calls this directly
no test coverage detected