Function fetchLocalShards

cpp/core/RegistryClient.cpp:404–430

}

std::pair<int, std::string> fetchLocalShards(const std::string& host, uint16_t port, Duration timeout, std::array<ShardInfo, 256>& shards) {
    const auto [sock, errStr] = registrySock(host, port, timeout);
    if (sock.error()) {
        return {sock.getErrno(), errStr};
    }

    RegistryReqContainer reqContainer;
    reqContainer.setLocalShards();
    {
        const auto [err, errStr] = writeRegistryRequest(sock.get(), reqContainer, timeout);
        if (err) { return {err, errStr}; }
    }

    RegistryRespContainer respContainer;
    {
        const auto [err, errStr] = readRegistryResponse(sock.get(), respContainer, timeout);
        if (err) { return {err, errStr}; }
    }
    if (respContainer.getLocalShards().shards.els.size() != shards.size()) {
        throw TERN_EXCEPTION("expecting %s shards, got %s", shards.size(), respContainer.getLocalShards().shards.els.size());
    }
    for (int i = 0; i < shards.size(); i++) {
        shards[i] = respContainer.getLocalShards().shards.els[i];
    }

    return {};
}

bool parseRegistryAddress(const std::string& fullRegistryAddress, std::string& registryHost, uint16_t& registryPort) {
    // split host:port