8jdZddlmZddlZddlZddlZddlZddlm Z m Z ddl m Z ddl mZddlmZd d lmZd Zd Zd Zd*dZd+dZd,dZd-dZd.dZd/d Zd0d#Zd1d&Zd2d'Zd3d)ZdS)4aMulticast 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_secondsfutasyncio.FuturereturnNonec\|s|ddSdS)z'Set a future to None if it is not done.N)done set_result)r s M/home/user/adhan/venv/lib/python3.11/site-packages/zeroconf/_utils/asyncio.py_set_future_none_if_not_doner*s4 88:: tfuturesset[asyncio.Future]cV|D]}t||dS)zResolve all futures to None.N)rclear)rr s r_resolve_all_futures_to_noner0s3**$S)))) MMOOOOOrloopasyncio.AbstractEventLoop future_settimeoutfloatcnK|}|||t|t|} |d{V|||dS#|||wxYw)z/Wait for a future or timeout (in milliseconds).N) create_futureadd call_laterr rcanceldiscard)rrrfuturehandles rwait_for_future_set_or_timeoutr)7s   ! !FNN6 __.w779UW] ^ ^F#  6"""""  6""""s B +B4r'asyncio.Future[bool | None]ctKtj}||t|} |d{VnO#tj$r=t jdkr*tjx}r|rYnwxYw| dS#| wxYw)zWait for a future or timeout.N)r ) asyncioget_running_loopr$rCancelledErrorsys version_info current_task cancellingr%)r'rrr(tasks rwait_future_or_timeoutr5Es  # % %D __W&BF K KF  !  w & &G4H4J4J,JD &PTP_P_PaPa &    s'<B!A BB!BB!!B7set[asyncio.Task]cKtjdd{VtdD]I}tjt 5tj|cdddcS#1swxYwYJtS)zReturn all tasks running.rNr )r-sleeprange contextlibsuppress RuntimeError all_tasksset)r_s r_async_get_all_tasksr@Rs -  1XX++   . . + +$T** + + + + + + + + + + + + + + + + + + + 55LsA**A. 1A. wait_taskscLKtj|td{VdS)z6Wait for the event loop thread we started to shutdown.)rN)r-wait_TASK_AWAIT_TIMEOUT)rAs r_wait_for_loop_tasksrE^s4 ,z+> ? ? ??????????rawrc*K|d{V}|d{VdS)z-Wait on an awaitable and the task it returns.N)rFr4s rawait_awaitablerIcs,888888D JJJJJJJJJrrrc tj||t|tzS#t jj$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)rFrrexs rrun_coro_with_timeoutrPisl'/D99@@ g & &)? ?      *'''B&'sz shutdown_loop..s%DDDt DdDDDrN) r>r-rKr@rL_GET_ALL_TASKS_TIMEOUTrE_WAIT_FOR_LOOP_TASKS_TIMEOUTcall_soon_threadsafestop)r pending_taskss r shutdown_looprZ|s()=d)C)CTJJQQRhiiMDD}DDDDM ()=m)L)LdSSZZ (    di(((((r asyncio.AbstractEventLoop | Nonectjt5tjcdddS#1swxYwYdS)z*Check if an event loop is already running.N)r:r;r<r-r.rHrrr.r.s~  \ * ***'))**************** 4s :>>)r rrr)rrrr)rrrrrr rr)r'r*rr rr)rrrr6)rAr6rr)rFrrr)rFrrrrr rr)rrrr)rr[) __doc__ __future__rr-concurrent.futuresrMr:r0collections.abcrrtypingr _exceptionsrconstr timer rDrUrVrrr)r5r@rErIrPrZr.rHrrres,#""""" 00000000************######   # # # #        @@@@  ''''& ) ) ) )r