gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

working blpop test in monkey

Browse Source 
Former-commit-id: 21af13c2a38741ad9e036fad42b23ea2454ac33c
This commit is contained in:
christianEQ 2021-03-17 16:10:06 +00:00
parent a585974932
commit 91a18c2313
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
monkey/monkey.py
View File

@ -181,8 +181,7 @@ def handle_blpop_response(c, resp=None):
global ops global ops
if resp != None: if resp != None:
ops['blpop'] += 1 ops['blpop'] += 1
else: c.blpop("list_" + getrandomkey(), callback=handle_blpop_response)
c.blpop("list_" + getrandomkey(), callback=handle_blpop_response)
def handle_set_response(c, resp=None): def handle_set_response(c, resp=None):
global ops global ops
@ -214,7 +213,7 @@ def stats_thread():
i = 0 i = 0
while not g_exit and not (runtime and i > runtime): while not g_exit and not (runtime and i > runtime):
time.sleep(1) time.sleep(1)
print("Ops per second: " + str(ops)) print("Ops per second: " + str({k:v for (k,v) in ops.items() if v}))
#print(f"Blocked threads: {len(list(filter(lambda x: x.blocked, clients)))}") #print(f"Blocked threads: {len(list(filter(lambda x: x.blocked, clients)))}")
clear_ops() clear_ops()
i += 1 i += 1
@ -229,7 +228,7 @@ def flush_db_sync():
def init_blocking(): def init_blocking():
global clients global clients
if numkeys > 5 * numclients: if numkeys > 100 * numclients:
print("WARNING: High ratio of keys to clients. Most lpushes will not be popped and unblocking will take a long time!") print("WARNING: High ratio of keys to clients. Most lpushes will not be popped and unblocking will take a long time!")
for i in range(numclients): for i in range(numclients):
clients.append(Client('127.0.0.1', 6379)) clients.append(Client('127.0.0.1', 6379))
@ -265,6 +264,10 @@ def main(test, flush):
except KeyError: except KeyError:
print(f"Test \"{test}\" not found. Exiting...") print(f"Test \"{test}\" not found. Exiting...")
exit() exit()
except ConnectionRefusedError:
print("Could not connect to server. Is it running?")
print("Exiting...")
exit()
threading.Thread(target=stats_thread).start() threading.Thread(target=stats_thread).start()
asyncore.loop() asyncore.loop()