@@ -243,32 +243,33 @@ def handle_incoming_messages(self, blocking: bool = False) -> MsgHandlingResult:
243243 try :
244244 self .socket .setblocking (blocking )
245245 incoming_message = self .read_message ()
246- try :
247- return self .handle_incoming_message (incoming_message )
248- except flat .InvalidFlatbuffer as e :
249- self .logger .error (
250- "Error while unpacking message (%s bytes): %s" ,
251- len (incoming_message ),
252- e ,
253- )
254- return MsgHandlingResult .TERMINATED
255- except Exception as e :
256- self .logger .error (
257- "Unexpected error while handling message of type: %s" ,
258- e ,
259- )
260- return MsgHandlingResult .TERMINATED
261246 except BlockingIOError :
262247 # No incoming messages and blocking==False
263248 return MsgHandlingResult .NO_INCOMING_MSGS
264249 except :
265250 self .logger .error ("SocketRelay disconnected unexpectedly!" )
266251 return MsgHandlingResult .TERMINATED
267252
253+ try :
254+ return self .handle_incoming_message (incoming_message )
255+ except flat .InvalidFlatbuffer as e :
256+ self .logger .error (
257+ "Error while unpacking message (%s bytes): %s" ,
258+ len (incoming_message ),
259+ e ,
260+ )
261+ return MsgHandlingResult .TERMINATED
262+ except Exception as e :
263+ self .logger .error (
264+ "Unexpected error while handling message of type: %s" ,
265+ e ,
266+ )
267+ return MsgHandlingResult .TERMINATED
268+
268269 def handle_incoming_message (self , incoming_message : bytes ) -> MsgHandlingResult :
269270 """
270271 Handles a messages by passing it to the relevant handlers.
271- Returns True if the message was NOT a shutdown request (i.e. NONE).
272+ Returns True if the message was NOT a shutdown request
272273 """
273274
274275 flatbuffer = flat .CorePacket .unpack (incoming_message ).message
0 commit comments