projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
20602: Add IneligibleForQueuePriority const.
[arvados.git]
/
sdk
/
go
/
httpserver
/
request_limiter_test.go
diff --git
a/sdk/go/httpserver/request_limiter_test.go
b/sdk/go/httpserver/request_limiter_test.go
index fd09c9305afd556ec170186fed3aff2bf7db27da..b04ff57cc176fca18d58773565cee1a55f3a5357 100644
(file)
--- a/
sdk/go/httpserver/request_limiter_test.go
+++ b/
sdk/go/httpserver/request_limiter_test.go
@@
-6,7
+6,6
@@
package httpserver
import (
"fmt"
import (
"fmt"
- "math"
"net/http"
"net/http/httptest"
"strconv"
"net/http"
"net/http/httptest"
"strconv"
@@
-135,14
+134,14
@@
func (*Suite) TestRequestLimiterQueuePriority(c *check.C) {
<-h.inHandler
}
<-h.inHandler
}
- c.Logf("starting %d priority=
MinInt64
requests (should respond 503 immediately)", rl.MaxQueue)
+ c.Logf("starting %d priority=
IneligibleForQueuePriority
requests (should respond 503 immediately)", rl.MaxQueue)
var wgX sync.WaitGroup
for i := 0; i < rl.MaxQueue; i++ {
wgX.Add(1)
go func() {
defer wgX.Done()
resp := httptest.NewRecorder()
var wgX sync.WaitGroup
for i := 0; i < rl.MaxQueue; i++ {
wgX.Add(1)
go func() {
defer wgX.Done()
resp := httptest.NewRecorder()
- rl.ServeHTTP(resp, &http.Request{Header: http.Header{"Priority": {fmt.Sprintf("%d",
math.MinInt64
)}}})
+ rl.ServeHTTP(resp, &http.Request{Header: http.Header{"Priority": {fmt.Sprintf("%d",
IneligibleForQueuePriority
)}}})
c.Check(resp.Code, check.Equals, http.StatusServiceUnavailable)
}()
}
c.Check(resp.Code, check.Equals, http.StatusServiceUnavailable)
}()
}