summaryrefslogtreecommitdiff
path: root/src/main/java/com/it_jaros/jscanner/Scanner.java
diff options
context:
space:
mode:
authorGravatar Matthias Jaros <jarlucmat@mailbox.org>2026-08-07 22:13:52 +0200
committerGravatar Matthias Jaros <jarlucmat@mailbox.org>2026-08-07 22:13:52 +0200
commit3dd6e7a05384055d27187b71ee8c9c277e165bbe (patch)
treedce19f2d607af2b34fd2a8ab011be47cae382915 /src/main/java/com/it_jaros/jscanner/Scanner.java
parent2dca7d5c827fd5cf4f15f2efad440fcd50cc6b00 (diff)
Comments refactored
Diffstat (limited to 'src/main/java/com/it_jaros/jscanner/Scanner.java')
-rw-r--r--src/main/java/com/it_jaros/jscanner/Scanner.java5
1 files changed, 3 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 775c0d5..770cb2b 100644
--- a/src/main/java/com/it_jaros/jscanner/Scanner.java
+++ b/src/main/java/com/it_jaros/jscanner/Scanner.java
@@ -244,8 +244,9 @@ public class Scanner implements AutoCloseable {
);
// consumer is the main thread
- // we run as long as the producer is running or as long as things are in pipeline to be processed
- // only exception is when cancelled is set
+ // we run as long as the producer is running OR
+ // as long as things are in pipeline waiting to be processed
+ // ONLY exception is when cancelled is set
final PortResultAccumulator accumulator = new PortResultAccumulator(host);
while (!cancelled && (state.running().get() || state.inPipeline().get() > 0)) {
try {