github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-21 19:01:49 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #87548 from skilxn-go/AddLoging

Browse Source 
Add logging to scheduler's event handlers
This commit is contained in:
Kubernetes Prow Robot 2020-01-27 06:31:02 -08:00 committed by GitHub
commit 2059ad6573
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
pkg/scheduler/eventhandlers.go
View File

@ -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