test commit, this may fix our problem with pps

Author: RealSuperUser

build

@@ -29,12 +29,11 @@
             <artifactId>annotations</artifactId>
             <version>24.1.0</version>
         </dependency>
-      <dependency>
+       <dependency>
           <groupId>org.projectlombok</groupId>
           <artifactId>lombok</artifactId>
           <version>RELEASE</version>
-          <scope>compile</scope>
-      </dependency>
+       </dependency>
   </dependencies>
   <build>
     <pluginManagement>

pom.xml

@@ -29,6 +29,8 @@ public void run() {
 		val isResult = Main.runner.parser.get("--sendResult", Boolean.class);
 		val isKeepAlive = Main.runner.parser.get("--keepAlive", Boolean.class);
 		val udp = Main.runner.parser.get("--udp", Boolean.class);
+		val sendBytes = Main.runner.parser.get("--sendBytes", Boolean.class);
+		val byteSize = Main.runner.parser.get("--byteSize", Integer.class);
 		if(this.isDebug()){
 			getLogger().setSection("DEBUG");
 			getLogger().print(Logger.LEVEL.INFO, "ip is: " + ip);
@@ -37,13 +39,15 @@ public void run() {
 			getLogger().print(Logger.LEVEL.INFO, "isResult is: " + isResult);
 			getLogger().print(Logger.LEVEL.INFO, "isKeepAlive is: " + isKeepAlive);
 			getLogger().print(Logger.LEVEL.INFO, "udp is: " + udp);
+			getLogger().print(Logger.LEVEL.INFO, "sendBytes is: " + sendBytes);
+			getLogger().print(Logger.LEVEL.INFO, "byteSize is: " + byteSize);
 		}
 		for(int i = 0; i <= maxThreads; i++){
 			if(this.isDebug)
 				getLogger().print(Logger.LEVEL.INFO, "adding new thread. max: " + maxThreads);
 			getTaskManager().add(new Thread(() -> {
 				while (true)
-					socketUtils.connect(ip, port, isResult, isKeepAlive, udp);
+					socketUtils.connect(ip, port, isResult, isKeepAlive, udp, sendBytes, byteSize);
 			}));
 		}
 		getLogger().print(Logger.LEVEL.INFO,  "doing tasks...");

src/main/java/ir/xenoncommunity/MainRunner.java

@@ -3,12 +3,14 @@
 import ir.xenoncommunity.Main;
 import lombok.val;
 
+import java.io.DataOutputStream;
 import java.net.DatagramSocket;
 import java.net.InetAddress;
 import java.net.Socket;
+import java.nio.ByteBuffer;
 
 public class SocketUtils {
-    public void connect(final String ipAddress, final int port, final boolean sendResult, final boolean keepAlive, final boolean udp) {
+    public void connect(final String ipAddress, final int port, final boolean sendResult, final boolean keepAlive, final boolean udp, final boolean writeBytes, final int byteSize) {
         Main.runner.getLogger().setSection("CONNECT");
         try {
             if (udp) {
@@ -17,18 +19,25 @@ public void connect(final String ipAddress, final int port, final boolean sendRe
                     throw new IllegalStateException("UDP is used with keepAlive.");
                 }
                 try (val socket = new DatagramSocket(port, InetAddress.getByName(ipAddress))) {
-                    if (sendResult && socket.isConnected()) {
+                    if (sendResult && socket.isConnected())
                         Main.runner.getLogger().print(Logger.LEVEL.INFO, String.format("Connected! ip: %s, port: %s, threads: %s\n", ipAddress, port, Main.runner.getTaskManager().tasks.size()));
-                    }
+
+                    if(writeBytes)
+                        socket.getChannel().write(ByteBuffer.allocateDirect(byteSize));
                 }
             } else {
                 try (val socket = new Socket(ipAddress, port)) {
-                    if (sendResult && socket.isConnected()) {
+                    if (sendResult && socket.isConnected())
                         Main.runner.getLogger().print(Logger.LEVEL.INFO, String.format("Connected! ip: %s, port: %s, threads: %s\n", ipAddress, port, Main.runner.getTaskManager().tasks.size()));
+
+                    if(writeBytes){
+                        val os = new DataOutputStream(socket.getOutputStream());
+                        os.write((byte) byteSize);
+                        os.close();
                     }
-                    if (keepAlive) {
+                    if (keepAlive)
                         socket.setKeepAlive(true);
-                    } else
+                    else
                         socket.close();
                 }
             }

src/main/java/ir/xenoncommunity/utils/SocketUtils.java

@@ -10,6 +10,7 @@ public void add(final Thread threadIn){
     }
     public void remove(final int idIn){
         tasks.get(idIn).interrupt();
+        tasks.remove(idIn);
     }
     public void doTasks(){
         tasks.forEach(Thread::start);