From ec85393ff80c3758bddc18a6e96a8f8d7a968041 Mon Sep 17 00:00:00 2001 From: Michael Johnson Date: Tue, 13 Aug 2024 18:20:55 +0100 Subject: [PATCH] Remove reconnect for read errors (#36) --- clients/rospy/src/rospy/impl/tcpros_base.py | 17 +++-------------- 1 file changed, 3 insertions(+), 14 deletions(-) diff --git a/clients/rospy/src/rospy/impl/tcpros_base.py b/clients/rospy/src/rospy/impl/tcpros_base.py index ce09cd35c0..80e0fa79db 100644 --- a/clients/rospy/src/rospy/impl/tcpros_base.py +++ b/clients/rospy/src/rospy/impl/tcpros_base.py @@ -798,22 +798,11 @@ def receive_loop(self, msgs_callback): msgs = self.receive_once() if not self.done and not is_shutdown(): msgs_callback(msgs, self) - else: - self._reconnect() except TransportException as e: - # set socket to None so we reconnect - try: - if self.socket is not None: - try: - self.socket.shutdown() - except: - pass - finally: - self.socket.close() - except: - pass - self.socket = None + # A transport exception means the connection has been closed from the other side. + # Clean up our side. + self.close() except DeserializationError as e: #TODO: how should we handle reconnect in this case?