From a6b4da70d34679db3ff18e1f44f41832326a94d9 Mon Sep 17 00:00:00 2001 From: Sam Anthony Date: Wed, 20 Nov 2024 10:07:19 -0500 Subject: stash IL --- .../java/derms/net/runicast/ReliableUnicast.java | 39 ---------------------- 1 file changed, 39 deletions(-) delete mode 100644 src/main/java/derms/net/runicast/ReliableUnicast.java (limited to 'src/main/java/derms/net/runicast/ReliableUnicast.java') diff --git a/src/main/java/derms/net/runicast/ReliableUnicast.java b/src/main/java/derms/net/runicast/ReliableUnicast.java deleted file mode 100644 index 6aa4e48..0000000 --- a/src/main/java/derms/net/runicast/ReliableUnicast.java +++ /dev/null @@ -1,39 +0,0 @@ -package derms.net.runicast; - -import derms.net.ConcurrentDatagramSocket; - -import java.io.IOException; -import java.net.DatagramSocket; -import java.net.InetAddress; - -/** TODO */ -public class ReliableUnicast { - public static Connection listen(InetAddress laddr, int lport) { - // TODO - } - - public static Connection connect(InetAddress raddr, int rport) throws IOException { - ConcurrentDatagramSocket sock = new ConcurrentDatagramSocket(); - sock.connect(raddr, rport); - InetAddress laddr = sock.getLocalAddress(); - int lport = sock.getLocalPort(); - Connection conn = new Connection(laddr, lport, raddr, rport, sock); - - conn.state.set(State.syncer); - conn.start(); - while (conn.state.get() == State.syncer) - Thread.yield(); - - State state = conn.state.get(); - switch (state) { - case established: - return conn; - case closed: - conn.close(); - throw new IOException("failed to connect to " + raddr + ":" + rport); - default: - conn.close(); - throw new IllegalStateException("illegal connection state: " + state); - } - } -} -- cgit v1.2.3