| Server IP : 127.0.0.1 / Your IP : 216.73.216.109 Web Server : Apache/2.4.54 (Win64) OpenSSL/1.1.1q PHP/8.1.10 System : Windows NT DESKTOP-E5T4RUN 10.0 build 19045 (Windows 10) AMD64 User : SERVERWEB ( 0) PHP Version : 8.1.10 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : C:/laragon/bin/python/python-3.10/Lib/asyncio/__pycache__/ |
Upload File : |
o
�L�b}� � @ s� d Z ddlZejdkred��ddlZddlZddlZddlZddlZddl Z ddl
Z
ddl Z ddl Z ddl
mZ ddl
mZ ddl
mZ dd l
mZ dd
l
mZ dd l
mZ dd l
mZ dd
l
mZ ddlmZ dZdZdZdZdZ dZ dZ G dd� dej �Z G dd� dej �Z!G dd� de!�Z"G dd � d e!�Z#G d d � d e$�Z%G d d � d ej&�Z'G d!d"� d"ej(�Z)G d#d$� d$�Z*G d%d&� d&ej+�Z,e'Z-G d'd(� d(ej.�Z/G d)d*� d*ej.�Z0e0Z1dS )+z.Selector and proactor event loops for Windows.� N�win32z
win32 only� )�events)�base_subprocess)�futures)�
exceptions)�proactor_events)�selector_events)�tasks)�
windows_utils)�logger)�SelectorEventLoop�ProactorEventLoop� IocpProactor�DefaultEventLoopPolicy� WindowsSelectorEventLoopPolicy� WindowsProactorEventLoopPolicy� �� i� i� g����MbP?g�������?c s` e Zd ZdZdd�� fdd�
Z� fdd�Zdd � Zd� fd
d � Z� fd d
�Z� fdd�Z � Z
S )�_OverlappedFuturez�Subclass of Future which represents an overlapped operation.
Cancelling it will immediately cancel the overlapped operation.
N��loopc s& t � j|d� | jr| jd= || _d S �Nr ���)�super�__init__�_source_traceback�_ov)�self�ovr �� __class__� �.C:\python3.10-64\lib\asyncio\windows_events.pyr 6 s
z_OverlappedFuture.__init__c sH t � �� }| jd ur"| jjrdnd}|�dd|� d| jjd�d�� |S )N�pending� completedr z overlapped=<z, �#x�>)r �
_repr_infor r# �insert�address�r �info�stater r! r" r' < s
z _OverlappedFuture._repr_infoc
C st | j d u rd S z| j �� W n& ty4 } zd|| d�}| jr$| j|d< | j�|� W Y d }~nd }~ww d | _ d S )Nz&Cancelling an overlapped future failed��message� exception�future�source_traceback)r �cancel�OSErrorr �_loop�call_exception_handler)r �exc�contextr! r! r" �_cancel_overlappedC s
�
��
z$_OverlappedFuture._cancel_overlappedc � | � � t� j|d�S �N)�msg)r8 r r2 �r r; r r! r" r2 S � z_OverlappedFuture.cancelc s t � �|� | �� d S �N)r �
set_exceptionr8 �r r/ r r! r" r? W s z _OverlappedFuture.set_exceptionc s t � �|� d | _d S r> )r �
set_resultr �r �resultr r! r" rA [ s
z _OverlappedFuture.set_resultr> ) �__name__�
__module__� __qualname__�__doc__r r' r8 r2 r? rA �
__classcell__r! r! r r" r 0 s r c sp e Zd ZdZdd�� fdd�
Zdd� Z� fdd �Zd
d � Zd d
� Zd� fdd� Z � fdd�Z
� fdd�Z � Z S )�_BaseWaitHandleFuturez2Subclass of Future which represents a wait handle.Nr c s8 t � j|d� | jr| jd= || _|| _|| _d| _d S )Nr r T)r r r r �_handle� _wait_handle� _registered)r r �handle� wait_handler r r! r" r c s
z _BaseWaitHandleFuture.__init__c C s t �| jd�t jkS �Nr )�_winapi�WaitForSingleObjectrJ �
WAIT_OBJECT_0�r r! r! r" �_pollq s �z_BaseWaitHandleFuture._pollc sd t � �� }|�d| jd��� | jd ur!| �� rdnd}|�|� | jd ur0|�d| jd��� |S )Nzhandle=r% �signaledZwaitingz wait_handle=)r r' �appendrJ rT rK r* r r! r" r' v s
z _BaseWaitHandleFuture._repr_infoc C s
d | _ d S r> )r �r �futr! r! r" �_unregister_wait_cb� s
z)_BaseWaitHandleFuture._unregister_wait_cbc
C s� | j sd S d| _ | j}d | _zt�|� W n3 tyH } z'|jtjkr>d|| d�}| jr1| j|d< | j� |� W Y d }~d S W Y d }~nd }~ww | �
d � d S �NFz$Failed to unregister the wait handler- r1 ) rL rK � _overlappedZUnregisterWaitr3 �winerror�ERROR_IO_PENDINGr r4 r5 rY �r rN r6 r7 r! r! r" �_unregister_wait� s* �
���
z&_BaseWaitHandleFuture._unregister_waitc r9 r: )r_ r r2 r< r r! r" r2 � r= z _BaseWaitHandleFuture.cancelc � | � � t� �|� d S r> )r_ r r? r@ r r! r" r? � � z#_BaseWaitHandleFuture.set_exceptionc r` r> )r_ r rA rB r r! r" rA � ra z _BaseWaitHandleFuture.set_resultr> )
rD rE rF rG r rT r' rY r_ r2 r? rA rH r! r! r r" rI ` s
rI c sF e Zd ZdZdd�� fdd�
Zdd� Z� fdd �Z� fd
d �Z� ZS ) �_WaitCancelFuturezoSubclass of Future which represents a wait for the cancellation of a
_WaitHandleFuture using an event.
Nr c s t � j||||d� d | _d S )Nr )r r �_done_callback)r r �eventrN r r r! r" r � s
z_WaitCancelFuture.__init__c C s t d��)Nz'_WaitCancelFuture must not be cancelled)� RuntimeErrorrS r! r! r" r2 � s z_WaitCancelFuture.cancelc �( t � �|� | jd ur| �| � d S d S r> )r rA rc rB r r! r" rA � �
�z _WaitCancelFuture.set_resultc rf r> )r r? rc r@ r r! r" r? � rg z _WaitCancelFuture.set_exception) rD rE rF rG r r2 rA r? rH r! r! r r" rb � s rb c s6 e Zd Zdd�� fdd�
Z� fdd�Zdd� Z� ZS ) �_WaitHandleFutureNr c s< t � j||||d� || _d| _t�d ddd �| _d | _d S )Nr TF)r r � _proactorZ_unregister_proactorr[ Z CreateEvent�_event�
_event_fut)r r rM rN �proactorr r r! r" r � s
z_WaitHandleFuture.__init__c sF | j d urt�| j � d | _ d | _| j�| j� d | _t� �|� d S r> ) rj rP � CloseHandlerk ri � _unregisterr r rY rW r r! r" rY � s
z%_WaitHandleFuture._unregister_wait_cbc
C s� | j sd S d| _ | j}d | _z t�|| j� W n3 tyJ } z'|jtjkr@d|| d�}| jr3| j|d< | j �
|� W Y d }~d S W Y d }~nd }~ww | j � | j| j
�| _d S rZ )rL rK r[ ZUnregisterWaitExrj r3 r\ r] r r4 r5 ri � _wait_cancelrY rk r^ r! r! r" r_ � s. �
���
�z"_WaitHandleFuture._unregister_wait)rD rE rF r rY r_ rH r! r! r r" rh � s rh c @ s< e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � ZeZ d S )
�
PipeServerzXClass representing a pipe server.
This is much like a bound, listening socket.
c C s, || _ t�� | _d | _d | _| �d�| _d S �NT)�_address�weakref�WeakSet�_free_instances�_pipe�_accept_pipe_future�_server_pipe_handle)r r) r! r! r" r � s
zPipeServer.__init__c C s | j | �d�}| _ |S )NF)rv rx )r �tmpr! r! r" �_get_unconnected_pipe s z PipeServer._get_unconnected_pipec
C sr | � � rd S tjtjB }|r|tjO }t�| j|tjtjB tj B tj
t j t j tj
tj�}t �|�}| j�|� |S r> )�closedrP �PIPE_ACCESS_DUPLEX�FILE_FLAG_OVERLAPPED� FILE_FLAG_FIRST_PIPE_INSTANCE�CreateNamedPiperr �PIPE_TYPE_MESSAGE�PIPE_READMODE_MESSAGE� PIPE_WAIT�PIPE_UNLIMITED_INSTANCESr ZBUFSIZE�NMPWAIT_WAIT_FOREVER�NULL�
PipeHandleru �add)r �first�flags�h�piper! r! r" rx
s"
��
z PipeServer._server_pipe_handlec C s
| j d u S r> )rr rS r! r! r" r{ �
zPipeServer.closedc C sV | j d ur
| j �� d | _ | jd ur)| jD ]}|�� qd | _d | _| j�� d S d S r> )rw r2 rr ru �closerv �clear)r r� r! r! r" r� " s
�zPipeServer.closeN)
rD rE rF rG r rz rx r{ r� �__del__r! r! r! r" rp � s
rp c @ s e Zd ZdZdS )�_WindowsSelectorEventLoopz'Windows version of selector event loop.N)rD rE rF rG r! r! r! r" r� 1 � r� c sJ e Zd ZdZd
� fdd� Z� fdd�Zdd� Zd d
� Z d
d d �Z� Z S )r z2Windows version of proactor event loop using IOCP.Nc s |d u rt � }t� �|� d S r> )r r r )r rl r r! r" r 8 s zProactorEventLoop.__init__c s� z2| j d u sJ �| �| j� t� �� W | j d ur1| j j}| j �� |d ur,| j�|� d | _ d S d S | j d urN| j j}| j �� |d urK| j�|� d | _ w r> ) Z_self_reading_future� call_soonZ_loop_self_readingr � run_foreverr r2 ri rn �r r r r! r" r� = s
�
z ProactorEventLoop.run_foreverc � s: �| j �|�}|I d H }|� }| j||d|id�}||fS )N�addr��extra)ri � connect_pipe�_make_duplex_pipe_transport)r �protocol_factoryr) �fr� �protocol�transr! r! r" �create_pipe_connectionP s �
�z(ProactorEventLoop.create_pipe_connectionc � s0 �t � ��d� ����fdd� ����� �gS )Nc
s2 d }z7| r'| � � }�j�|� ��� r|�� W d S �� }�j||d� id� ��� }|d u r2W d S �j�|�} W nU t y{ } z6|rW|�
� dkrW�� d||d�� |�� n�j rit
jd|dd� W Y d }~d S W Y d }~d S W Y d }~d S d }~w tjy� |r�|�� Y d S Y d S w | �_| ��� d S ) Nr� r� r zPipe accept failed)r. r/ r� z Accept pipe failed on pipe %rT)�exc_info)rC ru �discardr{ r� r� rz ri � accept_piper3 �filenor5 �_debugr �warningr �CancelledErrorrw �add_done_callback)r� r� r� r6 �r) �loop_accept_piper� r �serverr! r" r� [ sL
��
������z>ProactorEventLoop.start_serving_pipe.<locals>.loop_accept_piper> )rp r� )r r� r) r! r� r" �start_serving_pipeX s
�
(z$ProactorEventLoop.start_serving_pipec � sx �| � � }
t| |||||||f|
|d�| ��} z|
I d H W | S ttfy) � ty; | �� | �� I d H � w )N)�waiterr� )�
create_future�_WindowsSubprocessTransport�
SystemExit�KeyboardInterrupt�
BaseExceptionr� �_wait) r r� �args�shell�stdin�stdout�stderr�bufsizer� �kwargsr� �transpr! r! r" �_make_subprocess_transport� s& �
��� � �z,ProactorEventLoop._make_subprocess_transportr> )
rD rE rF rG r r� r� r� r� rH r! r! r r" r 5 s 0�r c @ s� e Zd ZdZd;dd�Zdd� Zdd� Zd d
� Zd<d d
�Zdd� Z d=dd�Z
d=dd�Z d=dd�Z d>dd�Z
d=dd�Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd<d%d&�Zd'd(� Zd)d*� Zd+d,� Zd-d.� Zd/d0� Zd1d2� Zd<d3d4�Zd5d6� Z d7d8� Z d9d:� Z d S )?r z#Proactor implementation using IOCP.r c C sD d | _ g | _t�tjtd|�| _i | _t� � | _
g | _ t� � | _ d S rO )
r4 �_resultsr[ �CreateIoCompletionPort�INVALID_HANDLE_VALUEr� �_iocp�_cachers rt rL �
_unregistered�_stopped_serving)r Z concurrencyr! r! r" r � s
�
zIocpProactor.__init__c C s | j d u r td��d S )NzIocpProactor is closed)r� re rS r! r! r" �
_check_closed� s
�zIocpProactor._check_closedc C sF dt | j� dt | j� g}| jd u r|�d� d| jjd�|�f S )Nzoverlapped#=%sz
result#=%sr{ z<%s %s>� )�lenr� r� r� rV r rD �join)r r+ r! r! r" �__repr__� s �
zIocpProactor.__repr__c C s
|| _ d S r> )r4 )r r r! r! r" �set_loop� r� zIocpProactor.set_loopNc C s | j s| �|� | j }g | _ |S r> )r� rT )r �timeoutry r! r! r" �select� s
zIocpProactor.selectc C s | j �� }|�|� |S r> )r4 r� rA )r �valuerX r! r! r" �_result� �
zIocpProactor._resultr c C �| | � |� t�t�}zt|tj�r|�|�� ||� n|�|�� |� W n t y2 | �
d� Y S w dd� }| � |||�S )N� c
S �B z|� � W S ty } z|jtjtjfv rt|j� �� d }~ww r> �� getresultr3 r\ r[ �ERROR_NETNAME_DELETED�ERROR_OPERATION_ABORTED�ConnectionResetErrorr� �r� �keyr r6 r! r! r" � finish_recv� �
�
��z&IocpProactor.recv.<locals>.finish_recv) �_register_with_iocpr[ �
Overlappedr� �
isinstance�socketZWSARecvr� �ReadFile�BrokenPipeErrorr� � _register�r �conn�nbytesr� r r� r! r! r" �recv� �
� �
zIocpProactor.recvc C r� )Nr c
S r� r> r� r� r! r! r" r� � r� z+IocpProactor.recv_into.<locals>.finish_recv) r� r[ r� r� r� r� Z WSARecvIntor� Z ReadFileIntor� r� r� )r r� �bufr� r r� r! r! r" � recv_into� r� zIocpProactor.recv_intoc C s^ | � |� t�t�}z |�|�� ||� W n ty# | �d� Y S w dd� }| �|||�S )N)r� Nc
S r� r> r� r� r! r! r" r� � r� z*IocpProactor.recvfrom.<locals>.finish_recv) r� r[ r� r� Z WSARecvFromr� r� r� r� r� r! r! r" �recvfrom� s
�
zIocpProactor.recvfromc C s> | � |� t�t�}|�|�� |||� dd� }| �|||�S )Nc
S r� r> r� r� r! r! r" � finish_send r� z(IocpProactor.sendto.<locals>.finish_send)r� r[ r� r� Z WSASendTor� r� )r r� r� r� r� r r� r! r! r" �sendto s
zIocpProactor.sendtoc C sZ | � |� t�t�}t|tj�r|�|�� ||� n|�|�� |� dd� }| � |||�S )Nc
S r� r> r� r� r! r! r" r� r� z&IocpProactor.send.<locals>.finish_send)
r� r[ r� r� r� r� ZWSASendr� � WriteFiler� )r r� r� r� r r� r! r! r" �send s
zIocpProactor.sendc sv | � �� | ��j�� t�t�}|���� � �� � � �fdd�}dd� }| �|�|�}||� �}t j
|| j d� |S )Nc sD |� � t�d��� �}� �tjtj|� � � ��
� � � � � � fS )Nz@P) r� �struct�packr� �
setsockoptr� �
SOL_SOCKETr[ ZSO_UPDATE_ACCEPT_CONTEXT�
settimeout�
gettimeout� getpeername)r� r� r r� �r� �listenerr! r" �
finish_accept/ s � z*IocpProactor.accept.<locals>.finish_acceptc � s. �z| I d H W d S t jy |�� � w r> )r r� r� )r0 r� r! r! r" � accept_coro8 s ��z(IocpProactor.accept.<locals>.accept_coror ) r� �_get_accept_socket�familyr[ r� r� ZAcceptExr� r� r
�
ensure_futurer4 )r r� r r� r� r0 �coror! r� r" �accept) s
zIocpProactor.acceptc
s� � j tjkrt�� �� |� | j�� }|�d � |S | � � � z t�
� �� � j � W n" t yL } z|j
tjkr9� � �� d dkrB� W Y d }~nd }~ww t�t�}|�� �� |� � fdd�}| �|� |�S )Nr r c s |� � � �tjtjd� � S rO )r� r� r� r� r[ ZSO_UPDATE_CONNECT_CONTEXT�r� r� r �r� r! r" �finish_connect[ s
�z,IocpProactor.connect.<locals>.finish_connect)�typer� �
SOCK_DGRAMr[ Z
WSAConnectr� r4 r� rA r� Z BindLocalr� r3 r\ �errnoZ WSAEINVAL� getsocknamer� r� Z ConnectExr� )r r� r) rX �er r� r! r� r" �connectE s(
���
zIocpProactor.connectc C sb | � |� t�t�}|d@ }|d? d@ }|�|�� t�|�� �|||dd� dd� }| �|||�S )Nr � r c
S r� r> r� r� r! r! r" �finish_sendfilen r� z.IocpProactor.sendfile.<locals>.finish_sendfile) r� r[ r� r� Z TransmitFiler� �msvcrt�
get_osfhandler� ) r �sock�file�offset�countr Z
offset_lowZ offset_highr r! r! r" �sendfiled s
� zIocpProactor.sendfilec sJ | � � � t�t�}|�� �� �}|r| �� �S � fdd�}| �|� |�S )Nc s |� � � S r> )r� r� �r� r! r" �finish_accept_pipe� s z4IocpProactor.accept_pipe.<locals>.finish_accept_pipe)r� r[ r� r� �ConnectNamedPiper� r� r� )r r� r � connectedr r! r r" r� y s
zIocpProactor.accept_pipec
� st �t } zt�|�}W n) ty$ } z
|jtjkr� W Y d }~nd }~ww t|d t�}t� |�I d H qt
� |�S )NT� ) �CONNECT_PIPE_INIT_DELAYr[ Z ConnectPiper3 r\ �ERROR_PIPE_BUSY�min�CONNECT_PIPE_MAX_DELAYr
�sleepr r� )r r) �delayrM r6 r! r! r" r� � s �
����
zIocpProactor.connect_pipec C s | � ||d�S )z�Wait for a handle.
Return a Future object. The result of the future is True if the wait
completed, or False if the wait did not complete (on timeout).
F)�_wait_for_handle)r rM r� r! r! r" �wait_for_handle� s z IocpProactor.wait_for_handlec C s | � |d d�}||_|S rq )r rc )r rd Z
done_callbackrX r! r! r" ro � s zIocpProactor._wait_cancelc s� | � � |d u r tj}nt�|d �}t�t�}t�|| j |j
|�}|r.t |||| j d�� n
t
|||| | j d�� � jr?� jd= � fdd�}� |d|f| j|j
< � S )N� @�@r r c s � � � S r> )rT r� �r� r! r" �finish_wait_for_handle� s z=IocpProactor._wait_for_handle.<locals>.finish_wait_for_handler )r� rP �INFINITE�math�ceilr[ r� r� ZRegisterWaitWithQueuer� r) rb r4 rh r r� )r rM r� Z
_is_cancel�msr rN r r! r r" r � s$
�
� z IocpProactor._wait_for_handlec C s4 || j vr| j �|� t�|�� | jdd� d S d S rO )rL r� r[ r� r� r� �r �objr! r! r" r� � s
�z IocpProactor._register_with_iocpc
C s� | � � t|| jd�}|jr|jd= |js:z|d d |�}W n ty4 } z |�|� W Y d }~n
d }~ww |�|� ||||f| j|j < |S r )
r� r r4 r r# r3 r? rA r� r) )r r r# �callbackr� r� r r! r! r" r� � s ��
zIocpProactor._registerc C s | � � | j�|� dS )a
Unregister an overlapped object.
Call this method when its future has been cancelled. The event can
already be signalled (pending in the proactor event queue). It is also
safe if the event is never signalled (because it was cancelled).
N)r� r� rV r� r! r! r" rn � s zIocpProactor._unregisterc C s t � |�}|�d� |S rO )r� r� )r r� �sr! r! r" r� r� z IocpProactor._get_accept_socketc C s| |d u rt }n|dk rtd��t�|d �}|t kr td�� t�| j|�}|d u r+n~d}|\}}}}z | j�|�\}} }
} W n) t yh | j
� � rZ| j
� dd||||f d�� |dtj
fvrft�|� Y q w |
| jv rs|�� n5|�� s�z| ||| �} W n ty� }
z|�|
� | j�|� W Y d }
~
nd }
~
ww |�| � | j�|� q | jD ]
} | j�| jd � q�| j�� d S ) Nr znegative timeoutr ztimeout too bigTz8GetQueuedCompletionStatus() returned an unexpected eventz)err=%s transferred=%s key=%#x address=%#x)r. �status)r �
ValueErrorr r r[ ZGetQueuedCompletionStatusr� r� �pop�KeyErrorr4 � get_debugr5 r� rP rm r� r2 �doner3 r? r� rV rA r� r) r� )r r� r! r& �errZ transferredr� r) r� r r# r$ r� r r! r! r" rT sV
��
�
��
�
'zIocpProactor._pollc C s | j �|� d S r> )r� r� r" r! r! r" �
_stop_serving> s zIocpProactor._stop_servingc C s | j d u rd S t| j�� �D ]D\}\}}}}|�� rqt|t�r!qz|�� W q tyR } z | j d urHd||d�}|j
rB|j
|d< | j � |� W Y d }~qd }~ww d}t �
� } | | }
| jr|
t �
� krwt�d| t �
� | � t �
� | }
| �|� | js`g | _t�| j � d | _ d S )NzCancelling a future failedr- r1 g �?z,%r is running after closing for %.1f seconds)r� �listr� �items� cancelledr� rb r2 r3 r4 r r5 �time� monotonicr �debugrT r� rP rm ) r r) rX r r# r$ r6 r7 Z
msg_update�
start_timeZnext_msgr! r! r" r� D sD
�
�� �
�
zIocpProactor.closec C s | � � d S r> )r� rS r! r! r" r� s s zIocpProactor.__del__)r r> )r )r N) rD rE rF rG r r� r� r� r� r� r� r� r� r� r� r� r r
r� r� r ro r r� r� rn r� rT r- r� r� r! r! r! r" r � s:
"
7 /r c @ s e Zd Zdd� ZdS )r� c
sP t j|f|||||d�|��� _� fdd�}� jj�t� jj��} | �|� d S )N)r� r� r� r� r� c s � j �� }� �|� d S r> )�_proc�poll�_process_exited)r� �
returncoderS r! r" r$ ~ s
z4_WindowsSubprocessTransport._start.<locals>.callback) r �Popenr5 r4 ri r �intrJ r� )
r r� r� r� r� r� r� r� r$ r� r! rS r" �_starty s ��� z"_WindowsSubprocessTransport._startN)rD rE rF r; r! r! r! r" r� w s r� c @ � e Zd ZeZdS )r N)rD rE rF r
�
_loop_factoryr! r! r! r" r � r� r c @ r< )r N)rD rE rF r r= r! r! r! r" r � r� r )2rG �sys�platform� ImportErrorr[ rP r r r r� r� r1 rs � r r r r r r r
r �logr �__all__r� r ZERROR_CONNECTION_REFUSEDZERROR_CONNECTION_ABORTEDr r �Futurer rI rb rh �objectrp ZBaseSelectorEventLoopr� ZBaseProactorEventLoopr r ZBaseSubprocessTransportr� r
�BaseDefaultEventLoopPolicyr r r r! r! r! r" �<module> sZ
0J4;e `