diff options
| author | Loic Guegan <manzerbredes@mailbox.org> | 2022-07-14 14:07:52 +0200 |
|---|---|---|
| committer | Loic Guegan <manzerbredes@mailbox.org> | 2022-07-14 14:07:52 +0200 |
| commit | e0dbebe31d4288f3636ef3871f45429b86b1d737 (patch) | |
| tree | 76574caae6ba69f42e304276f09e636845b9a3e9 /esds/node.py | |
| parent | 9671fc21eea14b6128c5f85208df4be0529c69d1 (diff) | |
Go back to commit 1eee1ac8
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 4c9ca5f..6a2566d 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): + def send(self, interface, data, datasize, dst, receiver_required=False): 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) + self.rargs=(interface, data, datasize, dst,receiver_required) 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): + def sendt(self, interface, data, datasize, dst, timeout, receiver_required=False): 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) + self.rargs=(interface, data, datasize, dst,receiver_required) self["request"]="send" self["state"]="call_blocking" ack=self.wait_ack(["send","timeout","send_cancel"]) |