From 93b40d57a3bbe863449d74e20511ced81701871f Mon Sep 17 00:00:00 2001
From: Captain ALM <captainalm@captainalm.com>
Date: Sat, 20 May 2023 15:49:54 +0100
Subject: [PATCH] Fix bugs in NetMarshalClient.

---
 src/com/captainalm/lib/calmnet/marshal/NetMarshalClient.java | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/src/com/captainalm/lib/calmnet/marshal/NetMarshalClient.java b/src/com/captainalm/lib/calmnet/marshal/NetMarshalClient.java
index b41f2c7..5774836 100644
--- a/src/com/captainalm/lib/calmnet/marshal/NetMarshalClient.java
+++ b/src/com/captainalm/lib/calmnet/marshal/NetMarshalClient.java
@@ -121,6 +121,8 @@ public class NetMarshalClient implements Closeable {
                 }
                 fragmentReceiver.clearRegistry();
                 fragmentSender.clearRegistry();
+                fragmentRMM.clear();
+                fragmentSMM.clear();
             }, "thread_frag_monitor_" + remoteAddress.getHostAddress() + ":" + remotePort);
             fragmentFinishReceiveMonitorThread = new Thread(() -> {
                 while (running) {
@@ -145,7 +147,7 @@ public class NetMarshalClient implements Closeable {
                     }
                 }
                 fragmentSender.clearLastIDFinished();
-            }, "thread_frag_fin_recv_monitor_" + remoteAddress.getHostAddress() + ":" + remotePort);
+            }, "thread_frag_fin_send_monitor_" + remoteAddress.getHostAddress() + ":" + remotePort);
             receiveThread = new Thread(() -> {
                 while (running) receiveThreadExecutedWithFragmentation();
                 fragmentReceiver.clearWaitingPackets();