diff options
| author | micplus <ain01a@outlook.com> | 2024-04-07 11:55:31 +0800 |
|---|---|---|
| committer | micplus <ain01a@outlook.com> | 2024-04-07 14:17:38 +0800 |
| commit | 09d2b2940d2df4b76b3ac321b5cc496b114a36be (patch) | |
| tree | 476acb24a34d8ff3c6021f422ce885f289779f2f | |
| parent | feat: add feature (diff) | |
| download | kubeedge-09d2b2940d2df4b76b3ac321b5cc496b114a36be.tar.gz | |
feat: remove unnecessary msg
Signed-off-by: micplus <ain01a@outlook.com>
| -rw-r--r-- | edge/pkg/edged/edged.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/edge/pkg/edged/edged.go b/edge/pkg/edged/edged.go index 1f81fce9f..c95407ab9 100644 --- a/edge/pkg/edged/edged.go +++ b/edge/pkg/edged/edged.go @@ -60,8 +60,8 @@ import ( metaclient "github.com/kubeedge/kubeedge/edge/pkg/metamanager/client" "github.com/kubeedge/kubeedge/edge/pkg/metamanager/dao" "github.com/kubeedge/kubeedge/pkg/apis/componentconfig/edgecore/v1alpha2" - "github.com/kubeedge/kubeedge/pkg/version" kefeatures "github.com/kubeedge/kubeedge/pkg/features" + "github.com/kubeedge/kubeedge/pkg/version" ) // GetKubeletDeps returns a Dependencies suitable for lite kubelet being run. @@ -145,9 +145,6 @@ func (e *edged) Start() { os.Exit(1) } klErrChan <- err - // send empty message to wakeup syncPod loop - nilMsg := model.NewMessage("").BuildRouter(e.Name(), e.Group(), "", "") - beehiveContext.Send(modules.EdgedModuleName, *nilMsg) } }() e.syncPod(e.KubeletDeps.PodConfig, klErrChan) @@ -254,9 +251,12 @@ func (e *edged) syncPod(podCfg *config.PodConfig, kubeletErrChan <-chan error) { case err := <-kubeletErrChan: klog.Errorf("Start edged failed, err: %v", err) return - case <-kubeletWaiter.C: - kubeletInited = true default: + select { + case <-kubeletWaiter.C: + kubeletInited = true + default: + } if !kubeletInited { time.Sleep(time.Second) continue |