diff options
| author | micplus <micplus@github.com> | 2024-04-03 15:22:31 +0800 |
|---|---|---|
| committer | micplus <ain01a@outlook.com> | 2024-04-07 14:17:37 +0800 |
| commit | 9e9cb4523a966a503895f644f4fe1ff4c89a864b (patch) | |
| tree | 4401e29cb4a6ea9a74c0c7514fb820c57c1c0432 | |
| parent | feat: add feature-gate for module restarting (diff) | |
| download | kubeedge-9e9cb4523a966a503895f644f4fe1ff4c89a864b.tar.gz | |
feat: remove metamanger main loop goroutine
Signed-off-by: micplus <ain01a@outlook.com>
| -rw-r--r-- | edge/pkg/metamanager/process.go | 30 |
1 files changed, 14 insertions, 16 deletions
diff --git a/edge/pkg/metamanager/process.go b/edge/pkg/metamanager/process.go index a11ceb5a5..c5e9f7919 100644 --- a/edge/pkg/metamanager/process.go +++ b/edge/pkg/metamanager/process.go @@ -419,21 +419,19 @@ func (m *metaManager) process(message model.Message) { } func (m *metaManager) runMetaManager() { - go func() { - for { - select { - case <-beehiveContext.Done(): - klog.Warning("MetaManager main loop stop") - return - default: - } - msg, err := beehiveContext.Receive(m.Name()) - if err != nil { - klog.Errorf("get a message %+v: %v", msg, err) - continue - } - klog.V(2).Infof("get a message %+v", msg) - m.process(msg) + for { + select { + case <-beehiveContext.Done(): + klog.Warning("MetaManager main loop stop") + return + default: } - }() + msg, err := beehiveContext.Receive(m.Name()) + if err != nil { + klog.Errorf("get a message %+v: %v", msg, err) + continue + } + klog.V(2).Infof("get a message %+v", msg) + m.process(msg) + } } |