- Sort Score
- Num 10 results
- Language All
Results 151 - 160 of 301 for unblock (0.22 seconds)
-
cmd/erasure-object-conditional_test.go
z.serverPools[0].erasureDisksMu.Lock() xl.getDisks = func() []StorageAPI { for i := range erasureDisks[:8] { erasureDisks[i] = nil } return erasureDisks } z.serverPools[0].erasureDisksMu.Unlock() t.Run("if-none-match with read quorum failure", func(t *testing.T) { // Test Case 1: if-none-match (create only if doesn't exist) // With if-none-match: *, this should only succeed if object doesn't exist.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 4.9K bytes - Click Count (0) -
cmd/metrics-v3-types.go
ch <- metric } } // LockAndSetBuckets - locks the buckets and sets the given buckets. It returns // a function to unlock the buckets. func (mg *MetricsGroup) LockAndSetBuckets(buckets []string) func() { mg.bucketsLock.Lock() mg.buckets = buckets return func() { mg.bucketsLock.Unlock() } } // MetricFQN - returns the fully qualified name for the given metric name.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Feb 28 19:33:08 GMT 2025 - 15.6K bytes - Click Count (0) -
internal/config/subnet/subnet.go
return c.submitPost(r) } func (c Config) submitPost(r *http.Request) (string, error) { configLock.RLock() r.Header.Set(xhttp.SubnetAPIKey, c.APIKey) configLock.RUnlock() r.Header.Set(xhttp.MinioDeploymentID, xhttp.GlobalDeploymentID) client := &http.Client{ Timeout: 10 * time.Second, Transport: c.transport, } resp, err := client.Do(r) if err != nil {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 2.9K bytes - Click Count (0) -
cmd/consolelogger.go
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.4K bytes - Click Count (0) -
cmd/erasure-healing.go
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 34.7K bytes - Click Count (0) -
cmd/iam.go
bootstrapTraceMsg("IAM initialization started") globalServerConfigMu.RLock() s := globalServerConfig globalServerConfigMu.RUnlock() sys.Lock() sys.iamRefreshInterval = iamRefreshInterval sys.Unlock() r := rand.New(rand.NewSource(time.Now().UnixNano())) var ( openidInit bool ldapInit bool authNInit bool authZInit bool )
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Wed Oct 15 17:00:45 GMT 2025 - 76.5K bytes - Click Count (0) -
internal/config/config.go
siteLK.Lock() s.name = n.name s.region = n.region siteLK.Unlock() } // Name returns currently configured site name func (s *Site) Name() string { siteLK.RLock() defer siteLK.RUnlock() return s.name } // Region returns currently configured site region func (s *Site) Region() string { siteLK.RLock() defer siteLK.RUnlock() return s.region }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 37.7K bytes - Click Count (0) -
cmd/bucket-stats.go
qs.TgtXferStats = make(map[string]map[RMetricName]XferStats) qs.MRFStats = ReplicationMRFStats{ LastFailedCount: atomic.LoadUint64(&r.mrfStats.LastFailedCount), } r.RLock() defer r.RUnlock() brs, ok := r.Cache[bucket] if !ok { return qs } for arn := range brs.Stats { qs.TgtXferStats[arn] = make(map[RMetricName]XferStats) } count := 0 var totPeak float64
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 13.5K bytes - Click Count (0) -
cmd/admin-handlers.go
return } nsLock := objectAPI.NewNSLock(minioMetaBucket, "site-net-perf") lkctx, err := nsLock.GetLock(ctx, globalOperationTimeout) if err != nil { writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(toAPIErrorCode(ctx, err)), r.URL) return } ctx = lkctx.Context() defer nsLock.Unlock(lkctx) durationStr := r.Form.Get(peerRESTDuration)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 99.7K bytes - Click Count (0) -
cmd/metrics-v3-cache.go
v.ioStats[d] = getDriveIOStatMetrics(getDiffStats(ps, cs), duration) } } } } prevDriveIOStats = currentStats prevDriveIOStatsRefreshedAt = now prevDriveIOStatsMu.Unlock() return v, err } return cachevalue.NewFromFunc(1*time.Minute, cachevalue.Opts{ReturnLastGood: true}, loadDriveMetrics) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 8.1K bytes - Click Count (0)