Stop the packet transfer if the socket is closed

MCXboxBroadcast · Sep 6, 2024 · fdfad9a · fdfad9a
1 parent 7df08f5
commit fdfad9a
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/core/src/main/java/com/rtm516/mcxboxbroadcast/core/webrtc/CustomDatagramTransport.java b/core/src/main/java/com/rtm516/mcxboxbroadcast/core/webrtc/CustomDatagramTransport.java
@@ -31,6 +31,7 @@ public int getSendLimit() {
     public int receive(byte[] buf, int off, int len, int waitMillis) throws IOException {
         if (socket.isClosed()) {
             this.close();
+            return -1;
         }
         DatagramPacket packet = new DatagramPacket(buf, off, len);
         socket.receive(packet);
@@ -41,6 +42,7 @@ public int receive(byte[] buf, int off, int len, int waitMillis) throws IOExcept
     public void send(byte[] buf, int off, int len) throws IOException {
         if (socket.isClosed()) {
             this.close();
+            return;
         }
         socket.send(new DatagramPacket(buf, off, len));
     }