- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 281 for unblock (2.35 sec)
-
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 }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 37.7K bytes - Viewed (0) -
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.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Oct 24 04:05:31 UTC 2025 - 4.9K bytes - Viewed (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
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 13.5K bytes - Viewed (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)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 99.7K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/concurrent/BuildPlanExecutor.java
lock.writeLock().lock(); try { plan(); } finally { lock.writeLock().unlock(); } } executePlan(); } catch (Exception e) { step.status.compareAndSet(SCHEDULED, FAILED);
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Thu Oct 16 06:12:36 UTC 2025 - 55.1K bytes - Viewed (0) -
cmd/object_api_suite_test.go
globalCompressConfig.Enabled = true globalCompressConfig.MimeTypes = mimeTypes globalCompressConfig.Extensions = extensions globalCompressConfig.AllowEncrypted = encrypt globalCompressConfigMu.Unlock() if encrypt { globalAutoEncryption = encrypt KMS, err := kms.ParseSecretKey("my-minio-key:5lF+0pJM0OWwlQrvK2S/I7W9mO4a6rJJI7wzj7v09cw=") if err != nil { t.Fatal(err) } GlobalKMS = KMS }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 34.5K bytes - Viewed (0) -
cmd/erasure-common.go
// // - Do not consume disks which are being healed // // - Future: skip busy disks return } mu.Lock() newDisks = append(newDisks, disks[i]) mu.Unlock() }() } wg.Wait() return newDisks } func (er erasureObjects) getOnlineLocalDisks() (newDisks []StorageAPI) { disks := er.getOnlineDisks()
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 2.3K bytes - Viewed (0) -
android/guava/src/com/google/common/io/Closer.java
* <li>If a {@code Throwable} is thrown in the try block, no exceptions that occur when attempting * to close resources will be thrown from the finally block. The throwable from the try block * will be thrown. * <li>If no exceptions or errors were thrown in the try block, the <i>first</i> exception thrown * by an attempt to close a resource will be thrown.
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 10.3K bytes - Viewed (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/model/ClassExtensionDoc.groovy
Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Wed Dec 09 08:14:05 UTC 2020 - 2.5K bytes - Viewed (0) -
KEYS.md
To do this, run the following command: ```bash gpg --sign-key 1BD97A6A154E7810EE0BC832E2F38302C8075E3D ``` ## Public Key Block in ascii-armored format ``` -----BEGIN PGP PUBLIC KEY BLOCK----- mQINBGOtCzoBEAC7hGOPLFnfvQKzCZpJb3QYq8X9OiUL4tVa5mG0lDTeBBiuQCDy Iyhpo8IypllGG6Wxj6ZJbhuHXcnXSu/atmtrnnjARMvDnQ20jX77B+g39ZYuqxgw
Registered: Wed Dec 31 11:36:14 UTC 2025 - Last Modified: Thu Dec 04 14:29:13 UTC 2025 - 4.7K bytes - Viewed (0)