diff options
author | Filip Tehlar <ftehlar@cisco.com> | 2023-06-08 17:39:39 +0200 |
---|---|---|
committer | Florin Coras <florin.coras@gmail.com> | 2023-06-08 17:04:36 +0000 |
commit | 3a910ab76800b9608b05e6b188730a2290b51ae0 (patch) | |
tree | 574fb81d426eb670cbfa22a764b1bee0cba6e7fc /extras/hs-test/hst_suite.go | |
parent | d5b6f9c0ef98f148b0e728fc1e8ccd8ba3faa806 (diff) |
hs-test: rename address allocator
Type: test
Change-Id: I1745719315d4e0785df5a03aa4312f84c40cb18f
Signed-off-by: Filip Tehlar <ftehlar@cisco.com>
Diffstat (limited to 'extras/hs-test/hst_suite.go')
-rw-r--r-- | extras/hs-test/hst_suite.go | 64 |
1 files changed, 11 insertions, 53 deletions
diff --git a/extras/hs-test/hst_suite.go b/extras/hs-test/hst_suite.go index 1fcffa42e00..d972c9d9b8e 100644 --- a/extras/hs-test/hst_suite.go +++ b/extras/hs-test/hst_suite.go @@ -2,7 +2,6 @@ package main import ( "flag" - "fmt" "io/ioutil" "os" "time" @@ -25,15 +24,15 @@ var nConfiguredCpus = flag.Int("cpus", 1, "number of CPUs assigned to vpp") type HstSuite struct { suite.Suite - containers map[string]*Container - volumes []string - netConfigs []NetConfig - netInterfaces map[string]*NetInterface - addresser *Addresser - testIds map[string]string - cpuAllocator *CpuAllocatorT - cpuContexts []*CpuContext - cpuPerVpp int + containers map[string]*Container + volumes []string + netConfigs []NetConfig + netInterfaces map[string]*NetInterface + ip4AddrAllocator *Ip4AddressAllocator + testIds map[string]string + cpuAllocator *CpuAllocatorT + cpuContexts []*CpuContext + cpuPerVpp int } func (s *HstSuite) SetupSuite() { @@ -229,7 +228,7 @@ func (s *HstSuite) loadNetworkTopology(topologyName string) { s.T().Fatalf("unmarshal error: %v", err) } - s.addresser = newAddresser(s) + s.ip4AddrAllocator = NewIp4AddressAllocator() s.netInterfaces = make(map[string]*NetInterface) for _, elem := range yamlTopo.Devices { switch elem["type"].(string) { @@ -243,7 +242,7 @@ func (s *HstSuite) loadNetworkTopology(topologyName string) { } case Veth, Tap: { - if netIf, err := newNetworkInterface(elem, s.addresser); err == nil { + if netIf, err := newNetworkInterface(elem, s.ip4AddrAllocator); err == nil { s.netConfigs = append(s.netConfigs, netIf) s.netInterfaces[netIf.Name()] = netIf } else { @@ -298,44 +297,3 @@ func (s *HstSuite) getTestId() string { return s.testIds[testName] } - -type AddressCounter = int - -type Addresser struct { - networks map[int]AddressCounter - suite *HstSuite -} - -func (a *Addresser) addNetwork(networkNumber int) { - a.networks[networkNumber] = 1 -} - -func (a *Addresser) newIp4Address(inputNetworkNumber ...int) (string, error) { - var networkNumber int = 0 - if len(inputNetworkNumber) > 0 { - networkNumber = inputNetworkNumber[0] - } - - if _, ok := a.networks[networkNumber]; !ok { - a.addNetwork(networkNumber) - } - - numberOfAddresses := a.networks[networkNumber] - - if numberOfAddresses == 254 { - return "", fmt.Errorf("no available IPv4 addresses") - } - - address := fmt.Sprintf("10.10.%v.%v/24", networkNumber, numberOfAddresses) - a.networks[networkNumber] = numberOfAddresses + 1 - - return address, nil -} - -func newAddresser(suite *HstSuite) *Addresser { - var addresser = new(Addresser) - addresser.suite = suite - addresser.networks = make(map[int]AddressCounter) - addresser.addNetwork(0) - return addresser -} |