From 1dca49157a5984f25ce6a810dfaf85b7cfc5a0a6 Mon Sep 17 00:00:00 2001 From: hub-Prateek Date: Wed, 22 Nov 2023 02:13:55 +0530 Subject: [PATCH] Utilized ListPlugins method --- pkg/scheduler/framework/runtime/framework.go | 32 +++++--------------- 1 file changed, 7 insertions(+), 25 deletions(-) diff --git a/pkg/scheduler/framework/runtime/framework.go b/pkg/scheduler/framework/runtime/framework.go index e5940709a6f..76d7e010621 100644 --- a/pkg/scheduler/framework/runtime/framework.go +++ b/pkg/scheduler/framework/runtime/framework.go @@ -355,32 +355,14 @@ func NewFramework(ctx context.Context, r Registry, profile *config.KubeScheduler options.captureProfile(outputProfile) } - for _, e := range f.getExtensionPoints(profile.Plugins) { - plugins := reflect.ValueOf(e.slicePtr).Elem() - pluginType := plugins.Type().Elem() + // Logs the enabled plugins enabled for each extension point + m := f.ListPlugins() + pluginMap := reflect.ValueOf(*m) + typeOfMap := pluginMap.Type() + + for i := 0; i < pluginMap.NumField(); i++ { loggerV := logger.V(2) - - enabledSet := newOrderedSet() - for _, plugin := range e.plugins.Enabled { - enabledSet.insert(plugin.Name) - } - - disabledSet := sets.New[string]() - for _, disabledPlugin := range e.plugins.Disabled { - disabledSet.Insert(disabledPlugin.Name) - } - - if disabledSet.Has("*") { - continue - } - - for _, ep := range profile.Plugins.MultiPoint.Enabled { - if !enabledSet.has(ep.Name) { - enabledSet.insert(ep.Name) - } - } - - loggerV.Info("Plugins enabled for", "extension", pluginType, "plugins", enabledSet.list) + loggerV.Info("Plugins enabled for", "extension", typeOfMap.Field(i).Name, "plugins", pluginMap.Field(i).Interface()) } f.setInstrumentedPlugins()