diff options
Diffstat (limited to 'src/main/java/derms/net/runicast')
| -rw-r--r-- | src/main/java/derms/net/runicast/Connection.java | 32 |
1 files changed, 27 insertions, 5 deletions
diff --git a/src/main/java/derms/net/runicast/Connection.java b/src/main/java/derms/net/runicast/Connection.java index 4824c2a..99f99a7 100644 --- a/src/main/java/derms/net/runicast/Connection.java +++ b/src/main/java/derms/net/runicast/Connection.java @@ -2,8 +2,10 @@ package derms.net.runicast; import derms.net.ConcurrentDatagramSocket; import derms.net.Packet; +import sun.reflect.generics.reflectiveObjects.NotImplementedException; import java.io.IOException; +import java.io.NotActiveException; import java.net.*; import java.time.Duration; import java.time.Instant; @@ -85,19 +87,19 @@ public class Connection implements Runnable { syncer(); continue; case syncee: - // TODO + syncee(); continue; case established: - // TODO + established(); continue; case listening: - // TODO + listening(); continue; case closing: - // TODO + closing(); continue; case opening: - // TODO + opening(); continue; default: throw new IllegalStateException("illegal connection state: " + state); @@ -133,6 +135,26 @@ public class Connection implements Runnable { } } + private void syncee() { + throw new NotImplementedException(); + } + + private void established() { + throw new NotImplementedException(); + } + + private void listening() { + throw new NotImplementedException(); + } + + private void closing() { + throw new NotImplementedException(); + } + + private void opening() { + throw new NotImplementedException(); + } + private void sendCtl(Type type, int id, int ack) throws IOException { ControlMessage msg = new ControlMessage(type, id, ack); DatagramPacket pkt = Packet.encode(msg, raddr, rport); |