summaryrefslogtreecommitdiff
path: root/src/main/java/com/it_jaros/jscanner/Scanner.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com/it_jaros/jscanner/Scanner.java')
-rw-r--r--src/main/java/com/it_jaros/jscanner/Scanner.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/main/java/com/it_jaros/jscanner/Scanner.java b/src/main/java/com/it_jaros/jscanner/Scanner.java
index 63b1d14..4910b9c 100644
--- a/src/main/java/com/it_jaros/jscanner/Scanner.java
+++ b/src/main/java/com/it_jaros/jscanner/Scanner.java
@@ -70,6 +70,7 @@ public class Scanner implements AutoCloseable {
host -> () -> {
try {
scan.getHostCounter().inc();
+ scan.getHostTotalCounter().inc();
return scanHostPorts(host, scan);
} finally {
scan.getHostCounter().dec();
@@ -99,10 +100,9 @@ public class Scanner implements AutoCloseable {
consumer.accept(result);
}
} finally {
- scan.getHostTotalCounter().inc();
- scan.getThreadCounter().dec();
state.activeWorkers().release();
state.inPipeline().decrementAndGet();
+ scan.getThreadCounter().dec();
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt();