Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for lockIsHeld (0.1 sec)

  1. platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceProjectLockTest.groovy

            expect:
            !taskLease.is(projectLock)
            !lockIsHeld(taskLease)
            !lockIsHeld(projectLock)
            workerLeaseService.withLocks([taskLease]) {
                assert lockIsHeld(taskLease)
                assert lockIsHeld(projectLock)
            }
            !lockIsHeld(taskLease)
            !lockIsHeld(projectLock)
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 05 16:29:26 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  2. platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/SharedResourceLeaseRegistryTest.groovy

            coordinationService.withStateLock(lock(lockB))
    
            then:
            lockIsHeld(lockA)
            lockIsHeld(lockB)
    
            when:
            coordinationService.withStateLock(unlock(lockA))
            coordinationService.withStateLock(unlock(lockB))
    
            then:
            !lockIsHeld(lockA)
            !lockIsHeld(lockB)
        }
    
        def "multiple threads can hold leases from a shared resource"() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:48:02 UTC 2023
    - 5K bytes
    - Viewed (0)
  3. src/runtime/lockrank_on.go

    	systemstack(func() {
    		i := gp.m.locksHeldLen
    		if i >= len(gp.m.locksHeld) {
    			throw("too many locks held concurrently for rank checking")
    		}
    		gp.m.locksHeld[i].rank = rank
    		gp.m.locksHeld[i].lockAddr = uintptr(unsafe.Pointer(l))
    		gp.m.locksHeldLen++
    
    		// i is the index of the lock being acquired
    		if i > 0 {
    			checkRanks(gp, gp.m.locksHeld[i-1].rank, rank)
    		}
    		lock2(l)
    	})
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 22 14:29:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  4. internal/dsync/dsync-server_test.go

    		time.Sleep(time.Duration(d))
    	}
    
    	l.mutex.Lock()
    	defer l.mutex.Unlock()
    	var locksHeld int64
    	if locksHeld, reply = l.lockMap[args.Resources[0]]; !reply { // No lock is held on the given name
    		return false, fmt.Errorf("Unlock attempted on an unlocked entity: %s", args.Resources[0])
    	}
    	if reply = locksHeld == WriteLock; !reply { // Unless it is a write lock
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jan 23 16:46:37 UTC 2023
    - 8.3K bytes
    - Viewed (0)
  5. cmd/admin-handlers_test.go

    			UID:    mustGetUUID(),
    			Owner:  owners[i%len(owners)],
    			Quorum: 2,
    		}
    		lris = append(lris, lri)
    		locksHeld[resource] = append(locksHeld[resource], lri)
    		// concurrent read lock, same resource different uid
    		lri.UID = mustGetUUID()
    		lris = append(lris, lri)
    		locksHeld[resource] = append(locksHeld[resource], lri)
    	}
    
    	var peerLocks []*PeerLocks
    	for _, owner := range owners {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  6. src/runtime/runtime2.go

    	pcvalueCache pcvalueCache
    
    	dlogPerM
    
    	mOS
    
    	chacha8   chacha8rand.State
    	cheaprand uint64
    
    	// Up to 10 locks held by this m, maintained by the lock ranking code.
    	locksHeldLen int
    	locksHeld    [10]heldLockInfo
    }
    
    type p struct {
    	id          int32
    	status      uint32 // one of pidle/prunning/...
    	link        puintptr
    	schedtick   uint32     // incremented on every scheduler call
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 17:57:37 UTC 2024
    - 47.9K bytes
    - Viewed (0)
Back to top