From e0196b370e8da38d366d327da57186dd3a44c2b2 Mon Sep 17 00:00:00 2001 From: Sam Anthony Date: Sat, 16 Nov 2024 10:39:06 -0500 Subject: reliable multicast: periodically send acks --- src/main/java/derms/net/rmulticast/HeartbeatMessage.java | 10 ++++++++++ 1 file changed, 10 insertions(+) create mode 100644 src/main/java/derms/net/rmulticast/HeartbeatMessage.java (limited to 'src/main/java/derms/net/rmulticast/HeartbeatMessage.java') diff --git a/src/main/java/derms/net/rmulticast/HeartbeatMessage.java b/src/main/java/derms/net/rmulticast/HeartbeatMessage.java new file mode 100644 index 0000000..a5a3c61 --- /dev/null +++ b/src/main/java/derms/net/rmulticast/HeartbeatMessage.java @@ -0,0 +1,10 @@ +package derms.net.rmulticast; + +import java.net.InetAddress; + +/** A message whose only purpose is to propagate acknowledgements and process IDs to the group. */ +class HeartbeatMessage extends Message { + HeartbeatMessage(InetAddress sender, MessageID[] acks, MessageID[] nacks) { + super(new NullPayload(), sender, acks, nacks); + } +} -- cgit v1.2.3