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

---
 .../java/derms/net/ConcurrentMulticastSocket.java  | 33 ++++++++++++++++++++++
 1 file changed, 33 insertions(+)
 create mode 100644 src/main/java/derms/net/ConcurrentMulticastSocket.java

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

diff --git a/src/main/java/derms/net/ConcurrentMulticastSocket.java b/src/main/java/derms/net/ConcurrentMulticastSocket.java
new file mode 100644
index 0000000..dba718b
--- /dev/null
+++ b/src/main/java/derms/net/ConcurrentMulticastSocket.java
@@ -0,0 +1,33 @@
+package derms.net;
+
+import java.io.IOException;
+import java.net.DatagramPacket;
+import java.net.InetAddress;
+import java.net.MulticastSocket;
+
+public class ConcurrentMulticastSocket {
+    private final MulticastSocket sock;
+
+    /** Create a socket for sending. */
+    public ConcurrentMulticastSocket() throws IOException {
+        this.sock = new MulticastSocket();
+    }
+
+    /** Create a socket bound to the specified port for receiving. */
+    public ConcurrentMulticastSocket(int port) throws IOException {
+        this.sock = new MulticastSocket(port);
+    }
+
+    /** Join a multicast group. */
+    public synchronized void joinGroup(InetAddress mcastaddr) throws IOException {
+        sock.joinGroup(mcastaddr);
+    }
+
+    public synchronized void send(DatagramPacket p) throws IOException {
+        sock.send(p);
+    }
+
+    public synchronized void receive(DatagramPacket p) throws IOException {
+        sock.receive(p);
+    }
+}
-- 
cgit v1.2.3