Update main.go
This commit is contained in:
parent
bafe56350b
commit
e435697aba
6
main.go
6
main.go
|
@ -878,8 +878,8 @@ func main() {
|
|||
}
|
||||
}()
|
||||
|
||||
timeoutTicker := time.NewTicker(time.Duration(config.TimeoutTickerInterval) * time.Second)
|
||||
rateLimitTicker := time.NewTicker(time.Duration(config.RateLimit[1]) * time.Second)
|
||||
timeoutTicker := time.NewTicker(time.Duration(config.TimeoutTickerInterval) * time.Millisecond)
|
||||
rateLimitTicker := time.NewTicker(time.Duration(config.RateLimit[1]) * time.Millisecond)
|
||||
done := make(chan bool)
|
||||
|
||||
go func() {
|
||||
|
@ -960,7 +960,7 @@ func main() {
|
|||
requests = config.RateLimit[0]
|
||||
}
|
||||
case t := <-timeoutTicker.C:
|
||||
if !startTime.IsZero() && t.After(startTime.Add(time.Duration(config.Timeout)*time.Second)) {
|
||||
if !startTime.IsZero() && t.After(startTime.Add(time.Duration(config.Timeout)*time.Millisecond)) {
|
||||
cmd := exec.Command(config.KillCommand[0], config.KillCommand[1:]...)
|
||||
cmd.Stdout = os.Stdout
|
||||
cmd.Stderr = os.Stderr
|
||||
|
|
Loading…
Reference in New Issue