We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2d4b61b commit 2b37423Copy full SHA for 2b37423
1 file changed
src/zeroconf/_engine.py
@@ -151,9 +151,10 @@ async def _async_create_endpoints(self) -> None:
151
152
for s in reader_sockets:
153
reader = await self._async_wrap_socket(s, s in sender_sockets)
154
- # The wrap above does not await before returning, so releasing
155
- # the engine's pending handle here keeps ``s`` in exactly one
156
- # place from a concurrent shutdown's point of view.
+ # _async_wrap_socket registers the transport with no await between
+ # creating and registering it, and the pending-handle cleanup below
+ # adds no await either, so a concurrent shutdown always sees ``s``
157
+ # in exactly one place.
158
if s is self._listen_socket:
159
# Keep a handle to the shared listen socket so interface
160
# rescans can add/drop multicast memberships on it.
0 commit comments