o ɂh'@sUddlmZddlZddlmmZddlZddl Z ddl m Z m Z m Z ddlmZmZddlmZmZmZddlmZmZddlZddlZddlmZddlmZd d lmZm Z d d l!m"Z"d d l#m$Z$e j%d krsddl&m'Z'da(de)d<da*de)d<da+dRddZ,edSddZ-dTd#d$Z.dUd'd(Z/ej0d)d*dVd/d0Z1ej0d)d1dWd6d7Z2ej0d)d1dXd:d;Z3ej4dd?Z5ej4dZd@dAZ6ej4d[dBdCZ7GdDdEdEZ8ej4dFdGd\dHdIZ9ej4dFdGd\dJdKZ:ej4d]dNdOZ;ej4d^dPdQZ.wrapperrerc)rer rcr rfr rr )rprr fixturenamesargnames)rbrcrsoriginal_argnamer$ror%pytest_fixture_setup_s$ ry)tryfirst collectorpytest.Module | pytest.ClassnameobjcCs|||r?t|dr|jjn|}t|rA|jddk}|d}t|dd}|s5|s5t dd|DrCt j d |dSdSdSdS) N hypothesisrKrVanyio pytestmarkr$css|]}|jdkVqdS)rN)r}).0markerr$r$r% sz,pytest_pycollect_makeitem..re) istestfunctionhasattrr inner_testr rSrZget_closest_markergetattranyr^mark usefixtures)r{r}r~ inner_funcanyio_auto_moder own_markersr$r$r%pytest_pycollect_makeitems   r pyfuncitem bool | Nonec sd fdd }|jd}|rt|\t|jdr3|jjjj|jkr1tr1||jj_dSt|jr|jfd d |j j D}t 2}z | |j|Wnt yt}zt|D] }t|tttfrn||qad}~wwWdd S1swYd SdS) Nrfr rrJcs<t}||WddS1swYdSN)rGrun_test)rfrn)r'r( original_funcr$r%run_with_hypothesiss "z/pytest_pyfunc_call..run_with_hypothesisrercsi|]}||qSr$r$)rarg)funcargsr$r% sz&pytest_pyfunc_call..T)rfr rrJ)rr1r&rr~rr __qualname__r _fixtureinforwrGrrrrrKeyboardInterrupt SystemExit)rrrtestargsrnexcgrpexcr$)r'r(rrr%pytest_pyfunc_calls<            rmodule)scopeparamscC|jSr)paramrur$r$r%rerecCst|tr|S|dS)Nrrrrtr$r$r%anyio_backend_name rcCst|triS|dS)Nrrrtr$r$r%anyio_backend_optionsrrc@s4eZdZdZdddZeddd ZddddZd 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. kindsocket.SocketKindrrJcCs||_tt|_dSr)_kindr2int _generated)selfrr$r$r%__init__szFreePortFactory.__init__cCr)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)rr$r$r%rszFreePortFactory.kindNfamilysocket.AddressFamily | Nonerc Cs|dur|g}n tjg}tjr|tj d}tP}|D]1}|t||j}|tjkr1dnd}z |||fWn t yFYnw|sO| d}q||j vrd|j ||WdSWdn1snwYq)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)rrfamiliesportstacksockaddrr$r$r%__call__s4     zFreePortFactory.__call__)rrrrJ)rrr)rrrr)__name__ __module__r__doc__rpropertyrrr$r$r$r%rs   rsession)rcC ttjSr)rr SOCK_STREAMr$r$r$r%free_tcp_port_factory rcCrr)rr SOCK_DGRAMr$r$r$r%free_udp_port_factoryrrCallable[[], int]rcC|Srr$)rr$r$r% free_tcp_port#rrcCrrr$)rr$r$r% free_udp_port(rr)rrrr)r'rr(r)rr*)rHrIrrJ)rSrTrrJ)rbr rcr rrd)r{r|r}rr~rrrJ)rr rr)rcr rr )rer rr)rer rr))rr)rrrr)rrrr)= __future__rbuiltinsr:_pytest.assertion.rewrite assertionrewriter8rsyscollections.abcrrr contextlibrrinspectrr r typingr r r^r/_pytest.fixturesr _pytest.outcomesr_core._eventlooprr_core._exceptionsrabcr version_infoexceptiongrouprr__annotations__rr7r&rGrRr`hookimplryrrfixturererrrrrrrr$r$r$r%sZ"              0   $    =