Polish

resetius · Nov 26, 2023 · 234064c · 234064c
1 parent 75408cf
commit 234064c
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 7 deletions.
diff --git a/src/raft.cpp b/src/raft.cpp
@@ -59,7 +59,7 @@ TRaft::TRaft(int node, const TNodeDict& nodes, const std::shared_ptr<ITimeSource
     : Id(node)
     , Nodes(nodes)
     , TimeSource(ts)
-    , MinVotes((nodes.size()+1/2))
+    , MinVotes((nodes.size()+2)/2)
     , Npeers(nodes.size())
     , Nservers(nodes.size()+1)
     , State(std::make_unique<TState>())
@@ -428,14 +428,12 @@ void TRaft::ApplyResult(ITimeSource::Time now, std::unique_ptr<TResult> result,
                     v->Send(messageEx);
                 }
             } else {
-                std::cout << "Send reply to " << messageEx->Dst << "\n";
                 Nodes[messageEx->Dst]->Send(std::move(messageEx));
             }
         }
     }
     if (!result->Messages.empty()) {
         for (auto&& m : result->Messages) {
-            std::cout << "Send append entries to " << m->Dst << "\n";
             Nodes[m->Dst]->Send(std::move(m));
         }
     }

diff --git a/src/server.h b/src/server.h
@@ -203,12 +203,10 @@ class TRaftServer {
 
 private:
     NNet::TSimpleTask InboundServe();
+    NNet::TSimpleTask InboundConnection(NNet::TSocket socket);
     NNet::TSimpleTask Idle();
     void DrainNodes();
 
-    NNet::TSimpleTask InboundConnection(NNet::TSocket socket);
-    NNet::TTestTask Connector(std::shared_ptr<INode> node);
-
     NNet::TPoll& Poller;
     NNet::TPoll::TSocket Socket;
     std::shared_ptr<TRaft> Raft;

diff --git a/test/test_raft.cpp b/test/test_raft.cpp
@@ -552,7 +552,7 @@ void test_election_5_nodes(void**) {
     raft->Process(req);
 
     assert_int_equal(raft->CurrentStateName(), EState::CANDIDATE);
-    req->Src = 3;
+    req->Src = 2;
     raft->Process(req);
     assert_int_equal(raft->CurrentStateName(), EState::CANDIDATE);