Handle timeout in aread_response

sveinse · Mar 13, 2023 · 537f717 · 537f717
1 parent 95daae2
commit 537f717
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/canopen/sdo/client.py b/canopen/sdo/client.py
@@ -109,8 +109,9 @@ def read_response(self):
 
     async def aread_response(self):
         try:
-            response = await self.aresponses.get()
-        except queue.Empty:
+            response = await asyncio.wait_for(
+                self.aresponses.get(), timeout=self.RESPONSE_TIMEOUT)
+        except TimeoutError:
             raise SdoCommunicationError("No SDO response received")
         res_command, = struct.unpack_from("B", response)
         if res_command == RESPONSE_ABORTED: