Skip to content

Commit

Permalink
wip
Browse files Browse the repository at this point in the history
  • Loading branch information
ceclinux committed Jul 4, 2022
1 parent 1ba767f commit e2e772d
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 1 deletion.
2 changes: 1 addition & 1 deletion ci/jenkins/test.sh
Original file line number Diff line number Diff line change
Expand Up @@ -541,7 +541,7 @@ function run_e2e {
if [[ $TESTBED_TYPE == "flexible-ipam" ]]; then
go test -v antrea.io/antrea/test/e2e --logs-export-dir `pwd`/antrea-test-logs --provider remote -timeout=100m --prometheus --antrea-ipam
else
go test -v antrea.io/antrea/test/e2e --logs-export-dir `pwd`/antrea-test-logs --provider remote -timeout=100m --prometheus
go test -run=TestMulticast -v antrea.io/antrea/test/e2e --logs-export-dir `pwd`/antrea-test-logs --provider remote -timeout=100m --prometheus
fi
if [[ "$?" != "0" ]]; then
TEST_FAILURE=true
Expand Down
5 changes: 5 additions & 0 deletions test/e2e/multicast_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -675,6 +675,7 @@ func computeMulticastInterfaces(t *testing.T, data *TestData) (map[int][]string,
return nil, err
}
transportInterface, err := GetTransportInterface(data)
t.Logf("%+v", transportInterface)
if err != nil {
t.Fatalf("Error getting transport interfaces: %v", err)
}
Expand All @@ -686,9 +687,13 @@ func computeMulticastInterfaces(t *testing.T, data *TestData) (map[int][]string,
}
// The final multicast interfaces used for the node is calculated by (localInterfacesSet intersects multicastInterfaceSet adds transportInterface).
localInterfacesSet := sets.NewString(strings.Split(strings.TrimSpace(localInterfacesStr), "\n")...)
t.Logf("%+v", localInterfacesSet)
multicastInterfaceSet := sets.NewString(multicastInterfaces...)
t.Logf("%+v", multicastInterfaceSet)
externalMulticastInterfaces := localInterfacesSet.Intersection(multicastInterfaceSet)
t.Logf("%+v", externalMulticastInterfaces)
currNodeMulticastInterfaces := externalMulticastInterfaces.Insert(transportInterface).List()
t.Logf("%+v", currNodeMulticastInterfaces)
t.Logf("Multicast interfaces for node index %d is %+v", nodeIdx, currNodeMulticastInterfaces)
nodeMulticastInterfaces[nodeIdx] = currNodeMulticastInterfaces
}
Expand Down

0 comments on commit e2e772d

Please sign in to comment.