Compare commits

..

2 Commits

5 changed files with 19 additions and 9 deletions

6
.idea/vcs.xml Normal file
View File

@ -0,0 +1,6 @@
<?xml version="1.0" encoding="UTF-8"?>
<project version="4">
<component name="VcsDirectoryMappings">
<mapping directory="" vcs="Git" />
</component>
</project>

Binary file not shown.

View File

@ -1,7 +1,6 @@
package com.captainalm.test.calmnet;
import com.captainalm.lib.calmnet.SSLUtilities;
import com.captainalm.lib.calmnet.SSLUtilityException;
import com.captainalm.lib.calmnet.ssl.*;
import com.captainalm.lib.calmnet.packet.IPacket;
import com.captainalm.lib.calmnet.packet.PacketException;
import com.captainalm.lib.calmnet.packet.core.NetworkSSLUpgradePacket;

View File

@ -1,6 +1,8 @@
package com.captainalm.test.calmnet;
import com.captainalm.lib.calmnet.packet.*;
import com.captainalm.lib.calmnet.packet.factory.CALMNETPacketFactory;
import com.captainalm.lib.calmnet.packet.factory.IPacketFactory;
import java.nio.file.Path;

View File

@ -1,12 +1,9 @@
package com.captainalm.test.calmnet;
import com.captainalm.lib.calmnet.SSLUtilities;
import com.captainalm.lib.calmnet.SSLUtilityException;
import com.captainalm.lib.calmnet.ssl.*;
import com.captainalm.lib.calmnet.packet.*;
import com.captainalm.lib.calmnet.packet.core.NetworkSSLUpgradePacket;
import com.captainalm.lib.calmnet.packet.fragment.FragmentAllocationPacket;
import com.captainalm.lib.calmnet.packet.fragment.FragmentPIDPacket;
import com.captainalm.lib.calmnet.packet.fragment.FragmentSendStopPacket;
import com.captainalm.lib.calmnet.packet.fragment.*;
import com.captainalm.lib.calmnet.stream.NetworkInputStream;
import com.captainalm.lib.calmnet.stream.NetworkOutputStream;
@ -89,9 +86,15 @@ public final class NetworkRuntime {
private void init(boolean useFragmentation, boolean verifyFragmentPayloads) {
fragmentReceiver = (useFragmentation) ? new FragmentReceiver(factory.getPacketLoader(), factory) : null;
if (fragmentReceiver != null) fragmentReceiver.setResponseVerification(verifyFragmentPayloads);
if (fragmentReceiver != null) {
fragmentReceiver.setResponseVerification(verifyFragmentPayloads);
fragmentReceiver.setSentDataWillBeAllVerified(verifyFragmentPayloads);
}
fragmentSender = (useFragmentation) ? new FragmentSender(factory.getPacketLoader()) : null;
if (fragmentSender != null) fragmentSender.setResponseVerification(verifyFragmentPayloads);
if (fragmentSender != null) {
fragmentSender.setResponseVerification(verifyFragmentPayloads);
fragmentSender.setSentDataWillBeAllVerified(verifyFragmentPayloads);
}
receiveThread.start();
if (useFragmentation) {
fragmentMonitorThread.start();