o p i'@sUddlmZddlZddlZddlmZmZmZddlm Z m Z ddl m Z m Z mZddlmZmZddlZddlZddlmZddlmZd d lmZmZd d lmZd d lmZejd krfddl m!Z!da"de#d<da$de#d<da%dRddZ&e dSddZ'dTd#d$Z(dUd'd(Z)ej*d)d*dVd/d0Z+ej*d)d1dWd6d7Z,ej*d)d1dXd:d;Z-ej.dd?Z/ej.dZd@dAZ0ej.d[dBdCZ1GdDdEdEZ2ej.dFdGd\dHdIZ3ej.dFdGd\dJdKZ4ej.d]dNdOZ5ej.d^dPdQZ6dS)_) 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]]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$Z/home/app/PaddleOCR-VL/.venv_paddleocr/lib/python3.10/site-packages/anyio/pytest_plugin.pyextract_backend_and_optionss r& backend_namerbackend_optionsdict[str, Any]Iterator[TestRunner]ccstdur.t|}tatjddur"tj|}ttjj ||p%i}t | |at d7a ztVWt d8a t sMtdusCJt daadSdSt d8a t sctdus[Jt daawNr)rrrrsniffioZcurrent_async_library_cvargetsetcallbackreset enter_contextZcreate_test_runner_runner_leasesclose)r'r(Zasynclibtokenr$r$r% get_runner%s2     r5parser pytest.ParserNonecCs|jddddddS)N anyio_modestrictz-AnyIO plugin mode (either "strict" or "auto")string)defaulthelptype)Zaddini)r6r$r$r%pytest_addoptionCs  r?config pytest.ConfigcCsV|dd|ddkr%|jdr'|ddkr)|tdddSdSdSdS) NmarkerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.r9autoasyncioZ asyncio_modezlAnyIO auto mode has been enabled together with pytest-asyncio auto mode. This may cause unexpected behavior.r)Zaddinivalue_linegetiniZ pluginmanagerZ has_pluginZissue_config_time_warningpytestZPytestConfigWarning)r@r$r$r%pytest_configureLs  rGT)Z hookwrapper fixturedefr requestGenerator[Any]c#sd fdd }|jtstrNd|jvrN||_|j}d|jvs.|jd 7_d|jvs<|jd 7_z dVW|_||_S|_||_wdVS) N anyio_backendr rIr kwargsrc;s|jrtrtjt|jurj|j}n}t|\}}r(||d<r.||d<t||&}t|rB| ||EdHn| ||VWddSWddS1s\wYdS)NrKrI) instancer r>__self____func____get__r&r5rZrun_asyncgen_fixtureZ run_fixture)rKrIrLZ local_funcr'r(runnerfuncZhas_backend_argZhas_request_argr$r%wrapperas(  "z%pytest_fixture_setup..wrapperrKrI)rKr rIr rLr rr )rSrr Z fixturenamesargnames)rHrIrTZoriginal_argnamer$rRr%pytest_fixture_setup_s$ rX)Ztryfirst collectorpytest.Module | pytest.ClassnameobjcCs|||r?t|dr|jjn|}t|rA|jddk}|d}t|dd}|s5|s5t dd|DrCt j d |dSdSdSdS) N hypothesisr9rCanyioZ pytestmarkr$css|]}|jdkVqdS)r^N)r[).0markerr$r$r% sz,pytest_pycollect_makeitem..rK) Zistestfunctionhasattrr] inner_testr r@rEZget_closest_markergetattranyrFmarkZ usefixtures)rYr[r\Z inner_funcZanyio_auto_moder`Z own_markersr$r$r%pytest_pycollect_makeitems   rg 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) NrLr rr8cs<t}||WddS1swYdSN)r5run_test)rLrQ)r'r( original_funcr$r%run_with_hypothesiss "z/pytest_pyfunc_call..run_with_hypothesisrKr]csi|]}||qSr$r$)r_arg)funcargsr$r% sz&pytest_pyfunc_call..T)rLr rr8)ror-r&rbr\r]rc __qualname__r Z _fixtureinforWr5rkrrrrKeyboardInterrupt SystemExit)rhrmrZtestargsrQZexcgrpexcr$)r'r(rorlr%pytest_pyfunc_calls<            rumodule)scopeparamscC|jSrj)paramrVr$r$r%rKrKcCst|tr|S|dS)NrrrrUr$r$r%anyio_backend_name r}cCst|triS|dSr+r|rUr$r$r%anyio_backend_optionsr~rc@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.SocketKindrr8cCs||_tt|_dSrj)_kindr.int _generated)selfrr$r$r%__init__szFreePortFactory.__init__cCry)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_INET6rr1rbindOSError getsocknameradd)rrZfamiliesportstacksockaddrr$r$r%__call__s4     zFreePortFactory.__call__)rrrr8)rrrj)rrrr)__name__ __module__rq__doc__rpropertyrrr$r$r$r%rs   rsession)rwcC ttjSrj)rr SOCK_STREAMr$r$r$r%free_tcp_port_factory rcCrrj)rr SOCK_DGRAMr$r$r$r%free_udp_port_factoryrrCallable[[], int]rcC|Srjr$)rr$r$r% free_tcp_port#r{rcCrrjr$)rr$r$r% free_udp_port(r{r)rrrr)r'rr(r)rr*)r6r7rr8)r@rArr8)rHr rIr rrJ)rYrZr[rr\rrr8)rhr rri)rIr rr )rKr rr)rKr rr))rr)rrrr)rrrr)7 __future__rrsyscollections.abcrrr contextlibrrinspectrr r typingr r rFr,Z_pytest.fixturesr Z_pytest.outcomesrZ_core._eventlooprrZ_core._exceptionsrabcr version_infoZexceptiongrouprr__annotations__rr2r&r5r?rGZhookimplrXrgruZfixturerKr}rrrrrrr$r$r$r%sZ              0   $    =