From b3608b5f5f02678114500e77deb3bb9ef310d25d Mon Sep 17 00:00:00 2001 From: Sam Anthony Date: Fri, 22 Nov 2024 12:48:24 -0500 Subject: runicast: make constructors public --- src/main/java/derms/net/runicast/ReliableUnicastReceiver.java | 5 ++++- src/main/java/derms/net/runicast/ReliableUnicastSender.java | 7 +++++-- 2 files changed, 9 insertions(+), 3 deletions(-) (limited to 'src/main/java') diff --git a/src/main/java/derms/net/runicast/ReliableUnicastReceiver.java b/src/main/java/derms/net/runicast/ReliableUnicastReceiver.java index dc69834..81e3502 100644 --- a/src/main/java/derms/net/runicast/ReliableUnicastReceiver.java +++ b/src/main/java/derms/net/runicast/ReliableUnicastReceiver.java @@ -10,6 +10,7 @@ import java.time.Duration; import java.util.concurrent.*; import java.util.logging.Logger; +/** The receiving end of a reliable unicast connection. */ public class ReliableUnicastReceiver { private static final Duration soTimeout = Duration.ofMillis(500); // Socket timeout. @@ -19,9 +20,11 @@ public class ReliableUnicastReceiver { private final ExecutorService pool; /** + * Listen for incoming messages on the specified address and port. + * * @param laddr The local IP address and port to listen on. */ - ReliableUnicastReceiver(SocketAddress laddr) throws IOException { + public ReliableUnicastReceiver(SocketAddress laddr) throws IOException { this.sock = new ConcurrentDatagramSocket(laddr); this.sock.setSoTimeout(soTimeout); this.delivered = new LinkedBlockingQueue(); diff --git a/src/main/java/derms/net/runicast/ReliableUnicastSender.java b/src/main/java/derms/net/runicast/ReliableUnicastSender.java index ecfece4..83408d5 100644 --- a/src/main/java/derms/net/runicast/ReliableUnicastSender.java +++ b/src/main/java/derms/net/runicast/ReliableUnicastSender.java @@ -16,6 +16,7 @@ import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.atomic.AtomicLong; import java.util.logging.Logger; +/** The sending end of a reliable unicast connection. */ public class ReliableUnicastSender { private static final Duration soTimeout = Duration.ofMillis(500); // Socket timeout. @@ -27,9 +28,11 @@ public class ReliableUnicastSender { private final ExecutorService pool; /** - * @param raddr Remote IP address to connect to. + * Connect to the specified address and port. + * + * @param raddr The remote IP address to connect to. */ - ReliableUnicastSender(InetSocketAddress raddr) throws IOException { + public ReliableUnicastSender(InetSocketAddress raddr) throws IOException { this.next = new AtomicLong(0); this.unacked = new AtomicLong(0); this.sent = new LinkedBlockingQueue>(); -- cgit v1.2.3