diff options
| author |   Ritu Sood <ritu.sood@intel.com> | 2019-08-29 17:50:51 -0700 |
|---|---|---|
| committer | Ritu Sood <ritu.sood@intel.com> | 2019-08-29 17:58:19 -0700 |
| commit | 00a81d850fc144c2d43bcc0cf401d355ec7b712c (patch) | |
| tree | 77ec46b9c8032b07b5c86abdde1da685422a7a27 /pkg | |
| parent | a6c37bf8c9c1e9f5072bfc3e43b6ec0061ee2108 (diff) | |
Add check for annotation presence
If annotation is found on pod then pod
is already processed, stop processing.
This is different from "Failed to add
ports" error.
Change-Id: I101df641c150e007146bc1aeda9c5b372be329ca
Signed-off-by: Ritu Sood <ritu.sood@intel.com>
Diffstat (limited to 'pkg')
| -rw-r--r-- | pkg/controller/pod/pod_controller.go | 3 |
1 files changed, 3 insertions, 0 deletions
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) |