diff options
| author | Sam Anthony <sam@samanthony.xyz> | 2024-11-20 10:07:19 -0500 |
|---|---|---|
| committer | Sam Anthony <sam@samanthony.xyz> | 2024-11-20 10:07:19 -0500 |
| commit | a6b4da70d34679db3ff18e1f44f41832326a94d9 (patch) | |
| tree | 8ec2783d5dca180a40e964310fd0ede7a93e3274 /src/main/java/derms/net/runicast/ReliableUnicast.java | |
| parent | 8b4f036d69ee10612fb947e7748c8081d04b1b5c (diff) | |
| download | soen423-a6b4da70d34679db3ff18e1f44f41832326a94d9.zip | |
stash IL
Diffstat (limited to 'src/main/java/derms/net/runicast/ReliableUnicast.java')
| -rw-r--r-- | src/main/java/derms/net/runicast/ReliableUnicast.java | 39 |
1 files changed, 0 insertions, 39 deletions
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); - } - } -} |