Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for enqueuePdb (0.65 sec)

  1. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/NodeState.java

            this.dependenciesMayChange = component.getModule().isVirtualPlatform();
        }
    
        // the enqueue and dequeue methods are used for performance reasons
        // in order to avoid tracking the set of enqueued nodes
        boolean enqueue() {
            if (queued) {
                return false;
            }
            queued = true;
            return true;
        }
    
        NodeState dequeue() {
            queued = false;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 14:19:34 UTC 2024
    - 58.9K bytes
    - Viewed (0)
  2. src/cmd/go/internal/modload/buildlist.go

    	enqueue = func(m module.Version, pruning modPruning) {
    		if m.Version == "none" {
    			return
    		}
    
    		if _, dup := loading.LoadOrStore(dedupKey{m, pruning}, nil); dup {
    			// m has already been enqueued for loading. Since unpruned loading may
    			// follow cycles in the requirement graph, we need to return early
    			// to avoid making the load queue infinitely long.
    			return
    		}
    
    		loadQueue.Add(func() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 16:04:44 UTC 2024
    - 53.8K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/queue/scheduling_queue.go

    func (p *PriorityQueue) Pop(logger klog.Logger) (*framework.QueuedPodInfo, error) {
    	p.lock.Lock()
    	defer p.lock.Unlock()
    	for p.activeQ.Len() == 0 {
    		// When the queue is empty, invocation of Pop() is blocked until new item is enqueued.
    		// When Close() is called, the p.closed is set and the condition is broadcast,
    		// which causes this loop to continue and return from the Pop().
    		if p.closed {
    			logger.V(2).Info("Scheduling queue is closed")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  4. pkg/kubelet/pod_workers_test.go

    		t.Fatalf("unexpected waiting static pods: %s", cmp.Diff(e, a))
    	}
    	// verify all are enqueued
    	if e, a := sets.New[string]("1-normal", "2-static", "4-static", "3-static"), podWorkers.workQueue.(*fakeQueue).Set(); !e.Equal(a) {
    		t.Fatalf("unexpected queued items: %s", cmp.Diff(e, a))
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
Back to top