#!/usr/bin/env python3
|
|
import subprocess
|
import time
|
import sys
|
|
def next_client(clients):
|
if len(clients) == 0:
|
return
|
|
c = clients.pop()
|
args = ["./random_client.py", str(c)]
|
|
proc = subprocess.Popen(args, stderr=subprocess.DEVNULL)
|
proc.cid = c
|
return proc
|
|
|
def run_clients(max_clients):
|
clients = list(range(1, max_clients))
|
start_time = time.time()
|
|
running_clients = []
|
while True:
|
print(len(running_clients))
|
if len(running_clients) < max_clients:
|
c = next_client(clients)
|
if c is not None:
|
running_clients.append(c)
|
else:
|
time.sleep(0.1)
|
|
for c in running_clients:
|
c.poll()
|
if c.returncode is not None:
|
running_clients.remove(c)
|
clients.append(c.cid)
|
c.terminate()
|
c.wait()
|
|
|
env = {}
|
env["LD_LIBRARY_PATH"] = "../../lib"
|
|
#broker = subprocess.Popen(["../../src/mosquitto", "-c", "random.conf"], env=env)
|
run_clients(1000)
|
