Method CheckAddRequest

phxqueue/store/store.cpp:348–380

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

    auto topic_id(impl_->topic_id);

    comm::RetCode ret;

    if (comm::RetCode::RET_OK != (ret = CheckRequestComm(req.store_id(), req.queue_id()))) {
        QLErr("CheckRequestComm ret %d", as_integer(ret));
        return ret;
    }


    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;
    }

    size_t byte_size{0};
    for (int i{0}; i < req.items_size(); ++i) {
        byte_size += req.items(i).ByteSize();
    }

    if (byte_size > topic_config->GetProto().topic().items_byte_size_limit()) {
        QLErr("size too large. byte_size %d >= size_limit %d",
              req.ByteSize(), topic_config->GetProto().topic().items_byte_size_limit());
        return comm::RetCode::RET_ERR_SIZE_TOO_LARGE;
    }

    return comm::RetCode::RET_OK;
}

comm::RetCode Store::CheckGetRequest(const comm::proto::GetRequest &req) {