- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,340 for held (0.05 sec)
-
src/runtime/lockrank_on.go
println("<none>") return } for j, held := range gp.m.locksHeld[:gp.m.locksHeldLen] { println(j, ":", held.rank.String(), held.rank, unsafe.Pointer(gp.m.locksHeld[j].lockAddr)) } } // acquireLockRankAndM acquires a rank which is not associated with a mutex // lock. To maintain the invariant that an M with m.locks==0 does not hold any // lock-like resources, it also acquires the M. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:29:04 UTC 2024 - 10.6K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceProjectLockTest.groovy
boolean lockIsHeld(final ResourceLock resourceLock) { MutableBoolean held = new MutableBoolean() coordinationService.withStateLock(new InternalTransformer<ResourceLockState.Disposition, ResourceLockState>() { @Override ResourceLockState.Disposition transform(ResourceLockState resourceLockState) { held.set(resourceLock.locked && resourceLock.isLockedByCurrentThread())
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 25.6K bytes - Viewed (0) -
cmd/local-locker.go
defer l.mutex.Unlock() var lri []lockRequesterInfo resource := args.Resources[0] if lri, reply = l.lockMap[resource]; !reply { // No lock is held on the given name return true, nil } if isWriteLock(lri) { // A write-lock is held, cannot release a read lock return false, fmt.Errorf("RUnlock attempted on a write locked entity: %s", resource) } l.removeEntry(resource, args, &lri)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 10.6K bytes - Viewed (0) -
src/runtime/mpagealloc.go
// // Returns a 0 base address on failure, in which case other returned values // should be ignored. // // p.mheapLock must be held. // // Must run on the system stack because p.mheapLock must be held. // //go:systemstack func (p *pageAlloc) alloc(npages uintptr) (addr uintptr, scav uintptr) { assertLockHeld(p.mheapLock)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 39.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
// A lock for writing is needed // for writing to any of the following: // - the flowSchemas field // - the slice held in the flowSchemas field // - the priorityLevelStates field // - the map held in the priorityLevelStates field // - any field of a priorityLevelState held in that map lock sync.RWMutex // flowSchemas holds the flow schema objects, sorted by increasing
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
override fun clone(): Call = RealCall(client, originalRequest, forWebSocket) override fun request(): Request = originalRequest /** * Immediately closes the socket connection if it's currently held. Use this to interrupt an * in-flight request from any thread. It's the caller's responsibility to close the request body * and response body streams; otherwise resources may be leaked. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
src/sync/map.go
// concurrent access (with or without mu held). // // The read field itself is always safe to load, but must only be stored with // mu held. // // Entries stored in read may be updated concurrently without mu, but updating // a previously-expunged entry requires that the entry be copied to the dirty // map and unexpunged with mu held. read atomic.Pointer[readOnly]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 15.6K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/leaderelection.go
// Lock is held and not expired, but our key is higher than the existing one. // We will pre-empt the existing leader. // nolint: lll klog.V(4).Infof("lock is held by %v with key %v, but our key (%v) evicts it", oldLeaderElectionRecord.HolderIdentity, oldLeaderElectionRecord.HolderKey, le.config.Lock.Key()) } else {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 24 04:04:42 UTC 2023 - 16.3K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/moduleconverter/dependencies/DefaultLocalConfigurationMetadataBuilder.java
for (PublishArtifact ownArtifact : ownArtifacts) { // The following line may realize tasks, so project lock must be held. result.add(new PublishArtifactLocalArtifactMetadata(componentId, ownArtifact)); } // TODO: Deprecate the behavior of inheriting artifacts from parent configurations.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 16:00:57 UTC 2024 - 18K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/HeldCertificate.kt
} } private fun pkcs1Bytes(): ByteString { val decoded = CertificateAdapters.privateKeyInfo.fromDer(keyPair.private.encoded.toByteString()) return decoded.privateKey } /** Build a held certificate with reasonable defaults. */ class Builder { private var notBefore = -1L private var notAfter = -1L private var commonName: String? = null private var organizationalUnit: String? = null
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 21.6K bytes - Viewed (0)