Method DoLock

phxqueue/consumer/hblock.cpp:628–770

}

comm::RetCode HeartBeatLock::DoLock(const int vpid, Queue_t *const queue) {

    comm::RetCode ret;

    auto &&opt = impl_->consumer->GetConsumerOption();

    auto topic_id = impl_->consumer->GetTopicID();

    if (LOCK_ITEM_MAGIC != queue->magic) {
        comm::ConsumerHeartBeatLockBP::GetThreadInstance()->OnNoLockTarget(topic_id);
        return comm::RetCode::RET_NO_LOCK_TARGET;
    }

    shared_ptr<const config::TopicConfig> topic_config;
    if (comm::RetCode::RET_OK != (ret = config::GlobalConfig::GetThreadInstance()->GetTopicConfigByTopicID(topic_id, topic_config))) {
        QLErr("ERR: GetTopicConfigByTopicID ret %d topic_id %u", comm::as_integer(ret), topic_id);
        return ret;
    }

    shared_ptr<const config::proto::Sub> sub;
    if (comm::RetCode::RET_OK != (ret = topic_config->GetSubBySubID(queue->sub_id, sub))) {
        QLErr("ERR: GetSubBySubID ret %d sub_id %u", comm::as_integer(ret), queue->sub_id);
        return ret;
    }

    if (sub->skip_lock()) {
        comm::ConsumerHeartBeatLockBP::GetThreadInstance()->OnSkipLock(topic_id, sub->sub_id());
        return comm::RetCode::RET_OK;
    }

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

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

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

    const int lock_id = *lock_ids.begin();

    string lock_key;
    {
        ostringstream oss;
        oss << topic_id << "-" << queue->sub_id << "-" << queue->store_id << "-" << queue->queue_id;
        lock_key = oss.str();
    }

    string client_id;
    {