- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for lockIsHeld (0.1 sec)
-
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceProjectLockTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 25.6K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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)