Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for Cancel (0.04 seconds)

  1. cmd/sts-handlers_test.go

    				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)
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 103.4K bytes
    - Click Count (1)
  2. cmd/admin-handlers.go

    	}
    
    	// Start profiling on remote servers.
    	for _, profiler := range profiles {
    		// Limit start time to max 10s.
    		ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
    		globalNotificationSys.StartProfiling(ctx, profiler)
    		// StartProfiling blocks, so we can cancel now.
    		cancel()
    
    		// Start profiling locally as well.
    		prof, err := startProfiler(profiler)
    		if err == nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (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 {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  4. cmd/server_test.go

    }
    
    func (s *TestSuiteCommon) RestartTestServer(c *check) {
    	// Shutdown.
    	s.testServer.cancel()
    	s.testServer.Server.Close()
    	s.testServer.Obj.Shutdown(context.Background())
    
    	// Restart.
    	ctx, cancel := context.WithCancel(context.Background())
    
    	s.testServer.cancel = cancel
    	s.testServer = initTestServerWithBackend(ctx, c, s.testServer, s.testServer.Obj, s.testServer.rawDiskPaths)
    	if s.secure {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 118.1K bytes
    - Click Count (0)
  5. 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,
    			)
    			resultsMu.Lock()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
Back to Top