Change-Id: I73744a9e0f1830688a171f3f28044926b13f8a43
Signed-off-by: Deepak S <deepak.s@linux.intel.com>
                     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):
 
 
 LOG = logging.getLogger(__name__)
 DURATION = 30
+WAIT_QUEUE = 1
 TREX_SYNC_PORT = 4500
 TREX_ASYNC_PORT = 4501
 
                      "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()