Skip to content

Commit 887a8bc

Browse files
committed
fix as review
Signed-off-by: bobz965 <zhangbingbing2_yewu@cmss.chinamobile.com>
1 parent 6eb5dea commit 887a8bc

File tree

2 files changed

+6
-7
lines changed

2 files changed

+6
-7
lines changed

pkg/controller/init.go

+3-3
Original file line numberDiff line numberDiff line change
@@ -859,11 +859,11 @@ func updateFinalizers(c client.Client, list client.ObjectList, getObjectItem fun
859859

860860
controllerutil.RemoveFinalizer(patchedObj, util.DepreciatedFinalizerName)
861861
controllerutil.AddFinalizer(patchedObj, util.KubeOVNControllerFinalizer)
862-
if err := c.Patch(context.Background(), patchedObj, client.MergeFrom(cachedObj)); err != nil {
863-
klog.Warningf("failed to sync finalizers for %s %s: %v",
862+
if err := c.Patch(context.Background(), patchedObj, client.MergeFrom(cachedObj)); err != nil && !k8serrors.IsNotFound(err) {
863+
klog.Errorf("failed to sync finalizers for %s %s: %v",
864864
patchedObj.GetObjectKind().GroupVersionKind().Kind,
865865
cache.MetaObjectToName(patchedObj), err)
866-
i++
866+
return err
867867
}
868868
i++
869869
}

pkg/controller/pod.go

+3-4
Original file line numberDiff line numberDiff line change
@@ -2151,7 +2151,6 @@ func (c *Controller) migrateVM(pod *v1.Pod, vmKey string) (bool, bool, bool, str
21512151
}
21522152
if _, ok := pod.Annotations[util.MigrationSourceAnnotation]; ok {
21532153
klog.Infof("will migrate out vm %s pod %s from source node %s", vmKey, pod.Name, pod.Spec.NodeName)
2154-
// 这里可能还有一个状态能标志结束,源pod更新了一次
21552154
return false, false, false, "", "", nil
21562155
}
21572156
// ovn set migrator only in the process of target vm pod
@@ -2182,15 +2181,15 @@ func (c *Controller) migrateVM(pod *v1.Pod, vmKey string) (bool, bool, bool, str
21822181
klog.Warning(err)
21832182
return false, false, false, "", "", nil
21842183
}
2185-
if migratePhase == util.MigrationStateStarted {
2184+
if migratePhase == util.MigrationPhaseStarted {
21862185
klog.Infof("start to migrate src vm %s from %s to %s", vmKey, srcNode, targetNode)
21872186
return true, false, false, srcNode, targetNode, nil
21882187
}
2189-
if migratePhase == util.MigrationStateSucceeded {
2188+
if migratePhase == util.MigrationPhaseSucceeded {
21902189
klog.Infof("succeed to migrate src vm %s from %s to %s", vmKey, srcNode, targetNode)
21912190
return true, true, false, srcNode, targetNode, nil
21922191
}
2193-
if migratePhase == util.MigrationStateFailed {
2192+
if migratePhase == util.MigrationPhaseFailed {
21942193
klog.Infof("failed to migrate src vm %s from %s to %s", vmKey, srcNode, targetNode)
21952194
return true, true, true, srcNode, targetNode, nil
21962195
}

0 commit comments

Comments
 (0)