WIP

scalecube · Jun 20, 2024 · 3761548 · 3761548
1 parent 959a24e
commit 3761548
Showing 1 changed file with 20 additions and 0 deletions.
diff --git a/cluster2/src/test/java/io/scalecube/cluster2/fdetector/FailureDetectorTest.java b/cluster2/src/test/java/io/scalecube/cluster2/fdetector/FailureDetectorTest.java
@@ -127,6 +127,26 @@ void testOnMembershipEventAddedThenLeaving() {
     verify(transport, never()).send(any(), any(), anyInt(), anyInt());
   }
 
+  @Test
+  void testOnTick() {
+    emitMembershipEvent(MembershipEventType.ADDED, fooMember);
+    failureDetector.doWork();
+
+    epochClock.advance(1);
+    failureDetector.doWork();
+    verify(transport).send(any(), any(), anyInt(), anyInt());
+
+    reset(transport);
+    epochClock.advance(config.pingInterval() + 1);
+    failureDetector.doWork();
+    verify(transport).send(any(), any(), anyInt(), anyInt());
+
+    reset(transport);
+    epochClock.advance(config.pingInterval() + 1);
+    failureDetector.doWork();
+    verify(transport).send(any(), any(), anyInt(), anyInt());
+  }
+
   @Test
   void testPingThenAck() {
     emitMembershipEvent(MembershipEventType.ADDED, fooMember);