monorail
/
Archipelago
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

optimize broadcast to serialize once

This commit is contained in:
Fabian Dill 2020-04-30 04:39:38 +02:00
parent 47784d2632
commit a6cc75d36a
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
MultiServer.py
View File

@ -163,15 +163,17 @@ async def send_json_msgs(client: Client, msg: str):
def broadcast_all(ctx: Context, msgs): def broadcast_all(ctx: Context, msgs):
msgs = json.dumps(msgs)
for client in ctx.clients: for client in ctx.clients:
if client.auth: if client.auth:
asyncio.create_task(send_msgs(client, msgs)) asyncio.create_task(send_json_msgs(client, msgs))
def broadcast_team(ctx: Context, team, msgs): def broadcast_team(ctx: Context, team, msgs):
msgs = json.dumps(msgs)
for client in ctx.clients: for client in ctx.clients:
if client.auth and client.team == team: if client.auth and client.team == team:
asyncio.create_task(send_msgs(client, msgs)) asyncio.create_task(send_json_msgs(client, msgs))
def notify_all(ctx : Context, text): def notify_all(ctx : Context, text):
logging.info("Notice (all): %s" % text) logging.info("Notice (all): %s" % text)