mirror of
https://github.com/buger/goreplay.git
synced 2024-04-21 12:32:02 +00:00
More verbose S3 logging
This commit is contained in:
+4
-1
@@ -79,11 +79,14 @@ type HTTPOutputConfig struct {
|
||||
|
||||
CompatibilityMode bool
|
||||
|
||||
RequestGroup string
|
||||
|
||||
Debug bool
|
||||
|
||||
TrackResponses bool
|
||||
}
|
||||
|
||||
|
||||
// HTTPOutput plugin manage pool of workers which send request to replayed server
|
||||
// By default workers pool is dynamic and starts with 10 workers
|
||||
// You can specify fixed number of workers using `--output-http-workers`
|
||||
@@ -180,7 +183,7 @@ func (o *HTTPOutput) sessionWorkerMaster() {
|
||||
now := time.Now()
|
||||
|
||||
for id, w := range o.workerSessions {
|
||||
if !w.lastActivity.IsZero() && now.Sub(w.lastActivity) >= 60*time.Second {
|
||||
if !w.lastActivity.IsZero() && now.Sub(w.lastActivity) >= 120*time.Second {
|
||||
w.stop <- true
|
||||
delete(o.workerSessions, id)
|
||||
atomic.AddInt64(&o.activeWorkers, -1)
|
||||
|
||||
Reference in New Issue
Block a user