hs-test: add more asserts

Type: test

Change-Id: Ia285ff39d9b19464ea086ec847ceaf52c6c0195c
Signed-off-by: Filip Tehlar <ftehlar@cisco.com>

extras/hs-test/suite_nginx_test.go

@@ -33,13 +33,13 @@ func (s *NginxSuite) SetupTest() {
 	// ... for proxy
 	vppProxyContainer := s.getContainerByName(vppProxyContainerName)
 	proxyVpp, _ := vppProxyContainer.newVppInstance(cpus, sessionConfig)
-	proxyVpp.start()
+	s.assertNil(proxyVpp.start())
 
 	clientInterface := s.netInterfaces[mirroringClientInterfaceName]
-	proxyVpp.createTap(clientInterface, 1)
+	s.assertNil(proxyVpp.createTap(clientInterface, 1))
 
 	serverInterface := s.netInterfaces[mirroringServerInterfaceName]
-	proxyVpp.createTap(serverInterface, 2)
+	s.assertNil(proxyVpp.createTap(serverInterface, 2))
 
 	nginxContainer := s.getTransientContainerByName(nginxProxyContainerName)
 	nginxContainer.create()
@@ -56,7 +56,7 @@ func (s *NginxSuite) SetupTest() {
 		"./resources/nginx/nginx_proxy_mirroring.conf",
 		values,
 	)
-	nginxContainer.start()
+	s.assertNil(nginxContainer.start())
 
 	proxyVpp.waitForApp("nginx-", 5)
 }

extras/hs-test/suite_no_topo_test.go

@@ -30,9 +30,9 @@ func (s *NoTopoSuite) SetupTest() {
 	cpus := s.AllocateCpus()
 	container := s.getContainerByName(singleTopoContainerVpp)
 	vpp, _ := container.newVppInstance(cpus, sessionConfig)
-	vpp.start()
+	s.assertNil(vpp.start())
 
 	tapInterface := s.netInterfaces[tapInterfaceName]
 
-	vpp.createTap(tapInterface)
+	s.assertNil(vpp.createTap(tapInterface), "failed to create tap interface")
 }

extras/hs-test/suite_ns_test.go

@@ -31,7 +31,7 @@ func (s *NsSuite) SetupTest() {
 	cpus := s.AllocateCpus()
 	container := s.getContainerByName("vpp")
 	vpp, _ := container.newVppInstance(cpus, sessionConfig)
-	vpp.start()
+	s.assertNil(vpp.start())
 
 	idx, err := vpp.createAfPacket(s.netInterfaces[serverInterface])
 	s.assertNil(err)

extras/hs-test/suite_veth_test.go

@@ -53,9 +53,7 @@ func (s *VethsSuite) SetupTest() {
 
 func (s *VethsSuite) setupServerVpp() {
 	serverVpp := s.getContainerByName("server-vpp").vppInstance
-
-	err := serverVpp.start()
-	s.assertNil(err)
+	s.assertNil(serverVpp.start())
 
 	serverVeth := s.netInterfaces[serverInterfaceName]
 	idx, err := serverVpp.createAfPacket(serverVeth)
@@ -65,9 +63,7 @@ func (s *VethsSuite) setupServerVpp() {
 
 func (s *VethsSuite) setupClientVpp() {
 	clientVpp := s.getContainerByName("client-vpp").vppInstance
-
-	err := clientVpp.start()
-	s.assertNil(err)
+	s.assertNil(clientVpp.start())
 
 	clientVeth := s.netInterfaces[clientInterfaceName]
 	idx, err := clientVpp.createAfPacket(clientVeth)

extras/hs-test/vppinstance.go

@@ -159,6 +159,7 @@ func (vpp *VppInstance) start() error {
 		core.DefaultReconnectInterval)
 	if err != nil {
 		fmt.Println("async connect error: ", err)
+		return err
 	}
 	vpp.connection = conn
 
@@ -172,12 +173,15 @@ func (vpp *VppInstance) start() error {
 	ch, err := conn.NewAPIChannel()
 	if err != nil {
 		fmt.Println("creating channel failed: ", err)
+		return err
 	}
 	if err := ch.CheckCompatiblity(vpe.AllMessages()...); err != nil {
 		fmt.Println("compatibility error: ", err)
+		return err
 	}
 	if err := ch.CheckCompatiblity(interfaces.AllMessages()...); err != nil {
 		fmt.Println("compatibility error: ", err)
+		return err
 	}
 	vpp.apiChannel = ch