|; idZddlmZddlZddlZddlZddlZddlm Z m Z ddl m Z ddl mZddlmZd d lmZd Zd Zd Zdd Zdd Z ddZddZddZddZddZddZddZddZy) 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_secondscH|js|jdyy)z'Set a future to None if it is not done.N)done set_result)futs J/home/ubuntu/myenv/lib/python3.12/site-packages/zeroconf/_utils/asyncio.py_set_future_none_if_not_doner*s 88: t cH|D] }t||jy)zResolve all futures to None.N)rclear)futuresrs r_resolve_all_futures_to_noner0s"*$S)* MMOrc6K|j}|j||jt|t|} |d{|j |j |y7&#|j |j |wxYww)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#BBclKtj}|j|t|} |d{|jy7#tj$r=t j dk\r'tjx}r|jrYbwxYw#|jwxYww)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_Pa   sD,B4A A A B4 A A BBBBB11B4cKtjdd{tdD];}tjt 5tj |cdddcStS7W#1swYSxYww)zReturn all tasks running.rNr )r&sleeprange contextlibsuppress RuntimeError all_tasksset)r_s r_async_get_all_tasksr8Rsq -- 1X+   . +$$T* + ++ 5L  + +s'BA3+BA5B5A> :BcVKtj|td{y7w)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<K|d{}|d{y77w)z-Wait on an awaitable and the task it returns.N)awr-s rawait_awaitablerAcs8D JJ s c tj||jt|tzS#t j j$r }t|d}~wwxYw)awRun 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_timeoutrHis['//D9@@ g &)? ?      * *'B&'s47A AA cjttjt||j t }||Dchc]}|j s|c}z}|r2tjt||j t|j|jycc}w)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}Dt dDDM(()=m)LdSZZ (  dii( Es B0B0ctjt5tjcdddS#1swYyxYw)z*Check if an event loop is already running.N)r2r3r4r&r'r?rrr'r's4   \ **'')*** s 8A)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