Add more validation and local fix

pkg/k8s/kubernetes.go

@@ -107,7 +107,7 @@ func BuildSUT(client *kubernetes.Clientset, s *config.PerfScenarios) error {
 		}
 	}
 	log.Debugf("Number of nodes with role worker: %d", ncount)
-	if !s.NodeLocal && ncount < 2 {
+	if (s.HostNetwork || !s.NodeLocal) && ncount < 2 {
 		return fmt.Errorf(" not enough nodes with label worker= to execute test (current number of nodes: %d).", ncount)
 	}
 
@@ -150,18 +150,6 @@ func BuildSUT(client *kubernetes.Clientset, s *config.PerfScenarios) error {
 			cdp.NodeAffinity = apiv1.NodeAffinity{
 				PreferredDuringSchedulingIgnoredDuringExecution: zoneNodeSelectorExpression(z),
 			}
-			cdp.PodAffinity = apiv1.PodAffinity{
-				RequiredDuringSchedulingIgnoredDuringExecution: []apiv1.PodAffinityTerm{
-					{
-						LabelSelector: &metav1.LabelSelector{
-							MatchExpressions: []metav1.LabelSelectorRequirement{
-								{Key: "role", Operator: metav1.LabelSelectorOpIn, Values: []string{serverRole}},
-							},
-						},
-						TopologyKey: "kubernetes.io/hostname",
-					},
-				},
-			}
 		}
 
 		cdp.NodeAffinity = apiv1.NodeAffinity{
@@ -345,10 +333,13 @@ func BuildSUT(client *kubernetes.Clientset, s *config.PerfScenarios) error {
 		}
 		sdpHost.PodAntiAffinity = antiAffinity
 	}
-	if s.HostNetwork {
-		s.ServerHost, err = deployDeployment(client, sdpHost)
-		if err != nil {
-			return err
+
+	if ncount > 1 {
+		if s.HostNetwork {
+			s.ServerHost, err = deployDeployment(client, sdpHost)
+			if err != nil {
+				return err
+			}
 		}
 	}
 	s.Server, err = deployDeployment(client, sdp)

pkg/netperf/netperf.go

@@ -130,6 +130,11 @@ func ParseResults(stdout *bytes.Buffer) (sample.Sample, error) {
 	if math.IsNaN(sample.Latency99ptile) {
 		return sample, fmt.Errorf("Latency value is NaN")
 	}
-	sample.LossPercent = 100 - (recv / send * 100)
+	// Negative values will mean UDP_STREAM
+	if sample.Retransmits < 0.0 {
+		sample.LossPercent = 100 - (recv / send * 100)
+	} else {
+		sample.LossPercent = 0
+	}
 	return sample, nil
 }