iSrSSKJr SSKrSSKrSSKrSSKrSSKJ r J r SSK J r SSK Jr SSKJr S S KJr S rS rS rSS jrSS jrSSjrSSjrSSjrSSjrSSjrSSjrSSjrSSjrg) aMulticast DNS Service Discovery for Python, v0.14-wmcbrine Copyright 2003 Paul Scott-Murphy, 2014 William McBrine This module provides a framework for the use of DNS Service Discovery using IP multicast. This library is free software; you can redistribute it and/or modify it under the terms of the GNU Lesser General Public License as published by the Free Software Foundation; either version 2.1 of the License, or (at your option) any later version. This library is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more details. You should have received a copy of the GNU Lesser General Public License along with this library; if not, write to the Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA ) annotationsN) Awaitable Coroutine)Any)EventLoopBlocked)_LOADED_SYSTEM_TIMEOUT)millis_to_secondscRUR5(dURS5 gg)z'Set a future to None if it is not done.N)done set_result)futs N/home/sebas/venvs/catt/lib/python3.13/site-packages/zeroconf/_utils/asyncio.py_set_future_none_if_not_doner*s 88:: t cLUHn[U5 M UR5 g)zResolve all futures to None.N)rclear)futuresrs r_resolve_all_futures_to_noner0s$S) MMOrc6# UR5nURU5 UR[U5[U5nUIShvN UR 5 UR U5 gN&!UR 5 UR U5 f=f7f)z/Wait for a future or timeout (in milliseconds).N) create_futureadd call_laterr rcanceldiscard)loop future_settimeoutfuturehandles rwait_for_future_set_or_timeoutr#7s{   !FNN6 __.w79UW] ^F#  6"  6"s0ABA3 A1 A3"B1A33#BBc# [R"5nURU[U5nUIShvN UR5 gN![RaI [ R S:a2[R"5=n(aUR5(aeNof=f!UR5 f=f7f)zWait for a future or timeout.N)r ) asyncioget_running_looprrCancelledErrorsys version_info current_task cancellingr)r!r rr"tasks rwait_future_or_timeoutr.Es  # # %D __W&BF KF     ! !   w &G4H4H4J,JD,JPTP_P_PaPa   sD-CA A A C A AB*'B-)B**B--B??Cc# [R"S5IShvN [S5H=n[R"[ 5 [R "U5sSSS5 s $ [5$NZ!,(df  M\=f7f)zReturn all tasks running.rNr )r&sleeprange contextlibsuppress RuntimeError all_tasksset)r_s r_async_get_all_tasksr8Rsa -- 1X   .$$T*/ . 5L / .s'B A7,B  A9B 9 B B cR# [R"U[S9IShvN gN7f)z6Wait for the event loop thread we started to shutdown.)r N)r&wait_TASK_AWAIT_TIMEOUT) wait_taskss r_wait_for_loop_tasksr=^s ,,z+> ???s '%'c<# UIShvN nUIShvN gNN7f)z-Wait on an awaitable and the task it returns.N)awr-s rawait_awaitablerAcs8D JJ s c[R"X5R[U5[-5$![ R Ra n[UeSnAff=f)a[Run a coroutine with a timeout. The timeout should only be used as a safeguard to prevent the program from blocking forever. The timeout should never be expected to be reached during normal operation. While not expected during normal operations, the function raises `EventLoopBlocked` if the coroutine takes longer to complete than the timeout. N) r&run_coroutine_threadsaferesultr r concurrentr TimeoutErrorr)r@rr exs rrun_coro_with_timeoutrHisY'//9@@ g &)? ?      * *'B&'s47A!AA!c[[R"[U5U5R [ 55nXVs1sHo"R 5(dMUiM sn-nU(a3[R"[U5U5R [5 URUR5 gs snf)z.Wait for pending tasks and stop an event loop.N) r6r&rCr8rD_GET_ALL_TASKS_TIMEOUTrr=_WAIT_FOR_LOOP_TASKS_TIMEOUTcall_soon_threadsafestop)r pending_tasksr-s r shutdown_looprO|s(()=d)CTJQQRhiM}D}t d}DDM(()=m)LdSZZ (  dii( Es B>B>c[R"[5 [R"5sSSS5 $!,(df  g=f)z*Check if an event loop is already running.N)r2r3r4r&r'r?rrr'r's+   \ *'') + * * s : A)rzasyncio.FuturereturnNone)rset[asyncio.Future]rQrR)rasyncio.AbstractEventLooprrSr floatrQrR)r!zasyncio.Future[bool | None]r rUrQrR)rrTrQset[asyncio.Task])r<rVrQrR)r@rrQrR)r@rrrTr rUrQr)rrTrQrR)rQz asyncio.AbstractEventLoop | None) __doc__ __future__rr&concurrent.futuresrEr2r)collections.abcrrtypingr _exceptionsrconstr timer r;rJrKrrr#r.r8r=rArHrOr'r?rrr_s,# 0**#   # # #1D #OT #  #  @  '& )r