diff options
Diffstat (limited to 'esds/node.py')
| -rw-r--r-- | esds/node.py | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/esds/node.py b/esds/node.py index 4bfae71..bca9a5f 100644 --- a/esds/node.py +++ b/esds/node.py @@ -170,9 +170,9 @@ class Node: self.rargs=interface self["state"]="call_blocking" self.wait_ack(["receive"]) - data,start_at,end_at=self["interfaces"][interface].get() + data,start_at,end_at,rcode=self["interfaces"][interface].get() self.plugin_notify("receive_return",(interface,data,start_at,end_at)) - return (RCode.SUCCESS,data) + return (rcode,data) def receivet(self,interface, timeout): if interface not in self["interfaces"]: @@ -196,9 +196,9 @@ class Node: self["request"]="timeout_remove" self["state"]="call_non_blocking" self.wait_ack(["timeout_remove"]) - data,start_at,end_at=self["interfaces"][interface].get() + data,start_at,end_at,rcode=self["interfaces"][interface].get() self.plugin_notify("receivet_return",(interface,data,start_at,end_at)) - result=(RCode.SUCCESS,data) + result=(rcode,data) return result def wait_ack(self, ack_types): |