daffainfo
/
nuclei
mirror of https://github.com/daffainfo/nuclei.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

speed up

dev
mzack 2024-04-04 21:21:06 +02:00
parent c4aa7dc1a2
commit aa06c9ef17
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
examples/with_speed_control/main.go
View File

@ -43,10 +43,10 @@ func main() {
panic("wrong initial rate limit") panic("wrong initial rate limit")
} }
time.Sleep(10 * time.Second) time.Sleep(10 * time.Second)
ne.Options().RateLimit = 5 ne.Options().RateLimit = 1000
time.Sleep(10 * time.Second) time.Sleep(10 * time.Second)
finalRate := ne.GetExecuterOptions().RateLimiter.GetLimit() finalRate := ne.GetExecuterOptions().RateLimiter.GetLimit()
if finalRate != 5 { if finalRate != 1000 {
panic("wrong final rate limit") panic("wrong final rate limit")
} }
}() }()
@ -81,13 +81,13 @@ func main() {
panic("wrong initial payload concurrency") panic("wrong initial payload concurrency")
} }
time.Sleep(10 * time.Second) time.Sleep(10 * time.Second)
ne.Options().PayloadConcurrency = 5 ne.Options().PayloadConcurrency = 100
time.Sleep(10 * time.Second) time.Sleep(10 * time.Second)
// the ongoing and next payload iterations will retrieve parallelism from this function // the ongoing and next payload iterations will retrieve parallelism from this function
// it should have the new set value, that will be cascade applied to all running adaptive wait groups // it should have the new set value, that will be cascade applied to all running adaptive wait groups
finalPayloadConcurrency := ne.GetExecuterOptions().GetThreadsForNPayloadRequests(100, 0) finalPayloadConcurrency := ne.GetExecuterOptions().GetThreadsForNPayloadRequests(100, 0)
if finalPayloadConcurrency != 5 { if finalPayloadConcurrency != 100 {
panic("wrong initial payload concurrency") panic("wrong initial payload concurrency")
} }
}() }()