github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-22 03:11:40 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #85526 from hex108/dump_nominated_pods

Browse Source 
Print nominated pods when dumping scheduler cached NodeInfo
This commit is contained in:
Kubernetes Prow Robot 2019-11-27 07:17:21 -08:00 committed by GitHub
commit be65a9d1b6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
pkg/scheduler/internal/cache/debugger/dumper.go vendored
View File

@ -46,7 +46,7 @@ func (d *CacheDumper) dumpNodes() {
snapshot := d.cache.Snapshot() snapshot := d.cache.Snapshot()
klog.Info("Dump of cached NodeInfo") klog.Info("Dump of cached NodeInfo")
for _, nodeInfo := range snapshot.Nodes { for _, nodeInfo := range snapshot.Nodes {
klog.Info(printNodeInfo(nodeInfo)) klog.Info(d.printNodeInfo(nodeInfo))
} }
} }
@ -61,14 +61,22 @@ func (d *CacheDumper) dumpSchedulingQueue() {
} }
// printNodeInfo writes parts of NodeInfo to a string. // printNodeInfo writes parts of NodeInfo to a string.
func printNodeInfo(n *schedulernodeinfo.NodeInfo) string { func (d *CacheDumper) printNodeInfo(n *schedulernodeinfo.NodeInfo) string {
var nodeData strings.Builder var nodeData strings.Builder
nodeData.WriteString(fmt.Sprintf("\nNode name: %+v\nRequested Resources: %+v\nAllocatable Resources:%+v\nNumber of Pods: %v\nPods:\n", nodeData.WriteString(fmt.Sprintf("\nNode name: %+v\nRequested Resources: %+v\nAllocatable Resources:%+v\nScheduled Pods(number: %v):\n",
n.Node().Name, n.RequestedResource(), n.AllocatableResource(), len(n.Pods()))) n.Node().Name, n.RequestedResource(), n.AllocatableResource(), len(n.Pods())))
// Dumping Pod Info // Dumping Pod Info
for _, p := range n.Pods() { for _, p := range n.Pods() {
nodeData.WriteString(printPod(p)) nodeData.WriteString(printPod(p))
} }
// Dumping nominated pods info on the node
nominatedPods := d.podQueue.NominatedPodsForNode(n.Node().Name)
if len(nominatedPods) != 0 {
nodeData.WriteString(fmt.Sprintf("Nominated Pods(number: %v):\n", len(nominatedPods)))
for _, p := range nominatedPods {
nodeData.WriteString(printPod(p))
}
}
return nodeData.String() return nodeData.String()
} }