Scheme: conn.baseURL.Scheme,
APIHost: conn.baseURL.Host,
SendHeader: conn.SendHeader,
- Timeout: 0, // disable auto-retry
+ // Disable auto-retry
+ Timeout: 0,
}
tokens, err := conn.tokenProvider(ctx)
if err != nil {
func (diag *diagnoser) runtests() {
client := arvados.NewClientFromEnv()
- client.Timeout = 0 // disable auto-retry, use context instead
+ // Disable auto-retry, use context instead
+ client.Timeout = 0
if client.APIHost == "" || client.AuthToken == "" {
diag.errorf("ARVADOS_API_HOST and ARVADOS_API_TOKEN environment variables are not set -- aborting without running any tests")
arvClient, err := arvados.NewClientFromConfig(s.cluster)
c.Assert(err, check.IsNil)
- arvClient.Timeout = 0 // disable auto-retry
+ // Disable auto-retry
+ arvClient.Timeout = 0
s.error503Server = httptest.NewTLSServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) { w.WriteHeader(http.StatusServiceUnavailable) }))
arvClient.Client = &http.Client{
func (s *permSuite) TestCheck(c *check.C) {
client := arvados.NewClientFromEnv()
- client.Timeout = 0 // disable auto-retry
+ // Disable auto-retry
+ client.Timeout = 0
+
pc := newPermChecker(*client).(*cachingPermChecker)
setToken := func(label, token string) {
c.Logf("...%s token %q", label, token)