Loading src/backends/cluster.cpp +6 −0 Changes for src/backends/cluster.cpp: 6 added lines, 0 removed lines. Original line number Diff line number Diff line Loading @@ -30,6 +30,7 @@ #include <algorithm> #include <crypto/sha.h> #include <netplus/exception.h> #include "cluster.h" #include "../cluster.h" Loading Loading @@ -70,6 +71,9 @@ namespace authdb { // Cache locally store.store(dgid, 0, _Buffer.data(), _Buffer.size()); } } catch (const netplus::NetException &e) { std::cerr << "ClusterBackend::fetchFromCluster: fetch_from_peers failed: " << e.what() << std::endl; } catch (const std::exception &e) { std::cerr << "ClusterBackend::fetchFromCluster: fetch_from_peers failed: " << e.what() << std::endl; Loading Loading @@ -104,6 +108,8 @@ namespace authdb { auto &cmtx = g_Cluster->getClientMutex(); std::lock_guard<std::mutex> lock(cmtx); client->replicate_to_peers(dgid, 0, _Buffer.data(), _Buffer.size()); } catch (const netplus::NetException &e) { std::cerr << "Cluster replicate failed: " << e.what() << std::endl; } catch (const std::exception &e) { std::cerr << "Cluster replicate failed: " << e.what() << std::endl; } Loading src/cluster.cpp +2 −0 Changes for src/cluster.cpp: 2 added lines, 0 removed lines. Original line number Diff line number Diff line Loading @@ -236,6 +236,8 @@ namespace authdb { void Cluster::server_loop() { try { server_->run(); } catch (const netplus::NetException &e) { std::cerr << "Cluster server error: " << e.what() << std::endl; } catch (const std::exception &e) { std::cerr << "Cluster server error: " << e.what() << std::endl; } Loading test/docker/config-node1.yaml +1 −0 Changes for test/docker/config-node1.yaml: 1 added line, 0 removed lines. Original line number Diff line number Diff line Loading @@ -17,5 +17,6 @@ AUTHDB: DATA_BLOCKS: 2 PARITY_BLOCKS: 1 PEERS: - "node1:4433" - "node2:4433" - "node3:4433" test/docker/config-node2.yaml +1 −0 Changes for test/docker/config-node2.yaml: 1 added line, 0 removed lines. Original line number Diff line number Diff line Loading @@ -18,4 +18,5 @@ AUTHDB: PARITY_BLOCKS: 1 PEERS: - "node1:4433" - "node2:4433" - "node3:4433" test/docker/config-node3.yaml +1 −0 Changes for test/docker/config-node3.yaml: 1 added line, 0 removed lines. Original line number Diff line number Diff line Loading @@ -19,3 +19,4 @@ AUTHDB: PEERS: - "node1:4433" - "node2:4433" - "node3:4433" Loading
src/backends/cluster.cpp +6 −0 Changes for src/backends/cluster.cpp: 6 added lines, 0 removed lines. Original line number Diff line number Diff line Loading @@ -30,6 +30,7 @@ #include <algorithm> #include <crypto/sha.h> #include <netplus/exception.h> #include "cluster.h" #include "../cluster.h" Loading Loading @@ -70,6 +71,9 @@ namespace authdb { // Cache locally store.store(dgid, 0, _Buffer.data(), _Buffer.size()); } } catch (const netplus::NetException &e) { std::cerr << "ClusterBackend::fetchFromCluster: fetch_from_peers failed: " << e.what() << std::endl; } catch (const std::exception &e) { std::cerr << "ClusterBackend::fetchFromCluster: fetch_from_peers failed: " << e.what() << std::endl; Loading Loading @@ -104,6 +108,8 @@ namespace authdb { auto &cmtx = g_Cluster->getClientMutex(); std::lock_guard<std::mutex> lock(cmtx); client->replicate_to_peers(dgid, 0, _Buffer.data(), _Buffer.size()); } catch (const netplus::NetException &e) { std::cerr << "Cluster replicate failed: " << e.what() << std::endl; } catch (const std::exception &e) { std::cerr << "Cluster replicate failed: " << e.what() << std::endl; } Loading
src/cluster.cpp +2 −0 Changes for src/cluster.cpp: 2 added lines, 0 removed lines. Original line number Diff line number Diff line Loading @@ -236,6 +236,8 @@ namespace authdb { void Cluster::server_loop() { try { server_->run(); } catch (const netplus::NetException &e) { std::cerr << "Cluster server error: " << e.what() << std::endl; } catch (const std::exception &e) { std::cerr << "Cluster server error: " << e.what() << std::endl; } Loading
test/docker/config-node1.yaml +1 −0 Changes for test/docker/config-node1.yaml: 1 added line, 0 removed lines. Original line number Diff line number Diff line Loading @@ -17,5 +17,6 @@ AUTHDB: DATA_BLOCKS: 2 PARITY_BLOCKS: 1 PEERS: - "node1:4433" - "node2:4433" - "node3:4433"
test/docker/config-node2.yaml +1 −0 Changes for test/docker/config-node2.yaml: 1 added line, 0 removed lines. Original line number Diff line number Diff line Loading @@ -18,4 +18,5 @@ AUTHDB: PARITY_BLOCKS: 1 PEERS: - "node1:4433" - "node2:4433" - "node3:4433"
test/docker/config-node3.yaml +1 −0 Changes for test/docker/config-node3.yaml: 1 added line, 0 removed lines. Original line number Diff line number Diff line Loading @@ -19,3 +19,4 @@ AUTHDB: PEERS: - "node1:4433" - "node2:4433" - "node3:4433"