diff options
| author | KubeEdge Bot <48982446+kubeedge-bot@users.noreply.github.com> | 2023-07-27 20:32:51 +0800 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2023-07-27 20:32:51 +0800 |
| commit | 671a3b9d17f2498ca4cd8660ac2f9a98fdd57aaf (patch) | |
| tree | eb1512cb4b0fd2bc4190ed18f3f9323832eff110 | |
| parent | Merge pull request #4895 from Shelley-BaoYue/automated-cherry-pick-of-#4641-u... (diff) | |
| parent | fix parsing resp err (diff) | |
| download | kubeedge-671a3b9d17f2498ca4cd8660ac2f9a98fdd57aaf.tar.gz | |
Merge pull request #4898 from Shelley-BaoYue/automated-cherry-pick-of-#4882-upstream-release-1.14v1.14.1
Automated cherry pick of #4882: fix parsing response message err in metamanager
| -rw-r--r-- | edge/pkg/metamanager/process.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/edge/pkg/metamanager/process.go b/edge/pkg/metamanager/process.go index 50884c65b..a11ceb5a5 100644 --- a/edge/pkg/metamanager/process.go +++ b/edge/pkg/metamanager/process.go @@ -352,6 +352,7 @@ func (m *metaManager) processRemote(message model.Message) { return } mapContent, ok := resp.GetContent().(map[string]interface{}) + respDB := resp if ok && isObjectResp(mapContent) { if mapContent["Err"] != nil { klog.V(4).Infof("process remote objResp err: %v", mapContent["Err"]) @@ -359,9 +360,9 @@ func (m *metaManager) processRemote(message model.Message) { return } klog.V(4).Infof("process remote objResp: %+v", mapContent["Object"]) - resp.Content = mapContent["Object"] + respDB.Content = mapContent["Object"] } - if err := m.handleMessage(&resp); err != nil { + if err := m.handleMessage(&respDB); err != nil { feedbackError(err, message) return } |