summaryrefslogtreecommitdiffstats
path: root/src/main/java/derms/net/runicast/ReliableUnicast.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/derms/net/runicast/ReliableUnicast.java')
-rw-r--r--src/main/java/derms/net/runicast/ReliableUnicast.java39
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);
- }
- }
-}