diff options
| author | LV-426 <lv-426@taproot.org.il> | 2015-01-02 17:51:21 +0200 |
|---|---|---|
| committer | LV-426 <lv-426@taproot.org.il> | 2015-01-02 17:56:27 +0200 |
| commit | 6d2a396218cb58f67fce1f83e5d53195156f4114 (patch) | |
| tree | c5b7d69cdef98e6545fd884700a2ae4aae9f91d5 /src | |
| parent | a0514f245f50e2f44e6fd21e1e00ec015be07976 (diff) | |
mv log_multicast() to RZ_WebSocket_Server
Diffstat (limited to 'src')
| -rw-r--r-- | src/server/rz_mesh.py | 8 |
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 |
