diff options
| -rw-r--r-- | internal/pkg/ovn/ovn.go | 5 | ||||
| -rw-r--r-- | pkg/controller/pod/pod_controller.go | 3 |
2 files changed, 3 insertions, 5 deletions
diff --git a/internal/pkg/ovn/ovn.go b/internal/pkg/ovn/ovn.go index 82fe837..12a4912 100644 --- a/internal/pkg/ovn/ovn.go +++ b/internal/pkg/ovn/ovn.go @@ -72,11 +72,6 @@ func (oc *Controller) AddLogicalPorts(pod *kapi.Pod, ovnNetObjs []map[string]int return } - if _, ok := pod.Annotations[Ovn4nfvAnnotationTag]; ok { - log.V(1).Info("AddLogicalPorts : Pod annotation found") - return - } - var ovnString, outStr string ovnString = "[" var ns netInterface diff --git a/pkg/controller/pod/pod_controller.go b/pkg/controller/pod/pod_controller.go index 8792985..23a847e 100644 --- a/pkg/controller/pod/pod_controller.go +++ b/pkg/controller/pod/pod_controller.go @@ -167,6 +167,9 @@ func (r *ReconcilePod) addLogicalPorts(pod *corev1.Pod) error { if err != nil { return err } + if _, ok := pod.Annotations[ovn.Ovn4nfvAnnotationTag]; ok { + return fmt.Errorf("Pod annotation found") + } key, value := ovnCtl.AddLogicalPorts(pod, nfn.Interface) if len(key) > 0 { return r.setPodAnnotation(pod, key, value) |