summaryrefslogtreecommitdiffstats
path: root/src/main/java/derms/net
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/derms/net')
-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;