Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for PushBack (0.2 sec)

  1. src/net/http/transport.go

    	tail    []*wantConn
    }
    
    // len returns the number of items in the queue.
    func (q *wantConnQueue) len() int {
    	return len(q.head) - q.headPos + len(q.tail)
    }
    
    // pushBack adds w to the back of the queue.
    func (q *wantConnQueue) pushBack(w *wantConn) {
    	q.tail = append(q.tail, w)
    }
    
    // popFront removes and returns the wantConn at the front of the queue.
    func (q *wantConnQueue) popFront() *wantConn {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 91K bytes
    - Viewed (0)
  2. src/runtime/mgcmark.go

    	// lock.
    	if atomic.Load(&gcBlackenEnabled) == 0 {
    		unlock(&work.assistQueue.lock)
    		return true
    	}
    
    	gp := getg()
    	oldList := work.assistQueue.q
    	work.assistQueue.q.pushBack(gp)
    
    	// Recheck for background credit now that this G is in
    	// the queue, but can still back out. This avoids a
    	// race in case background marking has flushed more
    	// credit since we checked above.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 21:25:11 UTC 2024
    - 52.5K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/queue/scheduling_queue.go

    	}
    	pInfo := obj.(*framework.QueuedPodInfo)
    	pInfo.Attempts++
    	p.schedulingCycle++
    	// In flight, no concurrent events yet.
    	if p.isSchedulingQueueHintEnabled {
    		p.inFlightPods[pInfo.Pod.UID] = p.inFlightEvents.PushBack(pInfo.Pod)
    	}
    
    	// Update metrics and reset the set of unschedulable plugins for the next attempt.
    	for plugin := range pInfo.UnschedulablePlugins.Union(pInfo.PendingPlugins) {
    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