summaryrefslogtreecommitdiffstats
path: root/src/main/java/derms/net/rmulticast/Receive.java
diff options
context:
space:
mode:
authorSam Anthony <sam@samanthony.xyz>2024-11-20 12:28:11 -0500
committerSam Anthony <sam@samanthony.xyz>2024-11-20 12:28:11 -0500
commitf107ea8af0e83d505022e934805bb096e636acff (patch)
tree6210e83ed2d5b534043e7ec20183268de26cd2d4 /src/main/java/derms/net/rmulticast/Receive.java
parent22c5d0003228d43df61c7ad56d3da847e99321e5 (diff)
downloadsoen423-f107ea8af0e83d505022e934805bb096e636acff.zip
rmulticast: fix comment
Diffstat (limited to 'src/main/java/derms/net/rmulticast/Receive.java')
-rw-r--r--src/main/java/derms/net/rmulticast/Receive.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/derms/net/rmulticast/Receive.java b/src/main/java/derms/net/rmulticast/Receive.java
index 679df27..3d25e75 100644
--- a/src/main/java/derms/net/rmulticast/Receive.java
+++ b/src/main/java/derms/net/rmulticast/Receive.java
@@ -19,9 +19,9 @@ class Receive<T extends MessagePayload> implements Runnable {
private static final Duration sockTimeout = Duration.ofMillis(500);
private final ConcurrentMulticastSocket inSock;
- private final Set<MessageID> acks;
- private final Set<MessageID> nacks; // Positively acknowledged messages.
- private final ReceivedSet<T> received; // Negatively acknowledged messages.
+ private final Set<MessageID> acks; // Positively acknowledged messages.
+ private final Set<MessageID> nacks; // Negatively acknowledged messages.
+ private final ReceivedSet<T> received;
private final BlockingQueue<Message<T>> retransmissions;
private final Set<InetAddress> groupMembers;
private final BlockingQueue<Message<T>> delivered;