diff --git a/pkg/scheduler/eventhandlers.go b/pkg/scheduler/eventhandlers.go index 95842ffaf25..ed66ec9e647 100644 --- a/pkg/scheduler/eventhandlers.go +++ b/pkg/scheduler/eventhandlers.go @@ -100,6 +100,7 @@ func (sched *Scheduler) addNodeToCache(obj interface{}) { klog.Errorf("scheduler cache AddNode failed: %v", err) } + klog.V(3).Infof("add event for node %q", node.Name) sched.SchedulingQueue.MoveAllToActiveOrBackoffQueue(queue.NodeAdd) } @@ -147,6 +148,7 @@ func (sched *Scheduler) deleteNodeFromCache(obj interface{}) { klog.Errorf("cannot convert to *v1.Node: %v", t) return } + klog.V(3).Infof("delete event for node %q", node.Name) // NOTE: Updates must be written to scheduler cache before invalidating // equivalence cache, because we could snapshot equivalence cache after the // invalidation and then snapshot the cache itself. If the cache is @@ -166,7 +168,9 @@ func (sched *Scheduler) onCSINodeUpdate(oldObj, newObj interface{}) { } func (sched *Scheduler) addPodToSchedulingQueue(obj interface{}) { - if err := sched.SchedulingQueue.Add(obj.(*v1.Pod)); err != nil { + pod := obj.(*v1.Pod) + klog.V(3).Infof("add event for unscheduled pod %s/%s", pod.Namespace, pod.Name) + if err := sched.SchedulingQueue.Add(pod); err != nil { utilruntime.HandleError(fmt.Errorf("unable to queue %T: %v", obj, err)) } } @@ -197,6 +201,7 @@ func (sched *Scheduler) deletePodFromSchedulingQueue(obj interface{}) { utilruntime.HandleError(fmt.Errorf("unable to handle object in %T: %T", sched, obj)) return } + klog.V(3).Infof("delete event for unscheduled pod %s/%s", pod.Namespace, pod.Name) if err := sched.SchedulingQueue.Delete(pod); err != nil { utilruntime.HandleError(fmt.Errorf("unable to dequeue %T: %v", obj, err)) } @@ -213,6 +218,7 @@ func (sched *Scheduler) addPodToCache(obj interface{}) { klog.Errorf("cannot convert to *v1.Pod: %v", obj) return } + klog.V(3).Infof("add event for scheduled pod %s/%s ", pod.Namespace, pod.Name) if err := sched.SchedulerCache.AddPod(pod); err != nil { klog.Errorf("scheduler cache AddPod failed: %v", err) @@ -261,6 +267,7 @@ func (sched *Scheduler) deletePodFromCache(obj interface{}) { klog.Errorf("cannot convert to *v1.Pod: %v", t) return } + klog.V(3).Infof("delete event for scheduled pod %s/%s ", pod.Namespace, pod.Name) // NOTE: Updates must be written to scheduler cache before invalidating // equivalence cache, because we could snapshot equivalence cache after the // invalidation and then snapshot the cache itself. If the cache is