Improve error handling.

TeskaLabs · Aug 15, 2023 · 68cec2d · 68cec2d
1 parent f81e7df
commit 68cec2d
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/asab/log.py b/asab/log.py
@@ -447,10 +447,12 @@ def _on_write(self):
 		self._loop.remove_writer(self._socket)
 
 		while not self._queue.empty():
-			# TODO: Handle eventual error in writing -> break the cycle and restart on write handler
 			msg = self._queue.get_nowait()
-			self._socket.sendall(msg)
-
+			try:
+				self._socket.sendall(msg)
+			except Exception as e:
+				print("Error when writing to syslog '{}'".format(self._address), e, file=sys.stderr)
+				self._enqueue(msg)
 
 	def _on_read(self):
 		try: