Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for cancelFunc (0.05 sec)

  1. cmd/xl-storage-disk-id-check.go

    	diskID       atomic.Pointer[string]
    	storage      *xlStorage
    	health       *diskHealthTracker
    	healthCheck  bool
    
    	metricsCache *cachevalue.Cache[DiskMetrics]
    	diskCtx      context.Context
    	diskCancel   context.CancelFunc
    }
    
    func (p *xlStorageDiskIDCheck) getMetrics() DiskMetrics {
    	p.metricsCache.InitOnce(5*time.Second,
    		cachevalue.Opts{},
    		func(ctx context.Context) (DiskMetrics, error) {
    			diskMetric := DiskMetrics{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  2. cmd/metacache-set.go

    				}
    			}
    		},
    	})
    }
    
    //msgp:ignore metaCacheRPC
    type metaCacheRPC struct {
    	o      listPathOptions
    	mu     sync.Mutex
    	meta   *metacache
    	rpc    *peerRESTClient
    	cancel context.CancelFunc
    }
    
    func (m *metaCacheRPC) setErr(err string) {
    	m.mu.Lock()
    	defer m.mu.Unlock()
    	meta := *m.meta
    	if meta.status != scanStateError {
    		meta.error = err
    		meta.status = scanStateError
    	} else {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 30.7K bytes
    - Viewed (0)
  3. cmd/bucket-replication.go

    			ReplicationARN: tgt.ARN,
    		},
    		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 Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 118.2K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    type TestServer struct {
    	Root         string
    	Disks        EndpointServerPools
    	AccessKey    string
    	SecretKey    string
    	Server       *httptest.Server
    	Obj          ObjectLayer
    	cancel       context.CancelFunc
    	rawDiskPaths []string
    }
    
    // UnstartedTestServer - Configures a temp FS/Erasure backend,
    // initializes the endpoints and configures the test server.
    // The server should be started using the Start() method.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  5. cmd/xl-storage.go

    	sync.RWMutex
    	formatData []byte
    
    	nrRequests   uint64
    	major, minor uint32
    	fsType       string
    
    	immediatePurge       chan string
    	immediatePurgeCancel context.CancelFunc
    
    	// mutex to prevent concurrent read operations overloading walks.
    	rotational bool
    	walkMu     *sync.Mutex
    	walkReadMu *sync.Mutex
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 91.7K bytes
    - Viewed (0)
  6. api/go1.16.txt

    pkg os, type FileMode = fs.FileMode
    pkg os, type PathError = fs.PathError
    pkg os, var ErrProcessDone error
    pkg os/signal, func NotifyContext(context.Context, ...os.Signal) (context.Context, context.CancelFunc)
    pkg path/filepath, func WalkDir(string, fs.WalkDirFunc) error
    pkg runtime/metrics, const KindBad = 0
    pkg runtime/metrics, const KindBad ValueKind
    pkg runtime/metrics, const KindFloat64 = 2
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Fri Dec 02 16:30:41 UTC 2022
    - 479.2K bytes
    - Viewed (0)
Back to top