Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for lockMap (0.06 sec)

  1. cmd/local-locker_test.go

    		if err != nil {
    			t.Fatal(err)
    		}
    		if !ok {
    			t.Fatal("did not get write lock")
    		}
    
    		rResources[i] = arg.Resources[0]
    	}
    	if len(l.lockMap) != len(rResources)+len(wResources) {
    		t.Fatalf("lockmap len, got %d, want %d + %d", len(l.lockMap), len(rResources), len(wResources))
    	}
    	if len(l.lockUID) != len(rResources)+len(wResources) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  2. cmd/local-locker.go

    		Quorum:          *args.Quorum,
    	}
    	lri, ok := l.lockMap[resource]
    	if ok {
    		if reply = !isWriteLock(lri); reply {
    			// Unless there is a write lock
    			l.lockMap[resource] = append(l.lockMap[resource], lrInfo)
    			l.lockUID[formatUUID(args.UID, 0)] = resource
    		}
    	} else {
    		// No locks held on the given name, so claim (first) read lock
    		l.lockMap[resource] = []lockRequesterInfo{lrInfo}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12K bytes
    - Viewed (0)
  3. cmd/lock-rest-server-common_test.go

    		Writer:          true,
    		UID:             "89ab-cdef",
    		Timestamp:       UTCNow().UnixNano(),
    		TimeLastRefresh: UTCNow().UnixNano(),
    	}
    
    	locker.ll.lockMap["name"] = []lockRequesterInfo{
    		lockRequesterInfo1,
    		lockRequesterInfo2,
    	}
    
    	lri := locker.ll.lockMap["name"]
    
    	// test unknown uid
    	if locker.ll.removeEntry("name", dsync.LockArgs{
    		Owner: "owner",
    		UID:   "unknown-uid",
    	}, &lri) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  4. cmd/namespace-lock_test.go

    		//    successfully acquiring the lock.
    		// 2) lk2 then needs to advance and remove the resource from lockMap.
    		// 3) lk3 or lk4 (whichever didn't execute in step 1) then executes and creates
    		//    a new entry in lockMap and acquires a lock for the same resource.
    
    		<-lk2ch
    		lk3ok := <-lk3ch
    		lk4ok := <-lk4ch
    
    		if lk3ok && lk4ok {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

     *
     * <pre>
     * Thread1: acquire(LockA) --X acquire(LockB)
     * Thread2: acquire(LockB) --X acquire(LockA)
     * </pre>
     *
     * <p>Neither thread will progress because each is waiting for the other. In more complex
     * applications, cycles can arise from interactions among more than 2 locks:
     *
     * <pre>
     * Thread1: acquire(LockA) --X acquire(LockB)
     * Thread2: acquire(LockB) --X acquire(LockC)
     * ...
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 18 15:05:43 UTC 2025
    - 35.9K bytes
    - Viewed (0)
Back to top