Method CleanLock

phxqueue/lock/cleanthread.cpp:130–207

}

void CleanThread::CleanLock(const int paxos_group_id, const uint64_t now,
                            int &nr_group_key, int &nr_group_clean_key) {
    if (!impl_->lock->GetNode()->IsIMMaster(paxos_group_id))
        return;

    auto &&current_map(impl_->lock->GetLockMgr()->map(paxos_group_id));
    int i{0};
    while (current_map.GetSize() > i &&
           impl_->lock->GetLockOption()->max_clean_lock_num > i) {
        ++i;

        // 1. make args
        proto::LockPaxosArgs args;

        // begin mutex
        {

            // ensure not acquiring lock or geting lock info
            comm::utils::MutexGuard guard(current_map.mutex());

            string current_clean_key;
            current_map.CleanForward(current_clean_key);
            proto::LocalLockInfo local_lock_info;
            comm::RetCode ret{current_map.Get(current_clean_key, local_lock_info)};
            if (comm::RetCode::RET_ERR_IGNORE == ret) {
                QLInfo("paxos_group_id %d lock_key \"%s\" Get ignore",
                       paxos_group_id, current_clean_key.c_str());

                continue;
            }

            ++nr_group_key;

            if (comm::RetCode::RET_OK != ret) {
                QLErr("paxos_group_id %d lock_key \"%s\" Get err %d",
                      paxos_group_id, current_clean_key.c_str(), ret);

                continue;
            }

            // add expired lock key
            if (now > local_lock_info.expire_time_ms()) {
                // TODO: use move?
                auto &&lock_info(args.mutable_acquire_lock_req()->mutable_lock_info());
                lock_info->set_lock_key(current_clean_key);
                lock_info->set_version(local_lock_info.version());
                lock_info->set_client_id(CLIENT_ID_CLEAN_THREAD);
                lock_info->set_lease_time_ms(0);
            }
        }
        // end mutex

        // 2. serialize args to paxos value
        string buf;
        args.SerializeToString(&buf);

        // 3. send to paxos
        LockContext lc;