Skip config if policy not applied yet

There is a stage when the SriovNetworkNodeState is initializing
where the spec is empty because the SriovNetworkNodePolicyReconciler
did not yet applied the policies.

It can cause a non required action by the plugins,
that will try to apply the empty spec by resetting the NIC for example.

The config daemon will not run the plugins if the generation is 1
and the Spec.Interfaces is empty.

Solves issue #283

For e2e tests, the wait timeout to get to initial Sync state has been
increased.
This change is needed as now the config daemon will not apply on "empty"
spec until the SriovNetworkNodePolicyReconciler will iterate on the Interfaces.
The reconcile loop interval is 5 minutes, so the test timeout needed to be increased.

Signed-off-by: Fred Rolland <[email protected]>

controllers/sriovnetworknodepolicy_controller.go

@@ -278,6 +278,11 @@ func (r *SriovNetworkNodePolicyReconciler) syncSriovNetworkNodeState(np *sriovne
 			return fmt.Errorf("failed to get SriovNetworkNodeState: %v", err)
 		}
 	} else {
+		if len(found.Status.Interfaces) == 0 {
+			logger.Info("SriovNetworkNodeState Status Interfaces are empty. Skip update of policies in spec")
+			return nil
+		}
+
 		logger.Info("SriovNetworkNodeState already exists, updating")
 		newVersion := found.DeepCopy()
 		newVersion.Spec = ns.Spec

pkg/daemon/daemon.go

@@ -420,6 +420,11 @@ func (dn *Daemon) nodeStateSyncHandler(generation int64) error {
 		return nil
 	}
 
+	if latestState.GetGeneration() == 1 && len(latestState.Spec.Interfaces) == 0 {
+		glog.V(0).Infof("nodeStateSyncHandler(): Interface policy spec not yet set by controller")
+		return nil
+	}
+
 	dn.refreshCh <- Message{
 		syncStatus:    "InProgress",
 		lastSyncError: "",

test/e2e/e2e_tests_suite_test.go

@@ -37,11 +37,7 @@ var quitNetNsSet chan bool
 var doneNetNsSet chan error
 
 // Define utility constants for object names and testing timeouts/durations and intervals.
-const (
-	timeout         = time.Second * 30
-	interval        = time.Second * 1
-	devPollInterval = time.Millisecond * 400
-)
+const devPollInterval = time.Millisecond * 400
 
 func TestSriovTests(t *testing.T) {
 	RegisterFailHandler(Fail)

test/e2e/sriovoperatornodepolicy_test.go

@@ -32,7 +32,7 @@ var _ = Describe("Operator", func() {
 		Eventually(func() *cluster.EnabledNodes {
 			sriovInfos, _ = cluster.DiscoverSriov(clients, testNamespace)
 			return sriovInfos
-		}, timeout, interval).ShouldNot(BeNil())
+		}, Timeout*15, RetryInterval*20).ShouldNot(BeNil())
 		Expect(len(sriovInfos.Nodes)).To(BeNumerically(">", 0))
 
 		sriovIface, err = sriovInfos.FindOneSriovDevice(sriovInfos.Nodes[0])