}
client.AuthToken = token
client.Timeout = time.Minute
+ client.Logger = c.logger
// A non-empty origin header tells controller to
// prioritize our traffic as interactive, which is
// true most of the time.
if err != nil {
return nil, err
}
+ kc := keepclient.New(arvadosclient)
+ kc.DiskCacheSize = c.cluster.Collections.WebDAVCache.DiskCacheSize
sess = &cachedSession{
cache: c,
client: client,
arvadosclient: arvadosclient,
- keepclient: keepclient.New(arvadosclient),
+ keepclient: kc,
}
c.sessions[token] = sess
}
// using the new fs).
sess.inuse.Lock()
if !sess.userLoaded || refresh {
- err := sess.client.RequestAndDecode(&sess.user, "GET", "/arvados/v1/users/current", nil, nil)
+ err := sess.client.RequestAndDecode(&sess.user, "GET", "arvados/v1/users/current", nil, nil)
if he := errorWithHTTPStatus(nil); errors.As(err, &he) && he.HTTPStatus() == http.StatusForbidden {
// token is OK, but "get user id" api is out
// of scope -- use existing/expired info if
// Mark more sessions for deletion until reaching desired
// memory size limit, starting with the oldest entries.
for i, snap := range snaps {
- if size <= c.cluster.Collections.WebDAVCache.MaxCollectionBytes {
+ if size <= int64(c.cluster.Collections.WebDAVCache.MaxCollectionBytes) {
break
}
if snap.prune {