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

Add a metric to track number of scheduler prioritizing goroutines

Browse Source
This commit is contained in:
Guoliang Wang 2019-10-07 09:39:49 +08:00
parent 08f7b22025
commit 9d173852c1
1 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
pkg/scheduler/core/generic_scheduler.go
View File

@ -732,7 +732,11 @@ func PrioritizeNodes(
if priorityConfigs[i].Function != nil { if priorityConfigs[i].Function != nil {
wg.Add(1) wg.Add(1)
go func(index int) { go func(index int) {
defer wg.Done() metrics.SchedulerGoroutines.WithLabelValues("prioritizing_legacy").Inc()
defer func() {
metrics.SchedulerGoroutines.WithLabelValues("prioritizing_legacy").Dec()
wg.Done()
}()
var err error var err error
results[index], err = priorityConfigs[index].Function(pod, nodeNameToInfo, nodes) results[index], err = priorityConfigs[index].Function(pod, nodeNameToInfo, nodes)
if err != nil { if err != nil {
@ -766,7 +770,11 @@ func PrioritizeNodes(
} }
wg.Add(1) wg.Add(1)
go func(index int) { go func(index int) {
defer wg.Done() metrics.SchedulerGoroutines.WithLabelValues("prioritizing_mapreduce").Inc()
defer func() {
metrics.SchedulerGoroutines.WithLabelValues("prioritizing_mapreduce").Dec()
wg.Done()
}()
if err := priorityConfigs[index].Reduce(pod, meta, nodeNameToInfo, results[index]); err != nil { if err := priorityConfigs[index].Reduce(pod, meta, nodeNameToInfo, results[index]); err != nil {
appendError(err) appendError(err)
} }
@ -812,7 +820,11 @@ func PrioritizeNodes(
} }
wg.Add(1) wg.Add(1)
go func(extIndex int) { go func(extIndex int) {
defer wg.Done() metrics.SchedulerGoroutines.WithLabelValues("prioritizing_extender").Inc()
defer func() {
metrics.SchedulerGoroutines.WithLabelValues("prioritizing_extender").Dec()
wg.Done()
}()
prioritizedList, weight, err := extenders[extIndex].Prioritize(pod, nodes) prioritizedList, weight, err := extenders[extIndex].Prioritize(pod, nodes)
if err != nil { if err != nil {
// Prioritization errors from extender can be ignored, let k8s/other extenders determine the priorities // Prioritization errors from extender can be ignored, let k8s/other extenders determine the priorities