fixup! C: ReplayController

TinyLake · May 1, 2024 · 48e23e5 · 48e23e5
1 parent 522924f
commit 48e23e5
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/core/src/mindustryX/features/ReplayController.java b/core/src/mindustryX/features/ReplayController.java
@@ -104,6 +104,12 @@ public static void stop(){
         writes = null;
     }
 
+    private static Net fakeServer = new Net(null){
+        @Override
+        public boolean server(){
+            return true;
+        }
+    };
     public static void onClientPacket(Packet p){
         if(!recording || p instanceof Streamable) return;
         if(p instanceof Disconnect){
@@ -117,7 +123,10 @@ public static void onClientPacket(Packet p){
                 writes.f(Time.time - startTime);
                 writes.b(id);
                 tmpBuf.position(0);
+                var bak = net;
+                net = fakeServer;
                 p.write(tmpWr);
+                net = bak;
                 int l = tmpBuf.position();
                 writes.s(l);
                 writes.b(tmpBuf.array(), 0, l);
@@ -181,7 +190,6 @@ public static void startPlay(Fi input){
         net.reset();
         netClient.beginConnecting();
         Reflect.set(net, "active", true);
-        Reflect.set(net, "server", true);
 
         startTime = Time.time;
         Threads.daemon("Replay Controller", () -> {
@@ -192,7 +200,7 @@ public static void startPlay(Fi input){
                     Packet p = Net.newPacket(reads.b());
                     p.read(reads, reads.us());
                     while(Time.time - startTime < nextTime)
-                        Thread.yield();
+                        Thread.sleep(1);
                     Core.app.post(() -> net.handleClientReceived(p));
                 }
             }catch(Exception e){