summaryrefslogtreecommitdiff
path: root/src/server
diff options
context:
space:
mode:
authorLV-426 <lv-426@taproot.org.il>2015-04-09 01:42:39 +0300
committerLV-426 <lv-426@taproot.org.il>2015-04-09 02:03:45 +0300
commit7709bb7896d9283047ea56ea6b89458c29b6fac3 (patch)
treed87177a0bdb5fd18adec1040795d3e15069cacb0 /src/server
parent421e3d7fe6e8a31b38e50b390687c41ac6b9e5ed (diff)
rz_mesh: misc: mv assert, doc, etc
Diffstat (limited to 'src/server')
-rw-r--r--src/server/rz_mesh.py11
1 files changed, 8 insertions, 3 deletions
diff --git a/src/server/rz_mesh.py b/src/server/rz_mesh.py
index cac2cacb..570e09d9 100644
--- a/src/server/rz_mesh.py
+++ b/src/server/rz_mesh.py
@@ -84,9 +84,10 @@ def init_ws_interface(cfg, kernel, flask_webapp):
flask_webapp.logger.error("Exception while handling socketio connection", exc_info=True)
return make_response__http__empty(101) # 'switching protocols' HTTP status code
- # link ws hooks: multicast on topo_diff, attr_diff
def decorator__ws_multicast(ws_srv, f, f_multicast):
"""
+ Emit multicast on topo_diff, attr_diff
+
@param f: [!] wrapped function, name used to derive socket message name
"""
@@ -100,9 +101,14 @@ def init_ws_interface(cfg, kernel, flask_webapp):
def wrapped_function(*args, **kw):
f_ret = f(*args, **kw)
+ assert type(f_ret) in [list, tuple] # expect (X_Diff, X_Diff.Commit_Result_Type)
+ #
+ # Identify f caller
+ #
+ # TODO: avoid stack inspection if possible
+ #
try:
- # TODO: avoid stack inspection if possible
stack = inspect.stack()
stack_frame = stack[1][0]
@@ -121,7 +127,6 @@ def init_ws_interface(cfg, kernel, flask_webapp):
log.exception('decorator__ws_multicast: failed to detect REST/Websocket call via stack inspection') # exception derived from stack
rzdoc = rzdoc_from_f_args_extractor(args)
- assert type(f_ret) in [list, tuple]
pkt_data = map(_prep_for_serialization, f_ret)