Method CheckRequestComm

phxqueue/store/store.cpp:304–345

}

comm::RetCode Store::CheckRequestComm(const int store_id, const int queue_id) {
    auto topic_id(impl_->topic_id);

    comm::RetCode ret;

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

    shared_ptr<const config::proto::Store> store;
    if (comm::RetCode::RET_OK != (ret = store_config->GetStoreByAddr(impl_->addr, store))) {
        QLErr("GetStoreByAddr ret %d", as_integer(ret));
        return ret;
    }

    // check store_id
    if (store->store_id() != store_id) {
        QLErr("store_id unmatch. store_id %d req_store_id %d", store->store_id(), store_id);
        return comm::RetCode::RET_ERR_RANGE_STORE;
    }

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

    // check queue_id
    if (!topic_config->IsValidQueue(queue_id)) {
        QLErr("IsValidQueue fail. queue_id %d", queue_id);
        return comm::RetCode::RET_ERR_RANGE_PUB;
    }

    return comm::RetCode::RET_OK;

}


comm::RetCode Store::CheckAddRequest(const comm::proto::AddRequest &req) {