Mh$UddlmZddlZddlZddlmZmZmZddlm Z m Z ddl m Z m Z mZddlmZmZddlZddlZddlmZddlmZd d lmZmZd d lmZd d lmZejd krddl m!Z!da"de#d<da$de#d<da%dBdZ&e dCdZ'dDd!Z(ej)d"#dEd'Z*ej)d"(dFd,Z+ej)d"(dGd/Z,ej-d0e1dHd2Z.ej-dId4Z/ej-dJd5Z0Gd6d7Z1ej-d89dKd:Z2ej-d89dKd;Z3ej-dLd?Z4ej-dMdAZ5dS)N) annotationsN)Callable GeneratorIterator) ExitStackcontextmanager)isasyncgenfunctioniscoroutinefunctionismethod)Anycast) SubRequest)Exit)get_all_backendsget_async_backend)iterate_exceptions) TestRunner) )ExceptionGroupzTestRunner | None_current_runnerzExitStack | None _runner_stackbackendobjectreturntuple[str, dict[str, Any]]ct|tr|ifSt|trt|dkrot|dtrTt|dtr9t ttttt ff|Std)Nrrz@anyio_backend must be either a string or tuple of (string, dict)) isinstancestrtuplelendictr r TypeError)rs S/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/anyio/pytest_plugin.pyextract_backend_and_optionsr's'3={ GU # #=G (9(9 gaj# & & =:gaj$+G+G =c4S>12G<< < V W WW backend_namer!backend_optionsdict[str, Any]Iterator[TestRunner]c#Ktt|}tatjdItj|}ttjj ||pi}t | |atdz a tVtdza ts(tJt dxaadSdS#tdza ts&tJt dxaawxYwNr)rrrrsniffiocurrent_async_library_cvargetsetcallbackreset enter_contextcreate_test_runner_runner_leasesclose)r)r*asynclibtokens r& get_runnerr;%sM $\22!  - 1 1$ 7 7 ?6::<HHE  " "7#E#KU S S S)/R'55  ' ' 8 8  aN3! 3 ,,,    ! ! !.2 2MOOO 3 3 ! 3 ,,,    ! ! !.2 2MO 2 2 2 2s D9Econfigr Nonec2|dddS)NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.)addinivalue_line)r<s r&pytest_configurerACs* Wr(T) hookwrapper fixturedefrequestGenerator[Any]c#TKd fd }|jtstrsd|jvrj||_|j}d|jvxs|xjd z c_d|jvxs|xjd z c_ dV|_||_S#|_||_wxYwdVS) Nargsr anyio_backendrDrkwargsrc?K|jrWtrHtjt|jur j|j}n}t |\}} r||d< r||d<t||5}t|r| ||Ed{Vn| ||VddddS#1swxYwYdS)NrHrD) instancer type__self____func____get__r'r;r run_asyncgen_fixture run_fixture) rHrDrGrI local_funcr)r*runnerfunchas_backend_arghas_request_args r&wrapperz%pytest_fixture_setup..wrapperLsa    T]##tG,<'='===..w/?@@JJJ(CM(R(R% o  4&3F? #  ( 'F9   o 6 6 =&!*-- =!66z6JJJJJJJJJJ((V<<<<<  = = = = = = = = = = = = = = = = = =sAC&&C*-C*rHrD) rGr rHr rDrrIr rr )rTr r fixturenamesargnames)rCrDrWoriginal_argnamerTrUrVs @@@r&pytest_fixture_setupr]Js========8 ?D$7#6t#<#<7 g2 2 2%JO)2 '6*:M'MMO :##'99##'0J4G'GGO 4##|3## 7"& &6 ###' &6 #6666 EENs BB#)tryfirst collectornameobjch|||rt|dr |jjn|}t |rl|d}t |dd}|std|Dr-tj d|dSdSdSdS)N hypothesisanyio pytestmarkc3,K|]}|jdkVdS)rdN)r`).0markers r& z,pytest_pycollect_makeitem..s)NNV[G3NNNNNNr(rH) istestfunctionhasattrrc inner_testr get_closest_markergetattranypytestmark usefixtures)r_r`ra inner_funcri own_markerss r&pytest_pycollect_makeitemrv}sT**>29#|2L2LUS^..RU z * * >11'::F!#|R88K >NN+NNNNN > ''88===== >> > > > >r( pyfuncitem bool | Nonec  d  fd }|jd}|r/t|\t|jdrC|jjj j|jkr t r||jj_dSt|jr|j fd|j j D}t5} | |j|nJ#t$r=}t|D]'}t|t t"t$fr||(d}~wwxYw dddn #1swxYwYd SdS) NrIr rr=ct5}||ddddS#1swxYwYdSN)r;run_test)rIrSr)r* original_funcs r&run_with_hypothesisz/pytest_pyfunc_call..run_with_hypothesiss  o 6 6 3& OOM6 2 2 2 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3 3s 6::rHrcc"i|] }|| Srfrf)rhargfuncargss r& z&pytest_pyfunc_call..sWWWsXc]WWWr(T)rIr rr=)rr1r'rlrarcrm __qualname__r _fixtureinfor[r;r|rrr rKeyboardInterrupt SystemExit) rwr~rtestargsrSexcgrpexcr)r*rr}s @@@@r&pytest_pyfunc_callrs33333333!%%o66G(CG(L(L% o :>< 0 0 &N5@M)-@-MMM&}55O;NJN-84 z~ . . !*HWWWWj6M6VWWWHL/:: fOOJNH====%1&9922%cD2CZ+PQQ2"%612 >               4 4s6E C54E 5 D<?8D77D<<E  EEmodule)scopeparamsc|jSr{)paramrYs r&rHrHs =r(rHc@t|tr|S|dS)Nrr r!rXs r&anyio_backend_namers%-%% Qr(c@t|triS|dSr.rrXs r&anyio_backend_optionsrs$-%%  Qr(c<eZdZdZd dZeddZddd ZdS)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. kindsocket.SocketKindrr=cP||_tt|_dSr{)_kindr2int _generated)selfrs r&__init__zFreePortFactory.__init__s 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.kinds zr(Nfamilysocket.AddressFamily | NonercL||g}n8tjg}tjr|tj d}t 5}|D]}|tj||j}|tjkrdnd} |||fn#t$rYnRwxYw|s| d}||j vr(|j ||cdddSdddn #1swxYwY)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 NTrz::1z 127.0.0.1r) socketAF_INEThas_ipv6appendAF_INET6rr5rbindOSError getsocknameradd)rrfamiliesportstacksockaddrs r&__call__zFreePortFactory.__call__s  xHH'H 1000 $D $& $ $F ..v}VTZ/P/PQQD$*fo$=$=55;D 4,////" 5#//11!44?22++D111# $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s8ADB/.D/ B=9D<B==ADD!D)rrrr=)rrr{)rrrr)__name__ __module__r__doc__rpropertyrrrfr(r&rrsk  %%%%X$$$$$$$r(rsession)rc4ttjSr{)rr SOCK_STREAMrfr(r&free_tcp_port_factoryrs 6- . ..r(c4ttjSr{)rr SOCK_DGRAMrfr(r&free_udp_port_factoryrs 6, - --r(rCallable[[], int]rc|Sr{rf)rs r& free_tcp_portr  " ""r(rc|Sr{rf)rs r& free_udp_portrrr()rrrr)r)r!r*r+rr,)r<r rr=)rCr rDr rrE)r_r r`r rar rr=)rwr rrx)rDr rr )rHr rr!)rHr rr+)rr)rrrr)rrrr)6 __future__rrsyscollections.abcrrr contextlibrrinspectr r r typingr r rqr/_pytest.fixturesr_pytest.outcomesr_core._eventlooprr_core._exceptionsrabcr version_infoexceptiongrouprr__annotations__rr7r'r;rAhookimplr]rvrfixturerHrrrrrrrrfr(r&rs""""""" 999999999900000000EEEEEEEEEE ''''''!!!!!!AAAAAAAA111111g------%)))))"& &&&&XXXX3333:T"""///#"/d$>>> >$!!! !Hh'7'7'9'9:::;:        :$:$:$:$:$:$:$:$zi   ///! /i   ...! .##########r(