- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for Erling (0.23 sec)
-
internal/dsync/drwmutex.go
lockFound := false for _, uid := range dm.writeLocks { if isLocked(uid) { lockFound = true break } } if !lockFound { panic("Trying to Unlock() while no Lock() is active") } // Copy write locks to stack array copy(locks, dm.writeLocks) } // Tolerance is not set, defaults to half of the locker clients.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
cmd/batch-handlers.go
attempts := 1 for attempts <= 3 { aerr := api.AbortMultipartUpload(ctx, tgtBucket, tgtObject, res.UploadID, ObjectOptions{}) if aerr == nil { return } batchLogIf(ctx, fmt.Errorf("trying %s: Unable to cleanup failed multipart replication %s on remote %s/%s: %w - this may consume space on remote cluster", humanize.Ordinal(attempts), res.UploadID, tgtBucket, tgtObject, aerr)) attempts++
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 08 14:11:38 GMT 2024 - 55.2K bytes - Viewed (0) -
internal/lsync/lrwmutex_test.go
// fmt.Println("1st read lock released, waiting...") }() go func() { time.Sleep(3 * time.Second) lrwm.RUnlock() // fmt.Println("2nd read lock released, waiting...") }() // fmt.Println("Trying to acquire write lock, waiting...") locked = lrwm.GetLock(ctx, "", "", duration) if locked { // fmt.Println("Write lock acquired, waiting...") time.Sleep(1 * time.Second) lrwm.Unlock() } else {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 7.9K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
go func() { time.Sleep(3 * testDrwMutexAcquireTimeout) drwm2.RUnlock(context.Background()) // fmt.Println("2nd read lock released, waiting...") }() drwm3 := NewDRWMutex(ds, "simplelock") // fmt.Println("Trying to acquire write lock, waiting...") ctx3, cancel3 := context.WithCancel(context.Background()) locked = drwm3.GetLock(ctx3, cancel3, id, source, Options{Timeout: duration}) if locked {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 9.7K bytes - Viewed (0) -
internal/logger/logonce.go
uerr = errors.Unwrap(leafErr) depth++ if depth == unwrapErrsDepth { // If we have reached enough depth we // do not further recurse down, this // is done to avoid any unnecessary // latencies this might bring. break } } if uerr == nil { leafErr = err } return leafErr } // One log message per error.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 3.8K bytes - Viewed (0) -
docs/metrics/prometheus/alerts.md
``` ## Verify the configuration and alerts To verify the above sample alert follow below steps 1. Start a distributed MinIO instance (4 nodes setup) 2. Start Prometheus server and AlertManager 3. Bring down couple of MinIO instances to bring down the Erasure Set tolerance to -1 and verify the same with `mc admin prometheus metrics ALIAS | grep minio_cluster_health_erasure_set_status`
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 28 20:53:59 GMT 2024 - 4.4K bytes - Viewed (0) -
cmd/prepare-storage.go
// is invalid. This function returns success for the // most part unless one of the formats is not consistent // with expected Erasure format. For example if a user is // trying to pool FS backend into an Erasure set. if err = checkFormatErasureValues(formatConfigs, storageDisks, setDriveCount); err != nil { return nil, nil, err }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0) -
cmd/data-scanner.go
// This may be because of 2 reasons: // // 1) The folder/object was deleted. // 2) We come from another disk and this disk missed the write. // // We therefore perform a heal check. // If that doesn't bring it back we remove the folder and assume it was deleted. // This means that the next run will not look for it. // How to resolve results. resolver := metadataResolutionParams{ dirQuorum: f.disksQuorum,
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Apr 15 09:40:19 GMT 2024 - 46.9K bytes - Viewed (0) -
CREDITS
place of business and such litigation shall be governed by laws of that jurisdiction, without reference to its conflict-of-law provisions. Nothing in this Section shall prevent a party's ability to bring cross-claims or counter-claims. 9. Miscellaneous ---------------- This License represents the complete agreement concerning the subject matter hereof. If any provision of this License is held to be
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Apr 16 18:48:56 GMT 2024 - 1.6M bytes - Viewed (0) -
internal/lsync/lrwmutex.go
success := lm.unlock(isWriteLock) if !success { panic("Trying to Unlock() while no Lock() is active") } } // RUnlock releases a read lock held on lm. // // It is a run-time error if lm is not locked on entry to RUnlock. func (lm *LRWMutex) RUnlock() { isWriteLock := false success := lm.unlock(isWriteLock) if !success { panic("Trying to RUnlock() while no RLock() is active") } }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Jan 02 17:15:06 GMT 2022 - 4.8K bytes - Viewed (0)