Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for moveAllToActiveOrBackoffQueue (0.32 sec)

  1. pkg/scheduler/eventhandlers.go

    				sched.SchedulingQueue.MoveAllToActiveOrBackoffQueue(logger, evt, nil, obj, nil)
    			}
    		}
    		if at&framework.Update != 0 {
    			evt := framework.ClusterEvent{Resource: gvk, ActionType: framework.Update, Label: fmt.Sprintf("%vUpdate", shortGVK)}
    			funcs.UpdateFunc = func(old, obj interface{}) {
    				sched.SchedulingQueue.MoveAllToActiveOrBackoffQueue(logger, evt, old, obj, nil)
    			}
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:21:04 UTC 2024
    - 24K bytes
    - Viewed (0)
  2. pkg/scheduler/internal/queue/scheduling_queue_test.go

    						}
    					}
    
    					b.StartTimer()
    					if tt.moveEvent.Resource != "" {
    						q.MoveAllToActiveOrBackoffQueue(logger, tt.moveEvent, nil, nil, nil)
    					} else {
    						// Random case.
    						q.MoveAllToActiveOrBackoffQueue(logger, events[i%len(events)], nil, nil, nil)
    					}
    				}
    			})
    		}
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  3. pkg/scheduler/internal/queue/scheduling_queue.go

    // moveAllToActiveOrBackoffQueue moves all pods from unschedulablePods to activeQ or backoffQ.
    // This function adds all pods and then signals the condition variable to ensure that
    // if Pop() is waiting for an item, it receives the signal after all the pods are in the
    // queue and the head is the highest priority pod.
    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/scheduler/schedule_one.go

    		// It's intentional to "defer" this operation; otherwise MoveAllToActiveOrBackoffQueue() would
    		// add this event to in-flight events and thus move the assumed pod to backoffQ anyways if the plugins don't have appropriate QueueingHint.
    		if status.IsRejected() {
    			defer sched.SchedulingQueue.MoveAllToActiveOrBackoffQueue(logger, internalqueue.AssignedPodDelete, assumedPod, nil, func(pod *v1.Pod) bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
Back to top