Bug Fix: force the network to attacht to trex to start the traffic 79/30179/2
authorDeepak S <deepak.s@linux.intel.com>
Thu, 9 Mar 2017 14:26:30 +0000 (19:56 +0530)
committerDeepak S <deepak.s@linux.intel.com>
Thu, 9 Mar 2017 15:07:25 +0000 (20:37 +0530)
Change-Id: I73744a9e0f1830688a171f3f28044926b13f8a43
Signed-off-by: Deepak S <deepak.s@linux.intel.com>
yardstick/network_services/traffic_profile/fixed.py
yardstick/network_services/vnf_generic/vnf/tg_trex.py

index a456c2b..ebc1e61 100644 (file)
@@ -43,7 +43,8 @@ class FixedProfile(TrafficProfile):
                     self._create_stream(src_ip, dst_ip),
                     ports=[ports])
 
-            traffic_generator.client.start(ports=traffic_generator.my_ports)
+            traffic_generator.client.start(ports=traffic_generator.my_ports,
+                                           force=True)
             self.first_run = False
 
     def _create_stream(self, src_ip, dst_ip):
index 2731476..1e751bf 100644 (file)
@@ -31,6 +31,7 @@ from stl.trex_stl_lib.trex_stl_exceptions import STLError
 
 LOG = logging.getLogger(__name__)
 DURATION = 30
+WAIT_QUEUE = 1
 TREX_SYNC_PORT = 4500
 TREX_ASYNC_PORT = 4501
 
@@ -259,6 +260,7 @@ class TrexTrafficGen(GenericTrafficGen):
                      "tx_throughput_mbps": float(xe_value.get("tx_bps", 0.0)),
                      "in_packets": xe_value.get("ipackets", 0),
                      "out_packets": xe_value.get("opackets", 0)}
+            time.sleep(WAIT_QUEUE)
             queue.put(samples)
 
         self.client.disconnect()