summaryrefslogtreecommitdiffstats
path: root/nfvbench/traffic_client.py
diff options
context:
space:
mode:
authorMichael Pedersen <michael.soelvkaer@gmail.com>2019-03-11 14:44:05 +0100
committerMichael Pedersen <michael.soelvkaer@gmail.com>2019-03-11 15:44:27 +0100
commit727e863a026fc1f4fbb427bca86829627e954488 (patch)
treeaf799ce97074bffe9b2a68300e9f39c598b7f848 /nfvbench/traffic_client.py
parente1887dcf96c21e96f259a94f5e6835d45b27dfdf (diff)
VxLAN per-chain counter support
Re-commit following upgrade of TRex. Adds support for per-chain counter statistics. Due to a TRex limitation this does not work for latency streams. Change-Id: I5c764820b9269fda3df2f0aaa293996cb06fb19a Signed-off-by: Michael Pedersen <michael.soelvkaer@gmail.com>
Diffstat (limited to 'nfvbench/traffic_client.py')
-rwxr-xr-xnfvbench/traffic_client.py11
1 files changed, 8 insertions, 3 deletions
diff --git a/nfvbench/traffic_client.py b/nfvbench/traffic_client.py
index 469b922..75c40c1 100755
--- a/nfvbench/traffic_client.py
+++ b/nfvbench/traffic_client.py
@@ -577,8 +577,8 @@ class TrafficClient(object):
LOG.info('Starting traffic generator to ensure end-to-end connectivity')
# send 2pps on each chain and each direction
rate_pps = {'rate_pps': str(self.config.service_chain_count * 2)}
- self.gen.create_traffic('64', [rate_pps, rate_pps], bidirectional=True, latency=False)
-
+ self.gen.create_traffic('64', [rate_pps, rate_pps], bidirectional=True, latency=False,
+ e2e=True)
# ensures enough traffic is coming back
retry_count = (self.config.check_traffic_time_sec +
self.config.generic_poll_sec - 1) / self.config.generic_poll_sec
@@ -658,7 +658,12 @@ class TrafficClient(object):
self.run_config['rates'][idx] = {'rate_pps': self.__convert_rates(rate)['rate_pps']}
self.gen.clear_streamblock()
- self.gen.create_traffic(frame_size, self.run_config['rates'], bidirectional, latency=True)
+ if not self.config.vxlan:
+ self.gen.create_traffic(frame_size, self.run_config['rates'], bidirectional,
+ latency=True)
+ else:
+ self.gen.create_traffic(frame_size, self.run_config['rates'], bidirectional,
+ latency=False)
def _modify_load(self, load):
self.current_total_rate = {'rate_percent': str(load)}