- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,937 for acquired (0.15 sec)
-
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/LockOnDemandCrossProcessCacheAccessTest.groovy
when: async { start { cacheAccess.withFileLock { instant.acquired thread.blockUntil.closed } } start { thread.blockUntil.acquired try { cacheAccess.close() } finally { instant.closed
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 21.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt
} } fun connectionCount(): Int { return connections.size } /** * Attempts to acquire a recycled connection to [address] for [connectionUser]. Returns the connection if it * was acquired, or null if no connection was acquired. The acquired connection will also be * given to [connectionUser] who may (for example) assign it to a [RealCall.connection]. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 16.2K bytes - Viewed (0) -
internal/dsync/drwmutex.go
quorumLocked := checkQuorumLocked(locks, quorum) && locksFailed <= tolerance if !quorumLocked { log("dsync: Unable to acquire lock in quorum %#v\n", args) // Release all acquired locks without quorum. if !releaseAll(ctx, ds, tolerance, owner, locks, isReadLock, restClnts, names...) { log("Unable to release acquired locks, these locks will expire automatically %#v\n", args) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 19.7K bytes - Viewed (0) -
src/runtime/lockrank_on.go
gp.m.locksHeld[i].lockAddr = 0 gp.m.locksHeldLen++ // i is the index of the lock being acquired if i > 0 { checkRanks(gp, gp.m.locksHeld[i-1].rank, rank) } }) } // checkRanks checks if goroutine g, which has mostly recently acquired a lock // with rank 'prevRank', can now acquire a lock with rank 'rank'. // //go:systemstack func checkRanks(gp *g, prevRank, rank lockRank) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:29:04 UTC 2024 - 10.6K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/start.go
StartTime: asof, }); err != nil { log.Printf("upload failed: %v", err) } } // acquireUploadToken acquires a token permitting the caller to upload. // To limit the frequency of uploads, only one token is issue per // machine per time period. // The boolean indicates whether the token was acquired. func acquireUploadToken() bool { if telemetry.Default.LocalDir() == "" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 14:52:56 UTC 2024 - 10.8K bytes - Viewed (0) -
src/runtime/metrics.go
// sysStatsAggregate represents system memory stats obtained // from the runtime. This set of stats is grouped together because // they're all relatively cheap to acquire and generally independent // of one another and other runtime memory stats. The fact that they // may be acquired at different times, especially with respect to // heapStatsAggregate, means there could be some skew, but because of
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 08 21:03:13 UTC 2024 - 26K bytes - Viewed (0) -
pkg/kube/krt/collection.go
log *istiolog.Scope // recomputeMu blocks a recomputation of I->O. recomputeMu sync.Mutex // mu protects all items grouped below. // This is acquired for reads and writes of data. // This can be acquired with recomputeMu held, but only with strict ordering (mu inside recomputeMu) mu sync.Mutex collectionState multiIndex[I, O]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 19.4K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultExclusiveCacheAccessCoordinatorTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 24K bytes - Viewed (0) -
src/runtime/lockrank.go
return "BAD RANK" } return lockNames[rank] } // lockPartialOrder is the transitive closure of the lock rank graph. // An entry for rank X lists all of the ranks that can already be held // when rank X is acquired. // // Lock ranks that allow self-cycles list themselves. var lockPartialOrder [][]lockRank = [][]lockRank{ lockRankSysmon: {}, lockRankScavenge: {lockRankSysmon},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 19.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/DefaultResourceLockCoordinationServiceTest.groovy
coordinationService.notifyStateChange() } then: 1 * listener.execute(lock) 0 * listener._ } def "does not notify listener when lock is acquired and released in single action"() { def listener = Mock(Action) coordinationService.addLockReleaseListener(listener) def lock = resourceLock("lock1") when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 17:16:10 UTC 2024 - 15.4K bytes - Viewed (0)