From d333754c8d4f8af9534300e457d026174a69cb65 Mon Sep 17 00:00:00 2001
From: Sam Anthony <sam@samanthony.xyz>
Date: Thu, 14 Nov 2024 12:05:24 -0500
Subject: ConcurrentMulticastSocket

---
 src/main/java/derms/net/rmulticast/Retransmit.java | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

(limited to 'src/main/java/derms/net/rmulticast/Retransmit.java')

diff --git a/src/main/java/derms/net/rmulticast/Retransmit.java b/src/main/java/derms/net/rmulticast/Retransmit.java
index ad44eb1..3f2fdbb 100644
--- a/src/main/java/derms/net/rmulticast/Retransmit.java
+++ b/src/main/java/derms/net/rmulticast/Retransmit.java
@@ -1,10 +1,10 @@
 package derms.net.rmulticast;
 
+import derms.net.ConcurrentMulticastSocket;
 import derms.net.Packet;
 
 import java.io.Serializable;
 import java.net.DatagramPacket;
-import java.net.MulticastSocket;
 import java.net.SocketAddress;
 import java.util.concurrent.BlockingQueue;
 import java.util.logging.Logger;
@@ -12,11 +12,11 @@ import java.util.logging.Logger;
 /** Retransmit dropped messages. */
 class Retransmit<T extends Serializable & Hashable> implements Runnable {
     private final BlockingQueue<Message<T>> retransmissions;
-    private final MulticastSocket outSock;
+    private final ConcurrentMulticastSocket outSock;
     private final SocketAddress group;
     private final Logger log;
 
-    Retransmit(BlockingQueue<Message<T>> retransmissions, MulticastSocket outSock, SocketAddress group) {
+    Retransmit(BlockingQueue<Message<T>> retransmissions, ConcurrentMulticastSocket outSock, SocketAddress group) {
         this.retransmissions = retransmissions;
         this.outSock = outSock;
         this.group = group;
@@ -30,9 +30,7 @@ class Retransmit<T extends Serializable & Hashable> implements Runnable {
                 Message<T> msg = retransmissions.take();
                 try {
                     DatagramPacket pkt = Packet.encode(msg, group);
-                    synchronized (outSock) {
-                        outSock.send(pkt);
-                    }
+                    outSock.send(pkt);
                 } catch (Exception e) {
                     log.warning(e.getMessage());
                 }
-- 
cgit v1.2.3