diff options
| author | Shelley-BaoYue <baoyue2@huawei.com> | 2023-09-22 16:48:24 +0800 |
|---|---|---|
| committer | Shelley-BaoYue <baoyue2@huawei.com> | 2023-10-23 16:18:01 +0800 |
| commit | 09c38cede1bc3d4f09e7c4a374b718b411f77cf1 (patch) | |
| tree | 9f6ececb5d5279eed58e481f9b580983d45f4a61 | |
| parent | Merge pull request #5102 from Shelley-BaoYue/automated-cherry-pick-of-#5063-u... (diff) | |
| download | kubeedge-09c38cede1bc3d4f09e7c4a374b718b411f77cf1.tar.gz | |
fix remove pod failed
Signed-off-by: Shelley-BaoYue <baoyue2@huawei.com>
| -rw-r--r-- | edge/pkg/edged/edged.go | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/edge/pkg/edged/edged.go b/edge/pkg/edged/edged.go index 172aefe05..16e422055 100644 --- a/edge/pkg/edged/edged.go +++ b/edge/pkg/edged/edged.go @@ -288,15 +288,16 @@ func (e *edged) handlePod(op string, content []byte, updatesChan chan<- interfac pods = append(pods, &pod) if filterPodByNodeName(&pod, e.nodeName) { + var podOp kubelettypes.PodOperation switch op { - case model.InsertOperation: - klog.V(4).InfoS("Receive message of adding new pods", "pods", klog.KObjs(pods)) - case model.UpdateOperation: - klog.V(4).InfoS("Receive message of updating pods", "pods", klog.KObjs(pods)) + case model.InsertOperation, model.UpdateOperation: + klog.V(4).InfoS("Receive message of add/update pods", "operation", op, "pods", klog.KObjs(pods)) + podOp = kubelettypes.UPDATE case model.DeleteOperation: klog.V(4).InfoS("Receive message of deleting pods", "pods", klog.KObjs(pods)) + podOp = kubelettypes.REMOVE } - updates := &kubelettypes.PodUpdate{Op: kubelettypes.UPDATE, Pods: pods, Source: kubelettypes.ApiserverSource} + updates := &kubelettypes.PodUpdate{Op: podOp, Pods: pods, Source: kubelettypes.ApiserverSource} updatesChan <- *updates } |