- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for rl (0.04 sec)
-
internal/lsync/lrwmutex_test.go
func TestDRLocker(t *testing.T) { wl := NewLRWMutex() var rl sync.Locker wlocked := make(chan bool, 1) rlocked := make(chan bool, 1) rl = wl.DRLocker() n := 10 go func() { for range n { rl.Lock() rl.Lock() rlocked <- true wl.Lock() wlocked <- true } }() for range n { <-rlocked rl.Unlock() select { case <-wlocked:
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 7.8K bytes - Viewed (0) -
cmd/bucket-lifecycle-handlers.go
writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } for _, rl := range lcCfg.Rules { updRule, ok := updatedRules[rl.ID] // original rule had expiry that is no longer in the new config, // or rule is present but missing expiration flags if (!rl.Expiration.IsNull() || !rl.NoncurrentVersionExpiration.IsNull()) &&
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Jan 20 14:49:07 UTC 2025 - 7K bytes - Viewed (0)