alfred/calmnetlib
1
0
Fork 0
Code Issues Pull Requests Projects Releases 2 Wiki Activity

Fix bugs in NetMarshalClient.

Browse Source
This commit is contained in:
Captain ALM 2023-05-20 15:49:54 +01:00
parent e3f294c090
commit 93b40d57a3
Signed by: alfred
GPG Key ID: 4E4ADD02609997B1
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/com/captainalm/lib/calmnet/marshal/NetMarshalClient.java
View File

@ -121,6 +121,8 @@ public class NetMarshalClient implements Closeable {
} }
fragmentReceiver.clearRegistry(); fragmentReceiver.clearRegistry();
fragmentSender.clearRegistry(); fragmentSender.clearRegistry();
fragmentRMM.clear();
fragmentSMM.clear();
}, "thread_frag_monitor_" + remoteAddress.getHostAddress() + ":" + remotePort); }, "thread_frag_monitor_" + remoteAddress.getHostAddress() + ":" + remotePort);
fragmentFinishReceiveMonitorThread = new Thread(() -> { fragmentFinishReceiveMonitorThread = new Thread(() -> {
while (running) { while (running) {
@ -145,7 +147,7 @@ public class NetMarshalClient implements Closeable {
} }
} }
fragmentSender.clearLastIDFinished(); fragmentSender.clearLastIDFinished();
}, "thread_frag_fin_recv_monitor_" + remoteAddress.getHostAddress() + ":" + remotePort); }, "thread_frag_fin_send_monitor_" + remoteAddress.getHostAddress() + ":" + remotePort);
receiveThread = new Thread(() -> { receiveThread = new Thread(() -> {
while (running) receiveThreadExecutedWithFragmentation(); while (running) receiveThreadExecutedWithFragmentation();
fragmentReceiver.clearWaitingPackets(); fragmentReceiver.clearWaitingPackets();