Commit 1f2ef651 authored by jan.koester's avatar jan.koester
Browse files

test

parent d5062f98

src/cluster.cpp

+9 −3
Original line number Diff line number Diff line
@@ -340,7 +340,9 @@ namespace authdb { 
#endif



            std::vector<paritypp::client::node_info> nodes;

            for (const auto &peer : cfg_.peers) {

            size_t self_idx = SIZE_MAX;

            for (size_t pi = 0; pi < cfg_.peers.size(); ++pi) {

                const auto &peer = cfg_.peers[pi];

                bool is_self = false;

                if (peer.port == cfg_.port) {

                    for (const auto &addr : local_addrs) {
@@ -351,7 +353,8 @@ namespace authdb { 
                    }

                }

                if (is_self) {

                    std::cerr << "Cluster: self node (" << peer.address

                    self_idx = nodes.size();

                    std::cerr << "Cluster: self node index " << pi << " (" << peer.address

                              << ":" << peer.port << ")" << std::endl;

                }

                nodes.push_back({peer.address, peer.port});
@@ -368,8 +371,11 @@ namespace authdb { 
            if (!nodes.empty()) {

                pclient_ = std::make_unique<paritypp::client>(

                    cfg_.data_blocks, cfg_.parity_blocks, nodes, pcreds);

                if (self_idx != SIZE_MAX) {

                    pclient_->set_local_node(self_idx, store_);

                }

            } else {

                std::cerr << "Cluster: no remote peers after filtering self" << std::endl;

                std::cerr << "Cluster: no peers configured" << std::endl;

            }

        }