o Xi(@sUddlmZddlZddlZddlmZmZmZddlm Z m Z ddl m Z m Z mZddlmZmZddlZddlmZddlmZd d lmZd d lmZmZmZmZd d lmZd d l m!Z!ej"dkrlddl#m$Z$da%de&d<da'de&d<da(dSddZ)e dTdd Z*dUd$d%Z+dVd(d)Z,ej-d*d+dWd0d1Z.ej-d*d2dXd7d8Z/ej-d*d2dYd;d<Z0ej1d=ed>dZd?d@Z2ej1d[dAdBZ3ej1d\dCdDZ4GdEdFdFZ5ej1dGdHd]dIdJZ6ej1dGdHd]dKdLZ7ej1d^dOdPZ8ej1d_dQdRZ9dS)`) annotationsN)Callable GeneratorIterator) ExitStackcontextmanager)isasyncgenfunctioniscoroutinefunctionismethod)Anycast) SubRequest)Exit)get_available_backends)current_async_libraryget_async_backendreset_current_async_libraryset_current_async_library)iterate_exceptions) TestRunner) )ExceptionGroupzTestRunner | None_current_runnerzExitStack | None _runner_stackbackendobjectreturntuple[str, dict[str, Any]]cCsft|tr |ifSt|tr/t|dkr/t|dtr/t|dtr/ttttttff|Std)Nrrz@anyio_backend must be either a string or tuple of (string, dict)) isinstancestrtuplelendictr r TypeError)rr'J/home/app/Keep/.python/lib/python3.10/site-packages/anyio/pytest_plugin.pyextract_backend_and_options s r) backend_namer"backend_optionsdict[str, Any]Iterator[TestRunner]ccstdur't|}tatdurt|}tt||pi}t| |at d7a ztVWt d8a t sFtdus.wrapperrHrF)rHr rFr rIr rr )rQrr Z fixturenamesargnames)rErFrRZoriginal_argnamer'rPr(pytest_fixture_setupcs$ rV)Ztryfirst collectorpytest.Module | pytest.ClassnameobjcCs|||r?t|dr|jjn|}t|rA|jddk}|d}t|dd}|s5|s5t dd|DrCt j d |dSdSdSdS) N hypothesisr8r@anyioZ pytestmarkr'css|]}|jdkVqdS)r\N)rY).0markerr'r'r( sz,pytest_pycollect_makeitem..rH) Zistestfunctionhasattrr[ inner_testr r=rBZget_closest_markergetattranyrCmarkZ usefixtures)rWrYrZZ inner_funcZanyio_auto_moder^Z own_markersr'r'r(pytest_pycollect_makeitems   re 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) NrIr rr7cs<t}||WddS1swYdSN)r4run_test)rIrO)r*r+ original_funcr'r(run_with_hypothesiss "z/pytest_pyfunc_call..run_with_hypothesisrHr[csi|]}||qSr'r')r]arg)funcargsr'r( sz&pytest_pyfunc_call..T)rIr rr7)rmgetr)r`rZr[ra __qualname__r Z _fixtureinforUr4rirrr!rKeyboardInterrupt SystemExit)rfrkrZtestargsrOZexcgrpexcr')r*r+rmrjr(pytest_pyfunc_calls<            rtmodule)scopeparamscC|jSrh)paramrTr'r'r(rHrHcCst|tr|S|dS)Nrr!r"rSr'r'r(anyio_backend_name r|cCst|triS|dSr.r{rSr'r'r(anyio_backend_optionsr}r~c@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.SocketKindrr7cCs||_tt|_dSrh)_kindsetint _generated)selfrr'r'r(__init__szFreePortFactory.__init__cCrx)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_INET6rr0rbindOSError getsocknameradd)rrZfamiliesportstacksockaddrr'r'r(__call__s4     zFreePortFactory.__call__)rrrr7)rrrh)rrrr)__name__ __module__rp__doc__rpropertyrrr'r'r'r(rs   rsession)rvcC ttjSrh)rr SOCK_STREAMr'r'r'r(free_tcp_port_factory rcCrrh)rr SOCK_DGRAMr'r'r'r(free_udp_port_factory"rrCallable[[], int]rcC|Srhr')rr'r'r( free_tcp_port'rzrcCrrhr')rr'r'r( free_udp_port,rzr)rrrr)r*r"r+r,rr-)r5r6rr7)r=r>rr7)rEr rFr rrG)rWrXrYr"rZrrr7)rfr rrg)rFr rr )rHr rr")rHr rr,)rr)rrrr)rrrr): __future__rrsyscollections.abcrrr contextlibrrinspectrr r typingr r rCZ_pytest.fixturesr Z_pytest.outcomesrrZ_core._eventlooprrrrZ_core._exceptionsrabcr version_infoZexceptiongrouprr__annotations__rr1r)r4r<rDZhookimplrVrertZfixturerHr|r~rrrrrr'r'r'r(sZ                0   $    =