Method SyncRpcResponse

src/catalog/client_manager.cc:106–149

    return nullptr;
}
void AsyncTableHandler::SyncRpcResponse() {
    auto cntl = callback_->GetController();
    auto response = callback_->GetResponse();
    if (!cntl || !response) {
        status_.code = hybridse::common::kRpcError;
        status_.msg = "rpc controller or response is null";
        LOG(WARNING) << status_.msg;
        return;
    }
    brpc::Join(cntl->call_id());
    if (cntl->Failed()) {
        status_ = ::hybridse::base::Status(::hybridse::common::kRpcError, "request error. " + cntl->ErrorText());
        LOG(WARNING) << status_.msg;
        return;
    }
    if (response->code() != 0) {
        status_ = ::hybridse::base::Status(::hybridse::common::kResponseError, "request error. " + response->msg());
        LOG(WARNING) << status_.msg;
        return;
    }

    if (response->row_sizes_size() == 0) {
        status_.code = hybridse::common::kResponseError;
        status_.msg = "response error: rows empty";
        LOG(WARNING) << status_.msg;
        return;
    }
    size_t buf_offset = 0;
    for (int i = 0; i < response->row_sizes_size(); ++i) {
        size_t row_size = response->row_sizes(i);
        hybridse::codec::Row row;
        if (0 != row_size && !codec::DecodeRpcRow(cntl->response_attachment(), buf_offset, row_size,
                                                  response->non_common_slices(), &row)) {
            status_.code = hybridse::common::kResponseError;
            status_.msg = "response error: content decode fail";
            LOG(WARNING) << status_.msg;
            return;
        }
        AddRow(row);
        buf_offset += row_size;
    }
    status_ = hybridse::base::Status::OK();
    return;
}

AsyncTablesHandler::AsyncTablesHandler()
    : hybridse::vm::MemTableHandler("", "", nullptr),