diff options
| author | Sam Anthony <sam@samanthony.xyz> | 2024-11-20 12:28:11 -0500 |
|---|---|---|
| committer | Sam Anthony <sam@samanthony.xyz> | 2024-11-20 12:28:11 -0500 |
| commit | f107ea8af0e83d505022e934805bb096e636acff (patch) | |
| tree | 6210e83ed2d5b534043e7ec20183268de26cd2d4 /src/main/java/derms/net | |
| parent | 22c5d0003228d43df61c7ad56d3da847e99321e5 (diff) | |
| download | soen423-f107ea8af0e83d505022e934805bb096e636acff.zip | |
rmulticast: fix comment
Diffstat (limited to 'src/main/java/derms/net')
| -rw-r--r-- | src/main/java/derms/net/rmulticast/Receive.java | 6 |
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; |