From f9cc68d4e664dbbc8f741311e298f3523b41e4ca Mon Sep 17 00:00:00 2001 From: dimgigov Date: Thu, 30 Jul 2026 18:46:09 +0300 Subject: [PATCH] chore(raft): ignore e2e test binary, stop raft network on shutdown --- .gitignore | 1 + src/baradadb.nim | 5 ++++- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/.gitignore b/.gitignore index 70d9f64..1a949a7 100644 --- a/.gitignore +++ b/.gitignore @@ -14,6 +14,7 @@ tests/fuzz_test tests/prop_test tests/bugfix_test tests/nimforum_smoke_test +tests/raft_e2e_test benchmarks/bench_all benchmarks/compare clients/nim/tests/test_client diff --git a/src/baradadb.nim b/src/baradadb.nim index a5bc13c..b3348a0 100644 --- a/src/baradadb.nim +++ b/src/baradadb.nim @@ -328,6 +328,7 @@ proc main() = var tcpServer = newServerWithRegistry(config, registry) # Start Raft cluster if enabled + var raftNet: RaftNetwork = nil if config.raftEnabled: info("Starting Raft node " & config.raftNodeId & " on port " & $config.raftPort) let raftDataDir = config.dataDir / "raft" @@ -357,7 +358,7 @@ proc main() = # Wire replication ↔ DistTxn wireReplicationDistTxn(tcpServer.replicationManager, tcpServer.distTxnManager) - var raftNet = newRaftNetwork(raftNode) + raftNet = newRaftNetwork(raftNode) asyncCheck raftNet.run() # Start replication health check and reconnection loops @@ -386,6 +387,8 @@ proc main() = tcpServer.stop() if tcpServer.gossipProtocol != nil: tcpServer.gossipProtocol.stop() + if raftNet != nil: + raftNet.stop() withStorageGate: registry.closeAll()