tests: resolve raft simulation and networking race conditions

Author: poyrazK

tests/multi_raft_tests.cpp

@@ -6,6 +6,7 @@
 #include <gtest/gtest.h>
 
 #include <chrono>
+#include <csignal>
 #include <thread>
 #include <vector>
 
@@ -92,6 +93,7 @@ TEST(MultiRaftTests, StateMachineIntegration) {
  * This ensures high availability by validating consensus emergence.
  */
 TEST(MultiRaftTests, LeaderElectionAndFailover) {
+    signal(SIGPIPE, SIG_IGN);
     const int num_nodes = 3;
     const int base_port = 9200;
 

tests/raft_simulation_tests.cpp

@@ -6,6 +6,7 @@
 #include <gtest/gtest.h>
 
 #include <chrono>
+#include <cstdio>
 #include <thread>
 
 #include "common/cluster_manager.hpp"
@@ -18,6 +19,7 @@ using namespace cloudsql::raft;
 namespace {
 
 TEST(RaftSimulationTests, FollowerToCandidate) {
+    static_cast<void>(std::remove("raft_group_1.state"));
     config::Config config;
     config.mode = config::RunMode::Coordinator;
 
@@ -34,24 +36,31 @@ TEST(RaftSimulationTests, FollowerToCandidate) {
     std::this_thread::sleep_for(std::chrono::milliseconds(500));
 
     // Should have attempted to become candidate/leader
+    group.stop();
+    static_cast<void>(std::remove("raft_group_1.state"));
 }
 
 TEST(RaftSimulationTests, HeartbeatReset) {
+    static_cast<void>(std::remove("raft_group_2.state"));
     config::Config config;
     config.mode = config::RunMode::Coordinator;
 
     cluster::ClusterManager cm(&config);
     network::RpcServer rpc(7001);
 
-    RaftGroup group(1, "node1", cm, rpc);
+    RaftGroup group(2, "node2", cm, rpc);
     group.start();
 
     // Send periodic heartbeats to prevent election
     for (int i = 0; i < 5; ++i) {
-        std::vector<uint8_t> payload(8, 0);  // Term 0
+        std::vector<uint8_t> payload(8, 0);
+        // Use a high term to ensure it's accepted
+        term_t term = 100;
+        std::memcpy(payload.data(), &term, 8);
+        
         network::RpcHeader header;
         header.type = network::RpcType::AppendEntries;
-        header.group_id = 1;
+        header.group_id = 2;
         header.payload_len = 8;
 
         group.handle_append_entries(header, payload, -1);
@@ -60,6 +69,8 @@ TEST(RaftSimulationTests, HeartbeatReset) {
         // Should NOT be leader yet because heartbeats reset the timer
         EXPECT_FALSE(group.is_leader());
     }
+    group.stop();
+    static_cast<void>(std::remove("raft_group_2.state"));
 }
 
 }  // namespace