summaryrefslogtreecommitdiff
path: root/src/server
diff options
context:
space:
mode:
authorLV-426 <lv-426@taproot.org.il>2015-04-22 00:48:30 +0300
committerLV-426 <lv-426@taproot.org.il>2015-04-22 17:26:20 +0300
commite4b89ac5294f5ebed6f05c74b4cc1c43aed46570 (patch)
tree9ef1b7f5bca991f5d351f0d21487124305ba4304 /src/server
parent7174f651a23659b619769c75318b15e25c3b1422 (diff)
rz_mesh: rm deprecated reader list processing - ctx: ca343051
Diffstat (limited to 'src/server')
-rw-r--r--src/server/rz_mesh.py9
1 files changed, 3 insertions, 6 deletions
diff --git a/src/server/rz_mesh.py b/src/server/rz_mesh.py
index 4573aeb8..8a46b7b2 100644
--- a/src/server/rz_mesh.py
+++ b/src/server/rz_mesh.py
@@ -199,15 +199,12 @@ def init_ws_interface(cfg, kernel, flask_webapp):
Cast update messege to subscribed readers
"""
- cast_set = []
- rzdoc_r_set = kernel.rzdoc__reader_set_from_rzdoc(rzdoc)
- for r_assoc in rzdoc_r_set:
- cast_set.append(r_assoc)
+ r_assoc_set = kernel.rzdoc__reader_set_from_rzdoc(rzdoc)
log.debug('ws: rzdoc cast: msg: \'%s\': rzdoc: %s, cast-size ~= %d' % (pkt.get('name'),
rzdoc.name,
- len(cast_set)))
- for r_assoc in cast_set:
+ len(r_assoc_set)))
+ for r_assoc in r_assoc_set:
try:
r_assoc.socket.send_packet(pkt)
except Exception as e: