client set to terminate itself

stress_tests/client/__init__.py

@@ -119,9 +119,9 @@ def run(client_notify, result_client, server_notify, server_result):
     client_notify.get()
 
     cad.start()
-
+    started_at = time.monotonic()
     terminating = False
-    while not terminating:
+    while not terminating and (time.monotonic() < started_at + 40):  # run for 40 seconds
         try:
             client_notify.get(timeout=1.0)
             terminating = True
@@ -130,5 +130,7 @@ def run(client_notify, result_client, server_notify, server_result):
         except KeyboardInterrupt:
             break
 
+    server_notify.put(None)
+
     lftf.close()
     # logger.warning('Got %s connections', len(cad.connections))