From c2853e0a0f02c863336c672db92c1b6ba41a1e3d Mon Sep 17 00:00:00 2001
From: Matthias Jaros <jarlucmat@mailbox.org>
Date: Sat, 22 Aug 2026 09:15:28 +0200
Subject: Wrapped ScanPortException in class

---
 .../jns/scan/engine/ScanPortException.java         |  7 +++++++
 .../com/it_jaros/jns/scan/engine/ScanPortTask.java | 23 +++++++++++++---------
 2 files changed, 21 insertions(+), 9 deletions(-)
 create mode 100644 src/main/java/com/it_jaros/jns/scan/engine/ScanPortException.java

(limited to 'src')

diff --git a/src/main/java/com/it_jaros/jns/scan/engine/ScanPortException.java b/src/main/java/com/it_jaros/jns/scan/engine/ScanPortException.java
new file mode 100644
index 0000000..5c5389f
--- /dev/null
+++ b/src/main/java/com/it_jaros/jns/scan/engine/ScanPortException.java
@@ -0,0 +1,7 @@
+package com.it_jaros.jns.scan.engine;
+
+public class ScanPortException extends RuntimeException {
+    public ScanPortException(int port, Exception e) {
+        super(String.valueOf(port), e);
+    }
+}
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 4255d6e..64d3298 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
@@ -43,17 +43,22 @@ public class ScanPortTask implements Callable<PortResult> {
 
     @Override
     public PortResult call() throws Exception {
-        socketLimit.acquire();
         try {
-            scan.portStart();
-            portScanRateLimiter.apply();
-            if (cancelledToken.isCancelled()) {
-                return PortResult.empty();
+            socketLimit.acquire();
+            try {
+                scan.portStart();
+                portScanRateLimiter.apply();
+                if (cancelledToken.isCancelled()) {
+                    return PortResult.empty();
+                }
+                return checkPort();
+            } finally {
+                scan.portFinish();
+                socketLimit.release();
             }
-            return checkPort();
-        } finally {
-            scan.portFinish();
-            socketLimit.release();
+        } catch (Exception e) {
+            // think about how to handle that
+            throw new ScanPortException(port, e);
         }
     }
 
-- 
cgit v1.3.1