Method GetLockID

phxqueue/scheduler/keepmasterthread.cpp:213–238

}

comm::RetCode KeepMasterThread::GetLockID(int &lock_id) {
    const int topic_id{impl_->scheduler->GetTopicID()};

    comm::RetCode ret;

    shared_ptr<const config::LockConfig> lock_config;
    if (comm::RetCode::RET_OK != (ret = config::GlobalConfig::GetThreadInstance()->GetLockConfig(topic_id, lock_config))) {
        QLErr("GetLockConfig ret %d", as_integer(ret));
        return ret;
    }

    set<int> lock_ids;
    if (comm::RetCode::RET_OK != (ret = lock_config->GetAllLockID(lock_ids))) {
        QLErr("GetAllLockID ret %d", as_integer(ret));
        return ret;
    }

    if (lock_ids.empty()) {
        QLErr("GetAllLockID lock_ids empty");
        return comm::RetCode::RET_ERR_RANGE_LOCK;

    }

    lock_id = *lock_ids.begin();
    return comm::RetCode::RET_OK;
}


}  // namespace scheduler