File: //usr/local/CyberCP/lib64/python3.10/site-packages/anyio/__pycache__/pytest_plugin.cpython-310.pyc
o
�h�$ � @ s� U d dl mZ d dlZd dlZd dlmZmZmZ d dlm Z m
Z
d dl m Z m
Z
mZ d dlmZmZ d dlZd dlZd dlmZ d dlmZ d d
lmZmZ d d lm Z d d l m Z ej d
k rfd dl m!Z! da"de#d< da$de#d< d a%dLdd�Z&e
dMd d ��Z'dNd#d$�Z(ej)d%d&�dOd*d+��Z*ej)d%d,�dPd0d1��Z+ej)d%d,�dQd4d5��Z,ej-d6e� d7�dRd8d9��Z.ej-dSd:d;��Z/ej-dTd<d=��Z0G d>d?� d?�Z1ej-d@dA�dUdBdC��Z2ej-d@dA�dUdDdE��Z3ej-dVdHdI��Z4ej-dWdJdK��Z5dS )X� )� annotationsN)�Callable� Generator�Iterator)� ExitStack�contextmanager)�isasyncgenfunction�iscoroutinefunction�ismethod)�Any�cast)�
SubRequest)�Exit� )�get_all_backends�get_async_backend)�iterate_exceptions)�
TestRunner)� � )�ExceptionGroupzTestRunner | None�_current_runnerzExitStack | None�
_runner_stack�backend�object�return�tuple[str, dict[str, Any]]c C sf t | t�r | i fS t | t�r/t| �dkr/t | d t�r/t | d t�r/ttttttf f | �S td��)N� r r z@anyio_backend must be either a string or tuple of (string, dict))�
isinstance�str�tuple�len�dictr r � TypeError)r � r$ �F/usr/local/CyberCP/lib/python3.10/site-packages/anyio/pytest_plugin.py�extract_backend_and_options s
r& � backend_namer �backend_options�dict[str, Any]�Iterator[TestRunner]c c s� � t d u r.t| �}t� atj�d �d u r"tj�| �}t�tjj |� |p%i }t�
|� |��a t d7 a z t V W t d8 a t sMtd usCJ �t�
� d aa d S d S t d8 a t sctd us[J �t�
� d aa w �Nr )r r r r �sniffio�current_async_library_cvar�get�set�callback�reset�
enter_context�create_test_runner�_runner_leases�close)r' r( �asynclib�tokenr$ r$ r% �
get_runner% s2 � � ��
r8 �configr �Nonec C s | � dd� d S )N�markerszManyio: mark the (coroutine function) test to be run asynchronously via anyio.)�addinivalue_line)r9 r$ r$ r% �pytest_configureC s �r= T)� hookwrapper�
fixturedef�request�Generator[Any]c # s� � d � ��fdd � }| j � t� �st� �rNd|jv rN|| _ | j}d| jv �s.| jd
7 _d| jv �s<| jd 7 _z
d V W � | _ || _S � | _ || _w d V S )
N�argsr �
anyio_backendr@ r
�kwargsr c ? s� � |j rt� �rt� j�t|j �u r� j�|j �}n� }t| �\}}�r(| |d< �r.||d< t||��&}t|�rB|� ||�E d H n|�
||�V W d � d S W d � d S 1 s\w Y d S )NrC r@ ) �instancer
�type�__self__�__func__�__get__r& r8 r �run_asyncgen_fixture� run_fixture)rC r@ rB rD �
local_funcr' r( �runner��func�has_backend_arg�has_request_argr$ r% �wrapperL s( ��� �"�z%pytest_fixture_setup.<locals>.wrapper�rC �r@ )
rB r rC r r@ r
rD r r r )rO r r � fixturenames�argnames)r? r@ rR �original_argnamer$ rN r% �pytest_fixture_setupJ s$ �
�rX )�tryfirst� collector�name�objc C sv | � ||�r5t|d�r|jjn|}t|�r7| �d�}t|dd�}|s+tdd� |D ��r9tj �
d�|� d S d S d S d S )N�
hypothesis�anyio�
pytestmarkr$ c s s � | ]}|j d kV qdS )r^ N)r[ )�.0�markerr$ r$ r% � <genexpr>� s � z,pytest_pycollect_makeitem.<locals>.<genexpr>rC ) �istestfunction�hasattrr] �
inner_testr �get_closest_marker�getattr�any�pytest�mark� usefixtures)rZ r[ r\ �
inner_funcra � own_markersr$ r$ r% �pytest_pycollect_makeitem} s
�rn �
pyfuncitem� bool | Nonec s d � ��fdd� }| j �d�}|r�t|�\� �t| jd�r3| jjj��j|jkr1t��r1|| jj_d S t| j�r�| j ��fd d
�| j j
D �}t � ���2}z |� | j|� W n t
yt } zt|�D ]
}t|tttf�rn||�qa� d }~ww W d � d S 1 s�w Y d S d S )
NrD r r r: c s< t � ���}|��| � W d � d S 1 sw Y d S �N)r8 �run_test)rD rM )r' r( �
original_funcr$ r% �run_with_hypothesis� s "�z/pytest_pyfunc_call.<locals>.run_with_hypothesisrC r] c s i | ]}|� | �qS r$ r$ )r` �arg)�funcargsr$ r% �
<dictcomp>� s z&pytest_pyfunc_call.<locals>.<dictcomp>T)rD r r r: )rv r. r& rd r\ r] re � __qualname__r � _fixtureinforV r8 rr r r r r �KeyboardInterrupt�
SystemExit)ro rt r �testargsrM �excgrp�excr$ )r' r( rv rs r% �pytest_pyfunc_call� s<
����
�
�
r �module)�scope�paramsc C � | j S rq )�paramrT r$ r$ r% rC � � rC c C s t | t�r| S | d S )Nr �r r rS r$ r$ r% �anyio_backend_name� �
r� c C s t | t�ri S | d S r+ r� rS r$ r$ r% �anyio_backend_options� r� r� c @ s4 e Zd ZdZddd�Zeddd ��Zdddd�Zd
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.
�kind�socket.SocketKindr r: c C s || _ tt � | _d S rq )�_kindr/ �int�
_generated)�selfr� r$ r$ r% �__init__� s zFreePortFactory.__init__c C r� )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� )r� r$ r$ r% r� � s zFreePortFactory.kindN�family�socket.AddressFamily | Noner� c
C s� |dur|g}n
t jg}t jr|�t j� d}t� �P}|D ]1}|�t � || j��}|t jkr1dnd}z |�||f� W n
t yF Y n w |sO|�
� d }q || j vrd| j � |� |W d � S W d � n1 snw Y q)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
NTr z::1z 127.0.0.1r )
�socket�AF_INET�has_ipv6�append�AF_INET6r r2 r� �bind�OSError� getsocknamer� �add)r� r� �families�port�stack�sock�addrr$ r$ r% �__call__� s4 � �
�� �zFreePortFactory.__call__)r� r� r r: )r r� rq )r� r� r r� )�__name__�
__module__rx �__doc__r� �propertyr� r� r$ r$ r$ r% r� � s
r� �session)r� c C �
t tj�S rq )r� r� � SOCK_STREAMr$ r$ r$ r% �free_tcp_port_factory� �
r� c C r� rq )r� r� �
SOCK_DGRAMr$ r$ r$ r% �free_udp_port_factory r� r� �Callable[[], int]r� c C � | � S rq r$ )r� r$ r$ r% �
free_tcp_port r� r� c C r� rq r$ )r� r$ r$ r% �
free_udp_port r� r� )r r r r )r' r r( r) r r* )r9 r r r: )r? r r@ r r rA )rZ r r[ r r\ r r r: )ro r r rp )r@ r r r )rC r r r )rC r r r) )r r� )r� r� r r� )r� r� r r� )6�
__future__r r� �sys�collections.abcr r r �
contextlibr r �inspectr r r
�typingr r ri r, �_pytest.fixturesr
�_pytest.outcomesr �_core._eventloopr r �_core._exceptionsr �abcr � version_info�exceptiongroupr r �__annotations__r r4 r& r8 r= �hookimplrX rn r �fixturerC r� r� r� r� r� r� r� r$ r$ r$ r% �<module> sX
2
$
=