Connector

src/server.cpp

@@ -80,6 +80,19 @@ NNet::TTestTask TNode::DoDrain() {
     co_return;
 }
 
+NNet::TTestTask TNode::DoConnect() {
+    while (!Connected) {
+        try {
+            auto deadline = TimeSource->Now() + std::chrono::milliseconds(15000);
+            co_await Socket.Connect(deadline);
+            Connected = true;
+        } catch (const std::exception& ex) {
+            std::cout << "Error on connect: " << ex.what() << "\n";
+        }
+    }
+    co_return;
+}
+
 NNet::TSimpleTask TRaftServer::InboundConnection(NNet::TSocket socket) {
     try {
         while (true) {

src/server.h

@@ -109,21 +109,24 @@ class TWriter {
 
 class TNode: public INode {
 public:
-    TNode(NNet::TPoll& poller, uint32_t id, NNet::TAddress address)
+    TNode(NNet::TPoll& poller, uint32_t id, NNet::TAddress address, const std::shared_ptr<ITimeSource>& ts)
         : Poller(poller)
         , Id(id)
         , Address(address)
+        , TimeSource(ts)
     { }
 
     void Send(const TMessageHolder<TMessage>& message) override;
     void Drain() override;
 
 private:
     NNet::TTestTask DoDrain();
+    NNet::TTestTask DoConnect();
 
     NNet::TPoll& Poller;
     uint32_t Id;
     NNet::TAddress Address;
+    std::shared_ptr<ITimeSource> TimeSource;
     NNet::TPoll::TSocket Socket;
     bool Connected = false;
 

src/timesource.h

@@ -3,14 +3,14 @@
 #include <chrono>
 
 struct ITimeSource {
-    using Time = std::chrono::time_point<std::chrono::system_clock>;
+    using Time = std::chrono::time_point<std::chrono::steady_clock>;
     virtual ~ITimeSource() = default;
     virtual Time Now() = 0;
 };
 
 class TTimeSource: public ITimeSource {
 public:
     Time Now() override {
-        return std::chrono::system_clock::now();
+        return std::chrono::steady_clock::now();
     }
 };

test/test_raft.cpp

@@ -45,7 +45,7 @@ class TFakeNode: public INode {
 class TFakeTimeSource: public ITimeSource {
 public:
     TFakeTimeSource()
-        : T(std::chrono::system_clock::now())
+        : T(std::chrono::steady_clock::now())
     { }
 
     ITimeSource::Time Now() override {