diff options
| author | Loic Guegan <manzerbredes@mailbox.org> | 2022-07-01 13:05:33 +0200 |
|---|---|---|
| committer | Loic Guegan <manzerbredes@mailbox.org> | 2022-07-01 13:05:33 +0200 |
| commit | 33ffa0b6e0af5e2f658d9d12d0347ea57edc97a7 (patch) | |
| tree | d3d2382f01af9fc9232ff60b8bcd7c52f2e70602 /esds/node.py | |
| parent | 1eee1ac81a0ef7f86c7acc2d431b0ac084aebf14 (diff) | |
Simplify the API: Now wired transmission are never aborted if receiver turned off. It will just not receive the data
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 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"]) |