diff options
Diffstat (limited to 'extras/hs-test/infra')
| -rw-r--r-- | extras/hs-test/infra/suite_nginx.go | 9 | ||||
| -rw-r--r-- | extras/hs-test/infra/suite_no_topo.go | 9 | ||||
| -rw-r--r-- | extras/hs-test/infra/suite_ns.go | 8 | ||||
| -rw-r--r-- | extras/hs-test/infra/suite_veth.go | 9 |
4 files changed, 31 insertions, 4 deletions
diff --git a/extras/hs-test/infra/suite_nginx.go b/extras/hs-test/infra/suite_nginx.go index f835262d591..bb1bdb0f42b 100644 --- a/extras/hs-test/infra/suite_nginx.go +++ b/extras/hs-test/infra/suite_nginx.go @@ -45,7 +45,14 @@ func (s *NginxSuite) SetupTest() { sessionConfig. NewStanza("session"). Append("enable"). - Append("use-app-socket-api").Close() + Append("use-app-socket-api") + + if strings.Contains(CurrentSpecReport().LeafNodeText, "InterruptMode") { + sessionConfig.Append("use-private-rx-mqs").Close() + s.Log("**********************INTERRUPT MODE**********************") + } else { + sessionConfig.Close() + } // ... for proxy vppProxyContainer := s.GetContainerByName(VppProxyContainerName) diff --git a/extras/hs-test/infra/suite_no_topo.go b/extras/hs-test/infra/suite_no_topo.go index c48e6fb1845..5f53f55f1bb 100644 --- a/extras/hs-test/infra/suite_no_topo.go +++ b/extras/hs-test/infra/suite_no_topo.go @@ -42,7 +42,14 @@ func (s *NoTopoSuite) SetupTest() { sessionConfig. NewStanza("session"). Append("enable"). - Append("use-app-socket-api").Close() + Append("use-app-socket-api") + + if strings.Contains(CurrentSpecReport().LeafNodeText, "InterruptMode") { + sessionConfig.Append("use-private-rx-mqs").Close() + s.Log("**********************INTERRUPT MODE**********************") + } else { + sessionConfig.Close() + } container := s.GetContainerByName(SingleTopoContainerVpp) vpp, _ := container.newVppInstance(container.AllocatedCpus, sessionConfig) diff --git a/extras/hs-test/infra/suite_ns.go b/extras/hs-test/infra/suite_ns.go index d88730b1c0b..601ec22a8a9 100644 --- a/extras/hs-test/infra/suite_ns.go +++ b/extras/hs-test/infra/suite_ns.go @@ -45,7 +45,13 @@ func (s *NsSuite) SetupTest() { Append("enable"). Append("use-app-socket-api"). Append("evt_qs_memfd_seg"). - Append("event-queue-length 100000").Close() + Append("event-queue-length 100000") + + if strings.Contains(CurrentSpecReport().LeafNodeText, "InterruptMode") { + sessionConfig.Append("use-private-rx-mqs").Close() + } else { + sessionConfig.Close() + } container := s.GetContainerByName("vpp") vpp, _ := container.newVppInstance(container.AllocatedCpus, sessionConfig) diff --git a/extras/hs-test/infra/suite_veth.go b/extras/hs-test/infra/suite_veth.go index d7bfa55acd0..f7b1c3da7d8 100644 --- a/extras/hs-test/infra/suite_veth.go +++ b/extras/hs-test/infra/suite_veth.go @@ -45,7 +45,14 @@ func (s *VethsSuite) SetupTest() { sessionConfig. NewStanza("session"). Append("enable"). - Append("use-app-socket-api").Close() + Append("use-app-socket-api") + + if strings.Contains(CurrentSpecReport().LeafNodeText, "InterruptMode") { + sessionConfig.Append("use-private-rx-mqs").Close() + s.Log("**********************INTERRUPT MODE**********************") + } else { + sessionConfig.Close() + } // ... For server serverContainer := s.GetContainerByName("server-vpp") |