Skip to content

Commit bea0c35

Browse files
authored
Improvements/experiment 2 (#5)
* Making necessary fixes to integrate with retina
1 parent 9668d14 commit bea0c35

File tree

2 files changed

+6
-1
lines changed

2 files changed

+6
-1
lines changed

network/benchmarks/netperf/lib/testlib.go

+3
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,9 @@ func PerformTests(testParams TestParams) error {
4444
primaryNode := nodes.Items[0]
4545
secondaryNode := nodes.Items[1]
4646

47+
fmt.Println("Primary Node : ", primaryNode.Name)
48+
fmt.Println("Secondary Node : ", secondaryNode.Name)
49+
4750
if testParams.CleanupOnly {
4851
cleanup(c, testParams.TestNamespace)
4952
return nil

network/benchmarks/netperf/lib/utilslib.go

+3-1
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,8 @@ func getMinionNodes(c *kubernetes.Clientset) (*api.NodeList, error) {
3333
context.Background(),
3434
metav1.ListOptions{
3535
FieldSelector: "spec.unschedulable=false",
36-
LabelSelector: "kubernetes.io/os=linux",
36+
// for now the tests can only run on linux/amd64 nodes
37+
LabelSelector: "kubernetes.io/os=linux,kubernetes.io/arch=amd64",
3738
})
3839
if err != nil {
3940
return nil, fmt.Errorf("failed to get nodes: %v", err)
@@ -143,6 +144,7 @@ func createRCs(c *kubernetes.Clientset, testParams TestParams, primaryNode, seco
143144
Labels: map[string]string{"app": name},
144145
},
145146
Spec: api.PodSpec{
147+
NodeSelector: map[string]string{"kubernetes.io/os": "linux", "kubernetes.io/arch": "amd64"},
146148
Containers: []api.Container{
147149
{
148150
Name: name,

0 commit comments

Comments
 (0)