- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for WithTimeout (0.06 sec)
-
cmd/admin-handlers.go
if pools { ctx2, cancel := context.WithTimeout(ctx, operationTimeout) poolsInfo, _ = getPoolsInfo(ctx2, allDisks) cancel() } } domain := globalDomainNames services := madmin.Services{ LDAP: ldap, Logger: log, Audit: audit, Notifications: notifyTarget, } { ctx2, cancel := context.WithTimeout(ctx, operationTimeout)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 99.7K bytes - Viewed (0) -
cmd/bucket-replication.go
}, HeaderSize: headerSize, } newCtx := ctx if globalBucketMonitor.IsThrottled(bucket, tgt.ARN) && objInfo.Size < minLargeObjSize { var cancel context.CancelFunc newCtx, cancel = context.WithTimeout(ctx, throttleDeadline) defer cancel() } r := bandwidth.NewMonitoredReader(newCtx, globalBucketMonitor, gr, opts) if objInfo.isMultipart() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 06:49:55 UTC 2024 - 116.1K bytes - Viewed (0) -
cmd/site-replication.go
results.NodeResults = append(results.NodeResults, result) resultsMu.Unlock() return }() continue } wg.Add(1) go func() { defer wg.Done() ctx, cancel := context.WithTimeout(ctx, duration+10*time.Second) defer cancel() result := perfNetRequest( ctx, info.DeploymentID, adminPathPrefix+adminAPIVersionPrefix+adminAPISiteReplicationNetPerf, nil, )
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 185.1K bytes - Viewed (0)