diff options
| author | LV-426 <lv-426@taproot.org.il> | 2015-04-10 19:07:14 +0300 |
|---|---|---|
| committer | LV-426 <lv-426@taproot.org.il> | 2015-04-12 18:44:55 +0300 |
| commit | 07af791b0bc75e8aae49d1e685f60f65771737e7 (patch) | |
| tree | c72808395d796152eca9d75481c4ad1cea55fb27 /src/server | |
| parent | 19798975922c37bcb4667d40e73bb6f735e2d013 (diff) | |
rz_mesh: improve logging
Diffstat (limited to 'src/server')
| -rw-r--r-- | src/server/rz_mesh.py | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/src/server/rz_mesh.py b/src/server/rz_mesh.py index 29e086f3..2382303a 100644 --- a/src/server/rz_mesh.py +++ b/src/server/rz_mesh.py @@ -57,10 +57,6 @@ class RZ_WebSocket_Server(SocketIOServer): handler_class=RZ_WebSocket_Server.RZ_SocketIOHandler, ws_handler_class=RZ_WebSocket_Server.RZ_WebSocketHandler) - 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 - def init_ws_interface(cfg, kernel, flask_webapp): """ Initialize websocket interface: @@ -126,8 +122,6 @@ def init_ws_interface(cfg, kernel, flask_webapp): args=pkt_data, endpoint='/graph') - ws_srv.log_multicast(msg_name) - ws_broadcast_to_rzdoc_readers(ws_srv, pkt, rzdoc) return f_ret @@ -174,7 +168,9 @@ def init_ws_interface(cfg, kernel, flask_webapp): for r_assoc in rzdoc_r_set: cast_set.append(r_assoc) - log.debug('reader diff cast: rzdoc: %s, cast size: %d' % (rzdoc.name, len(cast_set))) + log.debug('ws: rzdoc reader cast: msg: \'%s\': rzdoc: %s, cast-size ~= %d' % (pkt.get('name'), + rzdoc.name, + len(cast_set))) for r_assoc in cast_set: try: r_assoc.socket.send_packet(pkt) |