From 943577a0ad64863a321d11aa39143c6b0f0defb9 Mon Sep 17 00:00:00 2001 From: saintube Date: Wed, 10 Jan 2024 20:23:14 +0800 Subject: [PATCH] koordlet: fix core sched conflicts with group identity Signed-off-by: saintube --- pkg/koordlet/koordlet.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/pkg/koordlet/koordlet.go b/pkg/koordlet/koordlet.go index b16eea09b..a3bca892f 100644 --- a/pkg/koordlet/koordlet.go +++ b/pkg/koordlet/koordlet.go @@ -37,6 +37,7 @@ import ( "github.com/koordinator-sh/koordinator/pkg/koordlet/metricsadvisor" "github.com/koordinator-sh/koordinator/pkg/koordlet/prediction" "github.com/koordinator-sh/koordinator/pkg/koordlet/qosmanager" + "github.com/koordinator-sh/koordinator/pkg/koordlet/resourceexecutor" "github.com/koordinator-sh/koordinator/pkg/koordlet/runtimehooks" "github.com/koordinator-sh/koordinator/pkg/koordlet/statesinformer" statesinformerimpl "github.com/koordinator-sh/koordinator/pkg/koordlet/statesinformer/impl" @@ -63,6 +64,7 @@ type daemon struct { qosManager qosmanager.QOSManager runtimeHook runtimehooks.RuntimeHook predictServer prediction.PredictServer + executor resourceexecutor.ResourceUpdateExecutor } func NewDaemon(config *config.Configuration) (Daemon, error) { @@ -115,6 +117,7 @@ func NewDaemon(config *config.Configuration) (Daemon, error) { qosManager: qosManager, runtimeHook: runtimeHook, predictServer: predictServer, + executor: resourceexecutor.NewResourceUpdateExecutor(), } return d, nil @@ -163,6 +166,9 @@ func (d *daemon) Run(stopCh <-chan struct{}) { } }() + // start resource executor before the writers modules + go d.executor.Run(stopCh) + // start qos manager go func() { if err := d.qosManager.Run(stopCh); err != nil {