- Sort Score
- Num 10 results
- Language All
Results 1 - 1 of 1 for NewDRWMutex (0.04 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/dsync/drwmutex_test.go
func testSimpleWriteLock(t *testing.T, duration time.Duration) (locked bool) { drwm1 := NewDRWMutex(ds, "simplelock") ctx1, cancel1 := context.WithCancel(t.Context()) if !drwm1.GetRLock(ctx1, cancel1, id, source, Options{Timeout: time.Second}) { panic("Failed to acquire read lock") } // fmt.Println("1st read lock acquired, waiting...") drwm2 := NewDRWMutex(ds, "simplelock") ctx2, cancel2 := context.WithCancel(t.Context())
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 9.4K bytes - Click Count (0)