From 33ffa0b6e0af5e2f658d9d12d0347ea57edc97a7 Mon Sep 17 00:00:00 2001 From: Loic Guegan Date: Fri, 1 Jul 2022 13:05:33 +0200 Subject: Simplify the API: Now wired transmission are never aborted if receiver turned off. It will just not receive the data --- 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 09569a0..4c9ca5f 100644 --- a/esds/node.py +++ b/esds/node.py @@ -100,7 +100,7 @@ class Node: self["state"]="call_non_blocking" self.wait_ack(["turn_on"]) - def send(self, interface, data, datasize, dst,cancel_on_turn_off=True): + def send(self, interface, data, datasize, dst): if interface not in self["interfaces"]: self.abort("send() called with an unknown interface \""+interface+"\"") elif type(datasize) != int and type(datasize) != float: @@ -110,14 +110,14 @@ class Node: elif not self["turned_on"]: self.abort("send() called while node is turned off") self.plugin_notify("send_call",(interface,data,datasize,dst)) - self.rargs=(interface, data, datasize, dst,cancel_on_turn_off) + self.rargs=(interface, data, datasize, dst) self["request"]="send" self["state"]="call_blocking" ack=self.wait_ack(["send","send_cancel"]) self.plugin_notify("send_return",(interface,data,datasize,dst,ack[1])) return ack[1] - def sendt(self, interface, data, datasize, dst, timeout,cancel_on_turn_off=True): + def sendt(self, interface, data, datasize, dst, timeout): if interface not in self["interfaces"]: self.abort("sendt() called with an unknown interface \""+interface+"\"") elif type(datasize) != int and type(datasize) != float: @@ -134,7 +134,7 @@ class Node: self["request"]="timeout_add" self["state"]="call_non_blocking" self.wait_ack(["timeout_add"]) - self.rargs=(interface, data, datasize, dst,cancel_on_turn_off) + self.rargs=(interface, data, datasize, dst) self["request"]="send" self["state"]="call_blocking" ack=self.wait_ack(["send","timeout","send_cancel"]) -- cgit v1.2.3