afonso/core-extra
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

added broadcasting of node/link messages to multiple session client scenarios

Browse source
This commit is contained in:
Blake J. Harnden 2017-07-12 12:39:40 -07:00
parent 964fdd6793
commit 3ba7e3b1a3
1 changed files with 11 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
daemon/core/corehandlers.py
View file

@ -536,12 +536,20 @@ class CoreRequestHandler(SocketServer.BaseRequestHandler):
message.queuedtimes = 0
self.queue_message(message)
if message.message_type == MessageTypes.SESSION.value:
# delay is required for brief connections, allow session joining
if message.message_type == MessageTypes.SESSION.value:
time.sleep(0.125)
# TODO: do we really want to broadcast node and link messages from a client to other clients?
# self.session.broadcast(self, message)
# broadcast node/link messages to other connected clients
if message.message_type not in [MessageTypes.NODE.value, MessageTypes.LINK.value]:
continue
for client in self.session.broker.session_clients:
if client == self:
continue
logger.info("BROADCAST TO OTHER CLIENT: %s", client)
client.sendall(message.raw_message)
def handle_node_message(self, message):
"""