Fix py adjust timeout (#78)

* Add missing adjust_timeout to Python code * Code formatting
robotraconteur · Feb 9, 2023 · 8d47fbf · 8d47fbf
1 parent e7a2b7d
commit 8d47fbf
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/RobotRaconteurPython/RobotRaconteurPythonUtil.py b/RobotRaconteurPython/RobotRaconteurPythonUtil.py
@@ -874,7 +874,7 @@ def ReceivePacketWait(self, timeout=RobotRaconteurPython.RR_TIMEOUT_INFINITE):
         :type timeout: float
         :return: The received packet
         """
-        m = self.__innerpipe.ReceivePacketWait(timeout)
+        m = self.__innerpipe.ReceivePacketWait(adjust_timeout(timeout))
         return UnpackMessageElement(m, self.__type, self.__obj, self.__innerpipe.GetNode())
 
     def PeekNextPacketWait(self, timeout=RobotRaconteurPython.RR_TIMEOUT_INFINITE):
@@ -886,7 +886,7 @@ def PeekNextPacketWait(self, timeout=RobotRaconteurPython.RR_TIMEOUT_INFINITE):
         :param timeout: Timeout in seconds to wait for a packet, or -1 for infinite
         :return: The received packet
         """
-        m = self.__innerpipe.PeekNextPacketWait(timeout)
+        m = self.__innerpipe.PeekNextPacketWait(adjust_timeout(timeout))
         return UnpackMessageElement(m, self.__type, self.__obj, self.__innerpipe.GetNode())
 
     def TryReceivePacketWait(self, timeout=RobotRaconteurPython.RR_TIMEOUT_INFINITE, peek=False):
@@ -907,7 +907,8 @@ def TryReceivePacketWait(self, timeout=RobotRaconteurPython.RR_TIMEOUT_INFINITE,
         :rtype: Tuple[bool,T]
         """
         m = RobotRaconteurPython.MessageElement()
-        r = self.__innerpipe.TryReceivePacketWait(m, timeout, peek)
+        r = self.__innerpipe.TryReceivePacketWait(
+            m, adjust_timeout(timeout), peek)
         return (r, UnpackMessageElement(m, self.__type, self.__obj, self.__innerpipe.GetNode()))
 
     @property
@@ -1400,7 +1401,7 @@ def WaitInValueValid(self, timeout=RobotRaconteurPython.RR_TIMEOUT_INFINITE):
         :return: Value is valid
         :rtype: bool
         """
-        return self.__innerwire.WaitInValueValid(timeout)
+        return self.__innerwire.WaitInValueValid(adjust_timeout(timeout))
 
     def WaitOutValueValid(self, timeout=RobotRaconteurPython.RR_TIMEOUT_INFINITE):
         """
@@ -1414,7 +1415,7 @@ def WaitOutValueValid(self, timeout=RobotRaconteurPython.RR_TIMEOUT_INFINITE):
         :return: Value is valid
         :rtype: bool
         """
-        return self.__innerwire.WaitOutValueValid(timeout)
+        return self.__innerwire.WaitOutValueValid(adjust_timeout(timeout))
 
     @property
     def WireValueChanged(self):