a h$@s6UddlmZddlZddlZddlmZmZmZddlm 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%dddddZ&e ddddddZ'ddd d!d"Z(ej)d#d$ddd%d&d'd(Z*ej)d#d)ddddd*d+d,Z+ej)d#d)dd-d.d/d0Z,ej-d1ed2ddd3d4d5Z.ej-ddd6d7d8Z/ej-ddd6d9d:Z0Gd;d<d<Z1ej-d=d>dd.wrapperr:r:r8r8)rCrr Z fixturenamesargnames)r7r8rDZoriginal_argnamer#rBr$pytest_fixture_setupJs( rH)Ztryfirst) collectornameobjrcCsj|||rft|dr|jjn|}t|rf|d}t|dd}|sVtdd|Drftj d|dS)N hypothesisanyioZ pytestmarkr#css|]}|jdkVqdS)rMN)rJ).0markerr#r#r$ z,pytest_pycollect_makeitem..r:) ZistestfunctionhasattrrL inner_testr Zget_closest_markergetattranypytestmarkZ usefixtures)rIrJrKZ inner_funcrOZ own_markersr#r#r$pytest_pycollect_makeitem}s   rXz bool | None) pyfuncitemrc s(dddfdd }|jd}|r$t|\t|jdrn|jjjj|jkrjtrj||jj_dSt|jr$|jfdd |j j D}t n}z| |j|WnJt y}z2t|D]}t|tttfr||q̂WYd}~n d}~00Wdn1s0Yd SdS) Nr r3)r;rcs:t}||Wdn1s,0YdSN)r2run_test)r;rA)r&r' original_funcr#r$run_with_hypothesiss z/pytest_pyfunc_call..run_with_hypothesisr:rLcsi|]}||qSr#r#)rNarg)funcargsr#r$ rQz&pytest_pyfunc_call..T)r_r*r%rRrKrLrS __qualname__r Z _fixtureinforGr2r[rrrrKeyboardInterrupt SystemExit)rYr]rZtestargsrAZexcgrpexcr#)r&r'r_r\r$pytest_pyfunc_calls.         8remodule)scopeparams)r8rcCs|jSrZ)paramrFr#r#r$r:sr:)r:rcCst|tr|S|dSdS)NrrrrEr#r#r$anyio_backend_names rkcCst|triS|dSdSr(rjrEr#r#r$anyio_backend_optionss rlc@sDeZdZdZdddddZedddd Zdd d d ddZd S)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. zsocket.SocketKindr3)kindrcCs||_tt|_dSrZ)_kindr+int _generated)selfrnr#r#r$__init__szFreePortFactory.__init__rcCs|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 )ro)rrr#r#r$rnszFreePortFactory.kindNzsocket.AddressFamily | Nonerp)familyrc Cs|dur|g}ntjg}tjr*|tjd}t}|D]f}|t||j}|tjkr`dnd}z|||fWnt yYqYn0|s:| d}q:||j vr|j ||WdSWdq*1s0Yq*dS)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_ipv6appendAF_INET6rr.robindOSError getsocknamerqadd)rrruZfamiliesportstacksockaddrr#r#r$__call__s&     zFreePortFactory.__call__)N)__name__ __module__ra__doc__rspropertyrnrr#r#r#r$rms  rmsession)rgrtcCs ttjSrZ)rmrv SOCK_STREAMr#r#r#r$free_tcp_port_factorysrcCs ttjSrZ)rmrv SOCK_DGRAMr#r#r#r$free_udp_port_factorysrzCallable[[], int]rp)rrcCs|SrZr#)rr#r#r$ free_tcp_port sr)rrcCs|SrZr#)rr#r#r$ free_udp_portsr)6 __future__rrvsyscollections.abcrrr contextlibrrinspectrr r typingr r rVr)Z_pytest.fixturesr Z_pytest.outcomesrZ_core._eventlooprrZ_core._exceptionsrabcr version_infoZexceptiongrouprr__annotations__rr/r%r2r6ZhookimplrHrXreZfixturer:rkrlrmrrrrr#r#r#r$sV          2  $=