From 6f7d5674f678df8088f2b918a4cb2c8d6f291d8b Mon Sep 17 00:00:00 2001
From: Sam Anthony <sam@samanthony.xyz>
Date: Tue, 19 Nov 2024 11:22:56 -0500
Subject: runicast: send initial sync in syncer loop

---
 src/main/java/derms/net/runicast/Connection.java | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

(limited to 'src/main/java/derms/net/runicast/Connection.java')

diff --git a/src/main/java/derms/net/runicast/Connection.java b/src/main/java/derms/net/runicast/Connection.java
index 034d043..534112a 100644
--- a/src/main/java/derms/net/runicast/Connection.java
+++ b/src/main/java/derms/net/runicast/Connection.java
@@ -118,6 +118,8 @@ public class Connection implements Runnable {
         Instant tstart = Instant.now();
         for (;;) {
             try {
+                sendCtl(Type.sync, id0, 0);
+
                 ControlMessage msg = recvCtl(rexitTimeout);
                 if (msg.type == Type.ack && msg.ack != id0
                         || msg.type == Type.close && msg.ack == id0) {
@@ -126,8 +128,6 @@ public class Connection implements Runnable {
                 } else if (msg.type == Type.sync && msg.ack == id0) {
                     state.set(State.established);
                     return;
-                } else {
-                    continue;
                 }
             } catch (SocketTimeoutException e) {
                 Duration elapsed = Duration.between(tstart, Instant.now());
@@ -135,8 +135,6 @@ public class Connection implements Runnable {
                     state.set(State.closed);
                     return;
                 }
-                sendCtl(Type.sync, id0, 0);
-                continue;
             }
         }
     }
-- 
cgit v1.2.3