From c6b4725e552738a72d0151d2081edc30550d23b3 Mon Sep 17 00:00:00 2001 From: PingWang Date: Fri, 1 Jul 2022 13:56:33 +0800 Subject: [PATCH] Add failure handling of the desiredStateOfWorldPopulator start Signed-off-by: PingWang --- pkg/kubelet/pluginmanager/plugin_manager.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/pkg/kubelet/pluginmanager/plugin_manager.go b/pkg/kubelet/pluginmanager/plugin_manager.go index 79e0c8c46b7..e1491165feb 100644 --- a/pkg/kubelet/pluginmanager/plugin_manager.go +++ b/pkg/kubelet/pluginmanager/plugin_manager.go @@ -108,7 +108,11 @@ var _ PluginManager = &pluginManager{} func (pm *pluginManager) Run(sourcesReady config.SourcesReady, stopCh <-chan struct{}) { defer runtime.HandleCrash() - pm.desiredStateOfWorldPopulator.Start(stopCh) + if err := pm.desiredStateOfWorldPopulator.Start(stopCh); err != nil { + klog.ErrorS(err, "The desired_state_of_world populator (plugin watcher) starts failed!") + return + } + klog.V(2).InfoS("The desired_state_of_world populator (plugin watcher) starts") klog.InfoS("Starting Kubelet Plugin Manager")