Improved performance at the expense of CPU usageHEADtrunk

1 files changed, 3 insertions, 2 deletions

diff --git a/src/main/java/com/it_jaros/jns/scan/engine/ScanPortTask.java b/src/main/java/com/it_jaros/jns/scan/engine/ScanPortTask.java
index 926bffc..5e8aba4 100644
--- a/src/main/java/com/it_jaros/jns/scan/engine/ScanPortTask.java
+++ b/src/main/java/com/it_jaros/jns/scan/engine/ScanPortTask.java
@@ -29,6 +29,8 @@ public class ScanPortTask implements Callable<PortResult> {
     private final boolean bannerRecognition;
     private final int port;
     private final long timeoutInNanos;
+    private final long waitInMillis = 100;
+    final long waitInNanos = TimeUnit.MILLISECONDS.toNanos(waitInMillis);
 
     ScanPortTask(int port, ScanExecutionContext context, ScanHostContext hostContext) {
         this.inetAddress = hostContext.hostAddress();
@@ -84,7 +86,6 @@ public class ScanPortTask implements Callable<PortResult> {
         socketChannel.configureBlocking(false);
         socketChannel.connect(new InetSocketAddress(inetAddress, port));
         final long deadlineNanos = System.nanoTime() + timeoutInNanos;
-        final long waitInNanos = TimeUnit.MILLISECONDS.toNanos(1000);
         boolean isConnected = socketChannel.finishConnect();
         while (!cancelledToken.isCancelled() && !isConnected) {
             long remainingNanos = deadlineNanos - System.nanoTime();
@@ -134,7 +135,7 @@ public class ScanPortTask implements Callable<PortResult> {
             if (remaining <= 0) {
                 timedout = true;
             } else {
-                LockSupport.parkNanos(Math.min(remaining, TimeUnit.MILLISECONDS.toNanos(1000)));
+                LockSupport.parkNanos(Math.min(remaining, waitInNanos));
             }
         }
         return byteArrayOutputStream.toByteArray();