Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for rlocked (3.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top