From e0196b370e8da38d366d327da57186dd3a44c2b2 Mon Sep 17 00:00:00 2001
From: Sam Anthony <sam@samanthony.xyz>
Date: Sat, 16 Nov 2024 10:39:06 -0500
Subject: reliable multicast: periodically send acks

---
 src/main/java/derms/net/rmulticast/ReliableMulticast.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

(limited to 'src/main/java/derms/net/rmulticast/ReliableMulticast.java')

diff --git a/src/main/java/derms/net/rmulticast/ReliableMulticast.java b/src/main/java/derms/net/rmulticast/ReliableMulticast.java
index 2ead37e..72b3019 100644
--- a/src/main/java/derms/net/rmulticast/ReliableMulticast.java
+++ b/src/main/java/derms/net/rmulticast/ReliableMulticast.java
@@ -61,9 +61,9 @@ public class ReliableMulticast<T extends MessagePayload> {
         (new Thread(new Prune<T>(received, groupMembers))).start();
 
         try {
-            (new Thread(new Announce(group, laddr, outSock))).start();
+            (new Thread(new Heartbeat(group, laddr, acks, nacks, outSock))).start();
         } catch (IOException e) {
-            log.severe("Failed to start announce thread: " + e.getMessage());
+            log.severe("Failed to start heartbeat thread: " + e.getMessage());
             throw e;
         }
     }
-- 
cgit v1.2.3