Ej8UddlmZddlZddlZddlZddlmZmZmZddl m Z m Z ddl m Z mZmZddlmZmZmZddlZddlmZmZddlmZdd lmZd d lmZd d lmZm Z m!Z!m"Z"d d l#m$Z$erd dl%m&Z&ejNdkrddl(m)Z)erddl*m+Z,n ddl*m,Z,da.de/d<da0de/d<da1d0dZ2e d1dZ3d2dZ4d3dZ5d4dZ6ejndd5dZ8ejnd d6d Z9d7d"Z:ejndd8d#Z;ejxd$e%d9d&Z=ejxd:d'Z>ejxd;d(Z?Gd)d*Z@ejxd!+dd/ZDy#e-$r ddl*m+Z,YBwxYw)?) annotationsN)Callable GeneratorIterator) ExitStackcontextmanager)isasyncgenfunctioniscoroutinefunctionismethod) TYPE_CHECKINGAnycast)FuncFixtureInfo SubRequest)Exit)Scope)get_available_backends)current_async_libraryget_async_backendreset_current_async_libraryset_current_async_library)iterate_exceptions) TestRunner) )ExceptionGroup) CallSpec2)CallSpeczTestRunner | None_current_runnerzExitStack | None _runner_stackct|tr|ifSt|tr^t|dk(rPt|dtr=t|dtr*t ttttt ff|Std)Nrrz@anyio_backend must be either a string or tuple of (string, dict)) isinstancestrtuplelendictrr TypeError)backends Q/root/workspace/ytshorts/venv/lib/python3.12/site-packages/anyio/pytest_plugin.pyextract_backend_and_optionsr,/sq'3{ GU #G (9 gaj# &:gaj$+Gc4S>12G< < V WWc#Ktnt|}tat %t |}tj t||xsi}tj|j|atdz a ttdza ts!tJtjdxaayy#tdza ts!tJtjdxaawwxYwwNr) r rrr!rrcallbackr enter_contextcreate_test_runner_runner_leasesclose) backend_namebackend_optionsasynclibtokens r+ get_runnerr99s $\2! " *.l;E  " "#> F)/R'55  ' ' 8 aN3! , ,,    !.2 2MO ! , ,,    !.2 2MOsA>C/B: 1C/:2C,,C/cx|jd}|jddd|jddddy) Nanyio anyio_modestrictz-AnyIO plugin mode (either "strict" or "auto"))defaulthelpz --anyio-modez 'auto' - All async test functions will be handled by AnyIO pytest plugin 'strict' - Disabling autoprocessing(useful when anyio tests need to coexist with other async test plugins) )r>destr?)getgroupaddini addoption)parsergroups r+pytest_addoptionrFWsK OOG $E MM <  OO   r-cZ|j|ddk(xs|j|dk(S)N)r>auto) getoptiongetini)configmodes r+ _is_auto_moderMjs3t,6W&--:MQW:Wr-c|jddt|drO|jjdr3t|dr&|j t j ddyyyy)NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.r<asyncio asyncio_modezlAnyIO auto mode has been enabled together with pytest-asyncio auto mode. This may cause unexpected behavior.r)addinivalue_linerM pluginmanager has_pluginissue_config_time_warningpytestPytestConfigWarning)rKs r+pytest_configurerXpsu W fl+  + +I 6 &. 1((  & &<     2 7 ,r-T) hookwrapperc#Kdfd }|jts tr~d|jvrp||_|j}d|jvxs|xjdz c_d|jvxs|xjdz c_ d|_||_SdS#|_||_wxYww)N anyio_backendrequestc;K|jr[trPtjt|jur&jj |j}n}t |\}}r||d< r||d<t||5}|jr tdt|r|j||Ed{n|j||dddy7"#1swYyxYww)Nr[r\zCannot schedule a coroutine in the test runner while another is already running; likely caused by request.getfixturevalue() on an async fixture.) instancer type__self____func____get__r,r9 is_running RuntimeErrorr run_asyncgen_fixture run_fixture) r[r\kwargs local_funcr5r6runnerfunchas_backend_arghas_request_args r+wrapperz%pytest_fixture_setup..wrappers   T]]#tG,<,<'==..w/?/?@JJ(CM(R% o &3F? #  'F9   o 6 =&  ""V "*-!66z6JJJ((V<z,pytest_pycollect_makeitem..sH&v{{g-Hsr[) istestfunctionhasattrrx inner_testr rMrKget_closest_markergetattranyrVmark usefixtures) collectorr|obj inner_funcanyio_auto_moder~ own_markerss r+pytest_pycollect_makeitemrsT*29#|2LS^^..RU z *+I,<,|j: } |j-| +||j||d zycc}w#t$rt!}YpwxYw) Nr;r[ _arg2scope)paramsindicesr_idlistmarks)funcargsrr arg2scopeidlistr)rr initialnames names_closurename2fixturedefs[])r|callspeccallobj fixtureinfokeywords originalnamer) reversedlist enumerateitemsr$rVFunctionr functionrrq dataclassesfieldsrr|r)setrrModule _fixtureinforappendrrrrr from_parentparentrrr) riitem new_itemsf cs_fields param_indexr*rfinew_names_closurenew_fixtureinfonew_items r+pytest_collection_finishrs D7==!9:;614 tV__ -#DMM2''0<t'8'88I "-8-?-?-IJQVVJ J)22H2J(K' +$ W9,' /9!0+ >$3U\\#B!(   H (!# /9!0+ >#2ELL"A 'y  H&&$()9)9$:!"*;;%,,_="1[[!#"3%'%8%8 # "??66KK --.ay:% HH /!]]!%!2!27  *O' +R(1GMM!a!e $m61K "E  "s$HH 2H HH%$H%c  d fd }|jjd}|rt|\ t|jdr`|jj j j|jk7r&t r||jj _yt|jrg|j}|jjDcic]}||| }}t 5} |j|j| dddyycc}w#t$r4}t|D] }t|t t"t$fs||d}~wwxYw#1swYyxYw)Nclt5}|j|dddy#1swYyxYwN)r9run_test)rgrir5r6 original_funcs r+run_with_hypothesisz/pytest_pyfunc_call..run_with_hypothesiss2  o 6 3& OOM6 2 3 3 3s*3r[rxT)rgr rpNone)rgetr,rrrxr __qualname__r rrrr9rrrr$rKeyboardInterrupt SystemExit) pyfuncitemrr*rargtestargsriexcgrpexcr5r6rs @@@r+pytest_pyfunc_callr sQ3!!%%o6G(CG(L% o :>>< 0&NN55@@M))-@-M-MM&}5;NJNN--8 z~~ .!**H6@6M6M6V6VWsXc]*WHWL/: fOOJNNH=  X&1&92%cD2CZ+PQ"%612  s6' D+E0D00 E-9)E(#E((E--E00E9module)scoperc|jSr)paramros r+r[r[1s ==r-c0t|tr|S|dS)Nrr$r%rns r+anyio_backend_namer6s-%Qr-c0t|triS|dSr/rrns r+anyio_backend_optionsr>s-% Qr-c4eZdZdZddZeddZdd dZy) FreePortFactoryaO Manages port generation based on specified socket kind, ensuring no duplicate ports are generated. This class provides functionality for generating available free ports on the system. It is initialized with a specific socket kind and can generate ports for given address families while avoiding reuse of previously generated ports. Users should not instantiate this class directly, but use the ``free_tcp_port_factory`` and ``free_udp_port_factory`` fixtures instead. For simple uses cases, ``free_tcp_port`` and ``free_udp_port`` can be used instead. c>||_tt|_yr)_kindrint _generated)selfkinds r+__init__zFreePortFactory.__init__Ts c(*r-c|jS)z The type of socket connection (e.g., :data:`~socket.SOCK_STREAM` or :data:`~socket.SOCK_DGRAM`) used to bind for checking port availability )r)rs r+rzFreePortFactory.kindXszzr-NcJ||g}n@tjg}tjr|jtj d}t 5}|D]r}|j tj||j}|tjk(rdnd} |j||f|r`|jd}t||jvr&|jj||cdddSddd#t$rYwxYw#1swYxYw)z Return an unbound port for the given address family. :param family: if omitted, both IPv4 and IPv6 addresses will be tried :return: a port number Nrz::1z 127.0.0.1r) socketAF_INEThas_ipv6rAF_INET6rr1rbindOSError getsocknameradd)rfamilyfamiliesportstackfamsockaddrs r+__call__zFreePortFactory.__call__as   xH'H0D $# $C ..v}}S$**/MND$'6??$:5 D 4,/ #//1!4 $4??2++D1# $ $ $#  $ $s7A D!D 4D7?D DDDDD")rsocket.SocketKindrpr)rprr)rzsocket.AddressFamily | Nonerpr)__name__ __module__r__doc__rpropertyrrrzr-r+rrFs% %$r-r)rc4ttjSr)rr SOCK_STREAMrzr-r+free_tcp_port_factoryrs 6-- ..r-c4ttjSr)rr SOCK_DGRAMrzr-r+free_udp_port_factoryrs 6,, --r-c|Srrz)rs r+ free_tcp_portr ""r-c|Srrz)rs r+ free_udp_portrrr-)r*objectrpztuple[str, dict[str, Any]])r5r%r6dict[str, Any]rpzIterator[TestRunner])rDz pytest.Parserrpr)rK pytest.ConfigrLr%rpbool)rKrrpr)rsr r\r rpzGenerator[Any])rzpytest.Module | pytest.Classr|r%rrrpr)rzpytest.Sessionrpr)rr rpz bool | None)r\r rpr )r[r rpr%)r[r rpr)rpr)rCallable[[], int]rpr)rrrpr)E __future__rrrsyscollections.abcrrr contextlibrrinspectr r r typingr r rrV_pytest.fixturesrr_pytest.outcomesr _pytest.scoperr_core._eventlooprrrr_core._exceptionsrabcr version_infoexceptiongroupr_pytest.pythonrr ImportErrorr __annotations__r!r3r,r9rFrMrXhookimplrurrrfixturer[rrrrrrrrzr-r+rs5" 990EE++ 8!$ 2g-49 ,&*")"& &X33(6333:&  &T"9#9x$>+>36>=C> > >"71t$! !Hh'='?@A    :$:$zi /!/i .!.####Y 9889sG GG