diff options
| author | Loic Guegan <loic.guegan@mailbox.org> | 2023-08-22 18:18:32 +0200 |
|---|---|---|
| committer | Loic Guegan <loic.guegan@mailbox.org> | 2023-08-22 18:18:32 +0200 |
| commit | a7f38dc162b2b194cfe84a98d587888ca4033cde (patch) | |
| tree | 944b6800ea7d7a0544f8d6d3c6f3467130366c3f /esds/node.py | |
| parent | c05a90570f4a86928bfd9f02363f27a752c5fbdb (diff) | |
Debug and improve interference detection
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): |