From 4a28330355f3b9d0262b9300b84ef2f596b601b5 Mon Sep 17 00:00:00 2001
From: Georgy Moshkin <gmoshkin@picodata.io>
Date: Thu, 6 Oct 2022 09:28:03 +0300
Subject: [PATCH] fix: remove replication from main_loop
---
src/main.rs | 4 ----
src/traft/node.rs | 8 --------
2 files changed, 12 deletions(-)
diff --git a/src/main.rs b/src/main.rs
index 4a9d383a7b..399e206228 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -814,10 +814,6 @@ fn postjoin(args: &args::Run, storage: RaftSpaceAccess, peer_storage: PeerStorag
tlog!(Error, "failed setting on_shutdown trigger: {e}");
}
- let peer = traft::Storage::peer_by_raft_id(raft_id).unwrap().unwrap();
- box_cfg.replication = traft::Storage::box_replication(&peer.replicaset_id, None).unwrap();
- tarantool::set_cfg(&box_cfg);
-
loop {
let peer = traft::Storage::peer_by_raft_id(raft_id)
.unwrap()
diff --git a/src/traft/node.rs b/src/traft/node.rs
index a495e85dcf..b6e6c44203 100644
--- a/src/traft/node.rs
+++ b/src/traft/node.rs
@@ -876,14 +876,6 @@ impl MainLoop {
if topology_changed {
event::broadcast(Event::TopologyChanged);
- if let Some(peer) = traft::Storage::peer_by_raft_id(node_impl.raw_node.raft.id).unwrap()
- {
- let mut box_cfg = crate::tarantool::cfg().unwrap();
- assert_eq!(box_cfg.replication_connect_quorum, 0);
- box_cfg.replication =
- traft::Storage::box_replication(&peer.replicaset_id, None).unwrap();
- crate::tarantool::set_cfg(&box_cfg);
- }
}
FlowControl::Continue
--
GitLab