Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 2 of 2 for NewDRWMutex (0.04 seconds)

  1. internal/dsync/dsync_test.go

    }
    
    // Test three locks for same resource, one succeeds, one fails (after timeout)
    func TestThreeSimultaneousLocksForSameResource(t *testing.T) {
    	dm1st := NewDRWMutex(ds, "aap")
    	dm2nd := NewDRWMutex(ds, "aap")
    	dm3rd := NewDRWMutex(ds, "aap")
    
    	dm1st.Lock(id, source)
    	started := time.Now()
    	var expect time.Duration
    	// Release lock after 10 seconds
    	go func() {
    		// TOTAL
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  2. internal/dsync/drwmutex.go

    }
    
    func (g *Granted) isLocked() bool {
    	return isLocked(g.lockUID)
    }
    
    func isLocked(uid string) bool {
    	return len(uid) > 0
    }
    
    // NewDRWMutex - initializes a new dsync RW mutex.
    func NewDRWMutex(clnt *Dsync, names ...string) *DRWMutex {
    	restClnts, _ := clnt.GetLockers()
    	sort.Strings(names)
    	return &DRWMutex{
    		writeLocks:           make([]string, len(restClnts)),
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 20.3K bytes
    - Click Count (0)
Back to Top