Loading src/backends/cluster.cpp +9 −0 Changes for src/backends/cluster.cpp: 9 added lines, 0 removed lines. Original line number Diff line number Diff line Loading @@ -117,6 +117,12 @@ namespace authdb { size_t peer_rev = bufferRevision(peer_data); size_t cur_rev = bufferRevision(_Buffer); // Reject corrupt buffers before considering them if (!bufferValid(local_data)) local_data.clear(); if (!bufferValid(peer_data)) peer_data.clear(); std::vector<uint8_t> *best = nullptr; size_t best_rev = cur_rev; Loading @@ -131,11 +137,14 @@ namespace authdb { if (best) { _Buffer = std::move(*best); vacuum(); store.store(dgid, 0, _Buffer.data(), _Buffer.size()); } else if (_Buffer.empty() && !local_data.empty()) { _Buffer = std::move(local_data); vacuum(); } else if (_Buffer.empty() && !peer_data.empty()) { _Buffer = std::move(peer_data); vacuum(); } } Loading Loading
src/backends/cluster.cpp +9 −0 Changes for src/backends/cluster.cpp: 9 added lines, 0 removed lines. Original line number Diff line number Diff line Loading @@ -117,6 +117,12 @@ namespace authdb { size_t peer_rev = bufferRevision(peer_data); size_t cur_rev = bufferRevision(_Buffer); // Reject corrupt buffers before considering them if (!bufferValid(local_data)) local_data.clear(); if (!bufferValid(peer_data)) peer_data.clear(); std::vector<uint8_t> *best = nullptr; size_t best_rev = cur_rev; Loading @@ -131,11 +137,14 @@ namespace authdb { if (best) { _Buffer = std::move(*best); vacuum(); store.store(dgid, 0, _Buffer.data(), _Buffer.size()); } else if (_Buffer.empty() && !local_data.empty()) { _Buffer = std::move(local_data); vacuum(); } else if (_Buffer.empty() && !peer_data.empty()) { _Buffer = std::move(peer_data); vacuum(); } } Loading