Format: application/x-python-code
1 o
2
3 7'h�$ � @ s d dl mZ d dlZd dlZddlmZmZmZ zd dlZW n
4 e e
5 fy+ dZY nw zd dl Z W n e y= dZ Y nw d dd�Z G d d
6 � d
7 �Z
8 G d d � d �ZG d
9 d� d�ZG dd� d�ZG dd� d�ZG dd� d�ZG dd� d�ZG dd� d�ZG dd� d�ZG dd � d �ZdS ) � )� annotationsN� )�ExceptionMapping� PoolTimeout�map_exceptions�return�strc C sp zdd l } W n ty d}Y nw | �� }|dvr td��|dkr*td u r*td��|dkr6td u r6td��|S )Nr �asyncio)r �trioz/Running under an unsupported async environment.zBRunning with asyncio requires installation of 'httpcore[asyncio]'.r
10 z<Running with trio requires installation of 'httpcore[trio]'.)�sniffio� ImportError�current_async_library� RuntimeError�anyior
11 )r � environment� r �OC:\Users\shubh\Videos\agent\nova\Lib\site-packages\httpcore/_synchronization.pyr
12 s" ���r
13 c @ s@ e Zd ZdZddd�Zddd�Zddd �Z
14
15
16 dddd�Zd
17 S )� AsyncLock��
18 This is a standard lock.
19
20 In the sync case `Lock` provides thread locking.
21 In the async case `AsyncLock` provides async locking.
22 r �Nonec C �
23 d| _ d S �N� ��_backend��selfr r r �__init__8 �
24 zAsyncLock.__init__c C �< t � | _| jdkrt�� | _dS | jdkr t�� | _dS dS �z~
25 Detect if we're running under 'asyncio' or 'trio' and create
26 a lock with the correct implementation.
27 r
28 r N)r
29 r r
30 �Lock�
31 _trio_lockr � _anyio_lockr r r r �setup; �
32
33 �zAsyncLock.setupc � sL �| j s| �� | j dkr| j�� I d H | S | j dkr$| j�� I d H | S �Nr
34 r )r r$ r" �acquirer# r r r r �
35 __aenter__F s �
36
37 �zAsyncLock.__aenter__N�exc_type�type[BaseException] | None� exc_value�BaseException | None� traceback�types.TracebackType | Nonec � �6 �| j dkr
38 | j�� d S | j dkr| j�� d S d S r& )r r" �releaser# �r r) r+ r- r r r � __aexit__Q s �
39
40 �zAsyncLock.__aexit__�r r )r r �NNN�r) r* r+ r, r- r. r r )�__name__�
41 __module__� __qualname__�__doc__r r$ r( r2 r r r r r 0 s
42
43
44
45 �r c @ s, e Zd ZdZddd�Z ddd
46 d�ZdS )�AsyncThreadLock��
47 This is a threading-only lock for no-I/O contexts.
48
49 In the sync case `ThreadLock` provides thread locking.
50 In the async case `AsyncThreadLock` is a no-op.
51 r c C � | S �Nr r r r r � __enter__e � zAsyncThreadLock.__enter__Nr) r* r+ r, r- r. r c C � d S r= r r1 r r r �__exit__h � zAsyncThreadLock.__exit__)r r: r4 r5 )r6 r7 r8 r9 r> rA r r r r r: ] s
52 �r: c @ s6 e Zd Zddd�Zddd�Zddd�Zddd d
53 �Zd S )�
54 AsyncEventr r c C r r r r r r r r r r zAsyncEvent.__init__c C r r )r
55 r r
56 �Event� _trio_eventr � _anyio_eventr r r r r$ u r% zAsyncEvent.setupc C sB | j s| �� | j dkr| j�� d S | j dkr | j�� d S d S r& )r r$ rE �setrF r r r r rG � s
57
58 �zAsyncEvent.setN�timeout� float | Nonec � s> �| j s| �� | j dkrXtjti}|d u rtd�n|}t|��. t�|�� | j� � I d H W d � n1 s9w Y W d � d S W d � d S 1 sQw Y d S | j dkr�t
59 ti}t|��. t �|�� | j � � I d H W d � n1 s~w Y W d � d S W d � d S 1 s�w Y d S d S )Nr
60 �infr )
61 r r$ r
62 Z TooSlowErrorr �floatr Z
63 fail_afterrE �wait� TimeoutErrorr rF )r rH Z trio_exc_mapZtimeout_or_infZ
64 anyio_exc_mapr r r rL � s. �
65
66
67 ��"�
68
69 ��"��zAsyncEvent.waitr3 r= �rH rI r r )r6 r7 r8 r r$ rG rL r r r r rC q s
70
71
72
73 rC c @ s4 e Zd Zddd�Zddd�Zdd d
74 �Zdd d �Zd
75 S )�AsyncSemaphore�bound�intr r c C s || _ d| _d S r )�_boundr �r rP r r r r � s
76 zAsyncSemaphore.__init__c C sP t � | _| jdkrtj| j| jd�| _dS | jdkr&tj| j| jd�| _dS dS )z�
77 Detect if we're running under 'asyncio' or 'trio' and create
78 a semaphore with the correct implementation.
79 r
80 )�
81 initial_valueZ max_valuer N)r
82 r r
83 � SemaphorerR �_trio_semaphorer �_anyio_semaphorer r r r r$ � s
84 �
85 ��zAsyncSemaphore.setupc � sP �| j s| �� | j dkr| j�� I d H d S | j dkr&| j�� I d H d S d S r& )r r$ rV r' rW r r r r r' � s �
86
87 �zAsyncSemaphore.acquirec � r/ r& )r rV r0 rW r r r r r0 � s �
88
89 �zAsyncSemaphore.releaseN�rP rQ r r r3 )r6 r7 r8 r r$ r' r0 r r r r rO � s
90
91
92
93 rO c @ s2 e Zd Zddd�Zddd�Z dddd�ZdS )�AsyncShieldCancellationr r c C sD t � | _| jdkrtjdd�| _dS | jdkr tjdd�| _dS dS )z�
94 Detect if we're running under 'asyncio' or 'trio' and create
95 a shielded scope with the correct implementation.
96 r
97 T)�shieldr N)r
98 r r
99 Z CancelScope� _trio_shieldr �
100 _anyio_shieldr r r r r � s
101
102 �z AsyncShieldCancellation.__init__c C s0 | j dkr | j�� | S | j dkr| j�� | S r& )r r[ r> r\ r r r r r> � s
103
104
105 �
106 z!AsyncShieldCancellation.__enter__Nr) r* r+ r, r- r. c C s@ | j dkr| j�|||� d S | j dkr | j�|||� d S d S r& )r r[ rA r\ r1 r r r rA � s
107
108
109 �z AsyncShieldCancellation.__exit__r3 )r rY r4 r5 )r6 r7 r8 r r> rA r r r r rY � s
110
111 �rY c @ �6 e Zd ZdZddd�Zddd�Z dddd�ZdS )r! r r r c C � t �� | _d S r= �� threadingr! �_lockr r r r r � � z
112 Lock.__init__c C � | j �� | S r= �ra r' r r r r r> � �
113 zLock.__enter__Nr) r* r+ r, r- r. c C � | j �� d S r= �ra r0 r1 r r r rA � � z
114 Lock.__exit__r3 )r r! r4 r5 �r6 r7 r8 r9 r r> rA r r r r r! � �
115
116 �r! c @ r] )�
117 ThreadLockr; r r c C r^ r= r_ r r r r r rb zThreadLock.__init__c C rc r= rd r r r r r> re zThreadLock.__enter__Nr) r* r+ r, r- r. c C rf r= rg r1 r r r rA rh zThreadLock.__exit__r3 )r rk r4 r5 ri r r r r rk rj rk c @ s, e Zd Zd dd�Zd dd�Zd
118 dd
119 d �ZdS )rD r r c C r^ r= )r` rD �_eventr r r r r rb zEvent.__init__c C rf r= )rl rG r r r r rG rb z Event.setNrH rI c C s( |t d�krd }| jj|d�st� �d S )NrJ )rH )rK rl rL r )r rH r r r rL s
120 �z
121 Event.waitr3 r= rN )r6 r7 r8 r rG rL r r r r rD s
122
123 rD c @ s* e Zd Zd dd�Zd
124 dd�Zd
125 d d
126 �Zd S )rU rP rQ r r c C s t j|d�| _d S )N)�value)r` rU �
127 _semaphorerS r r r r ' s zSemaphore.__init__c C rf r= )rn r' r r r r r' * rb zSemaphore.acquirec C rf r= )rn r0 r r r r r0 - rb zSemaphore.releaseNrX r3 )r6 r7 r8 r r' r0 r r r r rU & s
128
129 rU c @ s( e Zd Zddd�Z ddd d
130 �ZdS )�ShieldCancellationr c C r< r= r r r r r r> 5 r? z ShieldCancellation.__enter__Nr) r* r+ r, r- r. r c C r@ r= r r1 r r r rA 8 rB zShieldCancellation.__exit__)r ro r4 r5 )r6 r7 r8 r> rA r r r r ro 1 s
131 �ro )r r )�
132 __future__r r` �types� _exceptionsr r r r
133 r �NotImplementedErrorr r
134 r r: rC rO rY r! rk rD rU ro r r r r �<module> s2 � �
135 -)$*