Merge c141f7e into f53b714

setup.py

@@ -28,7 +28,7 @@
     license = f.read()
 
 setup(name='swim-protocol',
-      version='0.3.7',
+      version='0.3.8',
       author='Ian Good',
       author_email='ian@icgood.net',
       description='SWIM protocol implementation for exchanging cluster '

swimprotocol/udp/protocol.py

@@ -2,6 +2,7 @@
 from __future__ import annotations
 
 import asyncio
+import logging
 from asyncio import BaseTransport, Condition, DatagramProtocol, \
     DatagramTransport
 from collections import deque
@@ -15,6 +16,8 @@
 
 __all__ = ['SwimProtocol']
 
+_log = logging.getLogger(__name__)
+
 
 class SwimProtocol(DatagramProtocol, IO):
     """Implements :class:`~asyncio.DatagramProtocol` and
@@ -60,6 +63,25 @@ def datagram_received(self, data: bytes, addr: tuple[str, int]) -> None:
             return
         asyncio.create_task(self._push(packet))
 
+    def error_received(self, exc: Exception) -> None:
+        """Called when a UDP send or receive operation fails.
+
+        See Also:
+            :meth:`asyncio.DatagramProtocol.error_received`
+
+        """
+        _log.exception('UDP operation failed')
+
+    def connection_lost(self, exc: Optional[Exception]) -> None:
+        """Called when the UDP socket is closed.
+
+        See Also:
+            :meth:`asyncio.BaseProtocol.connection_lost`
+
+        """
+        _log.error('UDP connection lost: %s', exc)
+        self._transport = None
+
     async def _push(self, packet: Packet) -> None:
         async with self._queue_lock:
             self._queue.append(packet)