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