diff options
| author | 2026-08-07 12:11:47 +0200 | |
|---|---|---|
| committer | 2026-08-07 12:15:18 +0200 | |
| commit | d9d3fb576ecc6d25d7b8a79fd79156b84f74ff90 (patch) | |
| tree | 10faf1a3f27cba16127d3c7839dc71ba1d1ac91e /src/main/java/com/it_jaros/jscanner/Scan.java | |
| parent | 97d4fded3bba629fe9597c58db2fbd7f995edc99 (diff) | |
Moved socketLimit before portRateLimiter because otherwise burst can
happen if sockets reach limit and too many threads accumulate after
portRateLimiter
Diffstat (limited to 'src/main/java/com/it_jaros/jscanner/Scan.java')
| -rw-r--r-- | src/main/java/com/it_jaros/jscanner/Scan.java | 10 |
1 files changed, 2 insertions, 8 deletions
diff --git a/src/main/java/com/it_jaros/jscanner/Scan.java b/src/main/java/com/it_jaros/jscanner/Scan.java index 6800c5a..3db803f 100644 --- a/src/main/java/com/it_jaros/jscanner/Scan.java +++ b/src/main/java/com/it_jaros/jscanner/Scan.java @@ -111,11 +111,13 @@ public class Scan { public void portStart() { this.portCounter.inc(); this.threadCounter.inc(); + this.socketCounter.inc(); } public void portFinish() { this.portCounter.dec(); this.threadCounter.dec(); + this.socketCounter.dec(); } public void hostStart() { @@ -128,14 +130,6 @@ public class Scan { this.hostCounter.dec(); } - public void socketStart() { - this.socketCounter.inc(); - } - - public void socketFinish() { - this.socketCounter.dec(); - } - public void producerStart() { this.threadCounter.inc(); } |
