summaryrefslogtreecommitdiff
path: root/src/server
diff options
context:
space:
mode:
authorLV-426 <lv-426@taproot.org.il>2015-01-02 17:51:21 +0200
committerLV-426 <lv-426@taproot.org.il>2015-01-02 17:56:27 +0200
commit6d2a396218cb58f67fce1f83e5d53195156f4114 (patch)
treec5b7d69cdef98e6545fd884700a2ae4aae9f91d5 /src/server
parenta0514f245f50e2f44e6fd21e1e00ec015be07976 (diff)
mv log_multicast() to RZ_WebSocket_Server
Diffstat (limited to 'src/server')
-rw-r--r--src/server/rz_mesh.py8
1 files changed, 5 insertions, 3 deletions
diff --git a/src/server/rz_mesh.py b/src/server/rz_mesh.py
index b6524531..c97f8809 100644
--- a/src/server/rz_mesh.py
+++ b/src/server/rz_mesh.py
@@ -19,8 +19,7 @@ class WebSocket_Graph_NS(BaseNamespace, BroadcastMixin):
Rhizi '/graph' websocket namespace
"""
def multicast_msg(self, msg_name, *args):
- multicast_size = len(self.socket.server.sockets) - 1 # subtract self socket
- log.info('ws: tx: msg: \'%s\': cast-size ~= %d' % (msg_name, multicast_size)) # ~=: as race conditions apply
+ self.socket.server.log_multicast(msg_name)
super(WebSocket_Graph_NS, self).broadcast_event_not_me(msg_name, *args)
def _log_conn(self, prefix_msg):
@@ -69,7 +68,10 @@ class RZ_WebSocket_Server(SocketIOServer):
resource='socket.io',
policy_server=False)
-def init_ws_interface(cfg, flask_webapp):
+ def log_multicast(self, msg_name):
+ multicast_size = len(self.sockets) - 1 # subtract self socket
+ log.info('ws: multicast: msg: \'%s\', cast-size ~= %d' % (msg_name, multicast_size)) # ~=: as race conditions apply
+
"""
Initialize websocket interface:
- apply websocket route handlers