From f220fa6eeea1368537fdaf76508fed88ee0b700c Mon Sep 17 00:00:00 2001 From: Matthias Jaros Date: Sun, 22 Feb 2026 21:20:51 +0100 Subject: Refactoring --- .../java/com/it_jaros/networkScanner/Scanner.java | 20 ++++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) (limited to 'src/main/java/com/it_jaros/networkScanner/Scanner.java') diff --git a/src/main/java/com/it_jaros/networkScanner/Scanner.java b/src/main/java/com/it_jaros/networkScanner/Scanner.java index 53e1dcf..8167661 100644 --- a/src/main/java/com/it_jaros/networkScanner/Scanner.java +++ b/src/main/java/com/it_jaros/networkScanner/Scanner.java @@ -40,11 +40,9 @@ public class Scanner { try (ExecutorService executor = Executors.newVirtualThreadPerTaskExecutor();) { List hosts = new ArrayList<>(); for (String target : targets) { - PortRange portRange = new PortRange(ports); - Progress progress = new Progress(target, portRange.getTotal(), new AtomicInteger(), - new AtomicInteger()); - hosts.add(progress); - results.add(scanTargetPorts(target, portRange, executor, progress)); + ScanResult result = scanTargetPorts(target, ports, executor); + results.add(result); + hosts.add(result.progress()); } progressBar.start(hosts); } @@ -54,8 +52,10 @@ public class Scanner { return results; } - private ScanResult scanTargetPorts(String target, PortRange portRange, ExecutorService executor, - Progress p) { + private ScanResult scanTargetPorts(String target, String ports, ExecutorService executor) { + PortRange portRange = new PortRange(ports); + Progress progress = new Progress(target, portRange.getTotal(), new AtomicInteger(), + new AtomicInteger()); AtomicLong scanSlotFactory = new AtomicLong(System.nanoTime()); Queue openPorts = new ConcurrentLinkedQueue<>(); while (portRange.hasNext()) { @@ -65,14 +65,14 @@ public class Scanner { waitForSlot(scanSlotFactory); if (isTargetPortOpen(target, currentPort)) { openPorts.add(currentPort); - progressBar.onPortOpen(p); + progressBar.onPortOpen(progress); } } finally { - progressBar.onPortFinished(p); + progressBar.onPortFinished(progress); } }); } - return new ScanResult(target, openPorts); + return new ScanResult(target, openPorts, progress); } private void waitForSlot(AtomicLong scanSlotFactory) { -- cgit v1.3.1