diff --git a/src/main.rs b/src/main.rs index 4a9d383a7bc1417ab8dab59510db8928c26d0642..399e20622871faa68c7a19d0d27f8576f7f26ef1 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 a495e85dcfcad8d047d0aee6c77964339c80b862..b6e6c4420375a9021c9ab4093d73a3beb10ac2de 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