diff options
| author | Sam Anthony <sam@samanthony.xyz> | 2024-11-16 13:13:46 -0500 |
|---|---|---|
| committer | Sam Anthony <sam@samanthony.xyz> | 2024-11-16 13:13:46 -0500 |
| commit | 034bace1a53943838e49a7d2442025276f60bc55 (patch) | |
| tree | 1c0ec338d870a0b133c7f8b7d2e996a7ed4b10b2 /src/main/java/derms | |
| parent | c281c7cbb8f1e044c3d4f4409cbbfcaf73fa40c9 (diff) | |
| download | soen423-034bace1a53943838e49a7d2442025276f60bc55.zip | |
reliable multicast: construct hashmap keysets correctly
Diffstat (limited to 'src/main/java/derms')
| -rw-r--r-- | src/main/java/derms/net/rmulticast/ReliableMulticast.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/derms/net/rmulticast/ReliableMulticast.java b/src/main/java/derms/net/rmulticast/ReliableMulticast.java index 19b7bd7..cfd4435 100644 --- a/src/main/java/derms/net/rmulticast/ReliableMulticast.java +++ b/src/main/java/derms/net/rmulticast/ReliableMulticast.java @@ -41,11 +41,11 @@ public class ReliableMulticast<T extends MessagePayload> { this.group = group; this.laddr = laddr; - this.acks = new ConcurrentHashMap<MessageID, Void>().keySet(); - this.nacks = new ConcurrentHashMap<MessageID, Void>().keySet(); + this.acks = ConcurrentHashMap.newKeySet(); + this.nacks = ConcurrentHashMap.newKeySet(); this.received = new ReceivedSet<T>(); this.retransmissions = new LinkedBlockingQueue<Message<T>>(); - this.groupMembers = new ConcurrentHashMap<InetAddress, Void>().keySet(); + this.groupMembers = ConcurrentHashMap.newKeySet(); this.outSock = new ConcurrentMulticastSocket(); this.outSock.joinGroup(group.getAddress()); |