From 050942608e70d01e5833fe5d0e5019071f95c68b Mon Sep 17 00:00:00 2001
From: Sam Anthony <sam@samanthony.xyz>
Date: Fri, 15 Nov 2024 17:03:21 -0500
Subject: reliable multicast: announce presence to group

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

(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 528bb41..a9e1fa4 100644
--- a/src/main/java/derms/net/rmulticast/ReliableMulticast.java
+++ b/src/main/java/derms/net/rmulticast/ReliableMulticast.java
@@ -53,6 +53,13 @@ public class ReliableMulticast<T extends Serializable & Hashable> {
         (new Thread(new Retransmit<T>(retransmissions, outSock, group))).start();
 
         (new Thread(new Prune<T>(received, groupMembers))).start();
+
+        try {
+            (new Thread(new Announce(group, laddr, outSock))).start();
+        } catch (IOException e) {
+            log.severe("Failed to start announce thread: " + e.getMessage());
+            throw e;
+        }
     }
 
     public void send(T payload) throws IOException {
-- 
cgit v1.2.3