[arvados] updated: 2.7.0-5502-gb11dab64f5
git repository hosting
git at public.arvados.org
Mon Dec 4 23:12:29 UTC 2023
Summary of changes:
sdk/go/arvados/limiter.go | 7 +++++++
1 file changed, 7 insertions(+)
via b11dab64f5cd5273247a1ae4c959c25168452a6a (commit)
from 504d5fea43c831adb924da5df84825c4e2fabb45 (commit)
Those revisions listed above that are new to this repository have
not appeared on any other notification email; so we list those
revisions in full, below.
commit b11dab64f5cd5273247a1ae4c959c25168452a6a
Author: Tom Clegg <tom at curii.com>
Date: Mon Dec 4 18:11:47 2023 -0500
21227: Don't reduce outgoing request concurrency below 4.
Arvados-DCO-1.1-Signed-off-by: Tom Clegg <tom at curii.com>
diff --git a/sdk/go/arvados/limiter.go b/sdk/go/arvados/limiter.go
index dc944160ab..9edc5386a7 100644
--- a/sdk/go/arvados/limiter.go
+++ b/sdk/go/arvados/limiter.go
@@ -16,6 +16,7 @@ import (
var (
requestLimiterQuietPeriod = time.Second
requestLimiterInitialLimit int64 = 8
+ requestLimiterMinimumLimit int64 = 4
)
type requestLimiter struct {
@@ -145,6 +146,12 @@ func (rl *requestLimiter) Report(resp *http.Response, err error) bool {
if max := rl.current * 2; max < rl.limit {
rl.limit = max
}
+ if min := requestLimiterMinimumLimit; min > rl.limit {
+ // If limit is too low, programs like
+ // controller and test suites can end up with
+ // too few slots to complete a single request.
+ rl.limit = min
+ }
if rl.maxlimit > 0 && rl.maxlimit < rl.limit {
rl.limit = rl.maxlimit
}
-----------------------------------------------------------------------
hooks/post-receive
--
More information about the arvados-commits
mailing list