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/Receive.java | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

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

diff --git a/src/main/java/derms/net/rmulticast/Receive.java b/src/main/java/derms/net/rmulticast/Receive.java
index f20f833..29ee305 100644
--- a/src/main/java/derms/net/rmulticast/Receive.java
+++ b/src/main/java/derms/net/rmulticast/Receive.java
@@ -50,12 +50,15 @@ class Receive<T extends Serializable & Hashable> implements Runnable {
     }
 
     private void receive(Message<T> msg) {
+        groupMembers.add(msg.sender);
+
+        if (msg instanceof AnnounceMessage)
+            return;
+
         acks.add(msg.id());
         received.add(msg);
         delivered.add(msg);
 
-        groupMembers.add(msg.sender);
-
         nacks.remove(msg.id());
         retransmissions.remove(msg);
 
-- 
cgit v1.2.3