From a7f38dc162b2b194cfe84a98d587888ca4033cde Mon Sep 17 00:00:00 2001 From: Loic Guegan Date: Tue, 22 Aug 2023 18:18:32 +0200 Subject: Debug and improve interference detection --- esds/node.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'esds/node.py') 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): -- cgit v1.2.3