From 8b4f036d69ee10612fb947e7748c8081d04b1b5c Mon Sep 17 00:00:00 2001
From: Sam Anthony <sam@samanthony.xyz>
Date: Tue, 19 Nov 2024 11:26:29 -0500
Subject: runicast: state machine function stubs

---
 src/main/java/derms/net/runicast/Connection.java | 32 ++++++++++++++++++++----
 1 file changed, 27 insertions(+), 5 deletions(-)

(limited to 'src/main/java')

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);
-- 
cgit v1.2.3