diff options
Diffstat (limited to 'client/go/internal/vespa/document/throttler.go')
| -rw-r--r-- | client/go/internal/vespa/document/throttler.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/client/go/internal/vespa/document/throttler.go b/client/go/internal/vespa/document/throttler.go index 3eb0ccd17f6..e7031e9892d 100644 --- a/client/go/internal/vespa/document/throttler.go +++ b/client/go/internal/vespa/document/throttler.go @@ -59,7 +59,7 @@ func NewThrottler(connections int) Throttler { return newThrottler(connections, func (t *dynamicThrottler) Sent() { currentInflight := t.TargetInflight() t.sent++ - if t.sent*t.sent*t.sent < 100*currentInflight*currentInflight { + if t.sent*t.sent*t.sent < 1000*currentInflight*currentInflight { return } t.sent = 0 @@ -94,7 +94,7 @@ func (t *dynamicThrottler) Sent() { if j != -1 { u := t.throughputs[j] if k != -1 { - t.throughputs[j] = (2*u + t.throughputs[i] + s) / 4 + t.throughputs[j] = (18*u + t.throughputs[i] + s) / 20 } s = u } |