- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for rlocked (3.17 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
startTime := time.Now() timeout := c.dispatchTimeoutBudget.takeAvailable() c.timer.Reset(timeout) // Send event to all blocked watchers. As long as timer is running, // `add` will wait for the watcher to unblock. After timeout, // `add` will not wait, but immediately close a still blocked watcher. // Hence, every watcher gets the chance to unblock itself while timer // is running, not only the first ones in the list.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/configurations/DefaultConfigurationSpec.groovy
assert dep.reason == reason } where: reason | strict "dependency was locked to version '1.1'" | true "dependency was locked to version '1.1' (update/lenient mode)" | false } private ResolverResults buildDependenciesResolved() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 17:30:13 UTC 2024 - 64.8K bytes - Viewed (0) -
src/runtime/mgc.go
// this before waking blocked assists. atomic.Store(&gcBlackenEnabled, 0) // Notify the CPU limiter that GC assists will now cease. gcCPULimiter.startGCTransition(false, now) // Wake all blocked assists. These will run when we // start the world again. gcWakeAllAssists() // Likewise, release the transition lock. Blocked // workers and assists will run when we start the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 62K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/configurations/DefaultConfiguration.java
} private String getLockReason(boolean strict, String lockedVersion) { if (strict) { return "dependency was locked to version '" + lockedVersion + "'"; } return "dependency was locked to version '" + lockedVersion + "' (update/lenient mode)"; } @Override public DomainObjectContext getDomainObjectContext() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 17:36:01 UTC 2024 - 85.4K bytes - Viewed (0) -
src/runtime/traceback.go
} else { print(" m=nil") } } print(" [", status) if isScan { print(" (scan)") } if waitfor >= 1 { print(", ", waitfor, " minutes") } if gp.lockedm != 0 { print(", locked to thread") } print("]:\n") } func tracebackothers(me *g) { level, _, _ := gotraceback() // Show the current goroutine first, if we haven't already.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 16:25:21 UTC 2024 - 55.1K bytes - Viewed (0) -
src/internal/trace/order.go
// Validate the named M. if mid == curCtx.M { if gen != o.initialGen && curCtx.G != gid { // If this isn't the first generation, we *must* have seen this // binding occur already. Even if the G was blocked in a syscall // for multiple generations since trace start, we would have seen // a previous GoStatus event that bound the goroutine to an M.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 52.4K bytes - Viewed (0) -
src/runtime/mheap.go
if idx/pagesPerArena >= uintptr(len(arenas)) { // Page reclaiming is done. h.reclaimIndex.Store(1 << 63) break } if !locked { // Lock the heap for reclaimChunk. lock(&h.lock) locked = true } // Scan this chunk. nfound := h.reclaimChunk(arenas, idx, pagesPerReclaimerChunk) if nfound <= npage { npage -= nfound } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 78K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/debug.go
} loc.Registers &= other.Registers return loc } var BlockStart = &Value{ ID: -10000, Op: OpInvalid, Aux: StringToAux("BlockStart"), } var BlockEnd = &Value{ ID: -20000, Op: OpInvalid, Aux: StringToAux("BlockEnd"), } var FuncEnd = &Value{ ID: -30000, Op: OpInvalid, Aux: StringToAux("FuncEnd"), } // RegisterSet is a bitmap of registers, indexed by Register.num.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 58.4K bytes - Viewed (0) -
src/testing/testing.go
c.parent.Fail() } c.mu.Lock() defer c.mu.Unlock() // c.done needs to be locked to synchronize checks to c.done in parent tests. if c.done { panic("Fail in goroutine after " + c.name + " has completed") } c.failed = true } // Failed reports whether the function has failed. func (c *common) Failed() bool { c.mu.RLock() defer c.mu.RUnlock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 76.1K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
} if event.IsWildCard() { // If the wildcard event is special one as someone wants to force all Pods to move to activeQ/backoffQ. // We return queueAfterBackoff in this case, while resetting all blocked plugins. logger.V(6).Info("Worth requeuing because the event is wildcard", "pod", klog.KObj(pInfo.Pod)) return queueAfterBackoff } hintMap, ok := p.queueingHintMap[pInfo.Pod.Spec.SchedulerName] if !ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0)