Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 6 of 6 for lockMap (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 3K bytes
    - Click Count (0)
  2. cmd/namespace-lock.go

    	defer n.lockMapMutex.Unlock()
    	if _, found := n.lockMap[resource]; !found {
    		return
    	}
    	if readLock {
    		n.lockMap[resource].RUnlock()
    	} else {
    		n.lockMap[resource].Unlock()
    	}
    	n.lockMap[resource].ref--
    	if n.lockMap[resource].ref < 0 {
    		logger.CriticalIf(GlobalContext, errors.New("resource reference count was lower than 0"))
    	}
    	if n.lockMap[resource].ref == 0 {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  3. cmd/peer-rest-client.go

    func (client *peerRESTClient) Close() error {
    	client.restClient.Close()
    	return nil
    }
    
    // GetLocks - fetch older locks for a remote node.
    func (client *peerRESTClient) GetLocks(ctx context.Context) (lockMap map[string][]lockRequesterInfo, err error) {
    	resp, err := getLocksRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	if err != nil || resp == nil {
    		return nil, err
    	}
    	return *resp, nil
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        checkMessage(expected, "LockC -> LockA", "LockB -> LockC", "LockA -> LockB");
      }
    
      public void testReentrancy_noDeadlock() {
        lockA.lock();
        lockB.lock();
        lockA.lock(); // Should not assert on lockB -> reentrant(lockA)
      }
    
      public void testExplicitOrdering_noViolations() {
        lock1.lock();
        lock3.lock();
        lock3.unlock();
        lock2.lock();
        lock3.lock();
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  5. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        checkMessage(expected, "LockC -> LockA", "LockB -> LockC", "LockA -> LockB");
      }
    
      public void testReentrancy_noDeadlock() {
        lockA.lock();
        lockB.lock();
        lockA.lock(); // Should not assert on lockB -> reentrant(lockA)
      }
    
      public void testExplicitOrdering_noViolations() {
        lock1.lock();
        lock3.lock();
        lock3.unlock();
        lock2.lock();
        lock3.lock();
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 16.3K bytes
    - Click Count (0)
  6. 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)
     * ...
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 36K bytes
    - Click Count (0)
Back to Top