Catch timeout issue during drain

mariano54 · mariano54 · commit adc6b35fdb4a · 2019-12-05T05:32:28.000+09:00
diff --git a/src/server/server.py b/src/server/server.py
@@ -268,7 +268,7 @@ async def serve_forever():
                 log.info(f"-> {message.function} to peer {connection.get_peername()}")
                 try:
                     await connection.send(message)
-                except (ConnectionResetError, BrokenPipeError, RuntimeError) as e:
+                except (ConnectionResetError, BrokenPipeError, RuntimeError, TimeoutError) as e:
                     log.error(
                         f"Cannot write to {connection}, already closed. Error {e}."
                     )

Original file line number	Diff line number	Diff line change
`@@ -268,7 +268,7 @@ async def serve_forever():`
`268`	`268`	`log.info(f"-> {message.function} to peer {connection.get_peername()}")`
`269`	`269`	`try:`
`270`	`270`	`await connection.send(message)`
`271`		`- except (ConnectionResetError, BrokenPipeError, RuntimeError) as e:`
	`271`	`+ except (ConnectionResetError, BrokenPipeError, RuntimeError, TimeoutError) as e:`
`272`	`272`	`log.error(`
`273`	`273`	`f"Cannot write to {connection}, already closed. Error {e}."`
`274`	`274`	`)`