Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for WithTimeout (0.04 sec)

  1. cmd/sts-handlers_test.go

    			func(t *testing.T) {
    				runAllIAMSTSTests(testCase, &check{t, testCase.serverType})
    			},
    		)
    	}
    }
    
    func (s *TestSuiteIAM) TestSTSServiceAccountsWithUsername(c *check) {
    	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    	defer cancel()
    
    	bucket := "dillon-bucket"
    	err := s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{})
    	if err != nil {
    		c.Fatalf("bucket create error: %v", err)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 100.2K bytes
    - Viewed (1)
  2. 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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  3. 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 isMP {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  4. cmd/site-replication.go

    				results.NodeResults = append(results.NodeResults, result)
    				resultsMu.Unlock()
    			}()
    			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 Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
Back to top