File: //opt/imh-python/lib/python3.9/asyncio/__pycache__/windows_events.cpython-39.opt-2.pyc
a
b�h�� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZddl m
Z
ddl m Z ddl m Z ddl m
Z
ddl mZ ddl mZ dd l mZ dd
l mZ dd lmZ d Zd Zd
ZdZdZdZdZG dd� de j�Z G dd� de j�Z G dd� de �Z G dd� de �Z G dd� de �Z!G d d � d ej"�Z#G d d � d ej$�Z%G d d!� d!�Z&G d"d#� d#e j'�Z(e#Z)G d$d%� d%e
j*�Z+G d&d'� d'e
j*�Z,e,Z-dS )(� N� )�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 Zdd�� fdd�
Z� fdd�Zdd� Zd� fd d
� Z� fd d �Z� fd
d�Z� Z S )�_OverlappedFutureN��loopc s& t � j|d� | jr | jd= || _d S �Nr ���)�super�__init__�_source_traceback�_ov)�self�ovr �� __class__� �7/opt/imh-python/lib/python3.9/asyncio/windows_events.pyr 1 s z_OverlappedFuture.__init__c sH t � �� }| jd urD| jjr dnd}|�dd|� d| jjd�d�� |S )N�pendingZ completedr z overlapped=<z, �#x�>)r �
_repr_infor r" �insert�address�r �info�stater r r! r% 7 s
z _OverlappedFuture._repr_infoc
C st | j d u rd S z| j �� W nL tyh } z4d|| d�}| jrH| j|d< | j�|� W Y d }~n
d }~0 0 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_overlapped> s
�
"z$_OverlappedFuture._cancel_overlappedc s | � � t� j|d�S �N)�msg)r6 r r0 �r r8 r r r! r0 N s z_OverlappedFuture.cancelc s t � �|� | �� d S �N)r �
set_exceptionr6 �r r- r r r! r; R s z _OverlappedFuture.set_exceptionc s t � �|� d | _d S r: )r �
set_resultr �r �resultr r r! r= V s z _OverlappedFuture.set_result)N)
�__name__�
__module__� __qualname__r r% r6 r0 r; r= �
__classcell__r r r r! r + s r c sl e Zd Zdd�� fdd�
Zdd� Z� fdd�Zd d
� Zd d � Zd� fd
d� Z� fdd�Z � fdd�Z
� Z S )�_BaseWaitHandleFutureNr 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 ^ s z _BaseWaitHandleFuture.__init__c C s t �| jd�t jkS �Nr )�_winapiZWaitForSingleObjectrE Z
WAIT_OBJECT_0�r r r r! �_polll s �z_BaseWaitHandleFuture._pollc sd t � �� }|�d| jd��� | jd urB| �� r4dnd}|�|� | jd ur`|�d| jd��� |S )Nzhandle=r# �signaledZwaitingz wait_handle=)r r% �appendrE rM rF r( r r r! r% q 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 s
d S d| _ | j}d | _zt�|� W nf ty� } zN|jtjkr|d|| d�}| jrb| j|d< | j� |� W Y d }~d S W Y d }~n
d }~0 0 | �
d � d S �NFz$Failed to unregister the wait handler+ r/ ) rG rF � _overlappedZUnregisterWaitr1 �winerror�ERROR_IO_PENDINGr r2 r3 rR �r rI r4 r5 r r r! �_unregister_wait� s$ �
$z&_BaseWaitHandleFuture._unregister_waitc s | � � t� j|d�S r7 )rX r r0 r9 r r r! r0 � s z _BaseWaitHandleFuture.cancelc s | � � t� �|� d S r: )rX r r; r< r r r! r; � s z#_BaseWaitHandleFuture.set_exceptionc s | � � t� �|� d S r: )rX r r= r> r r r! r= � s z _BaseWaitHandleFuture.set_result)N) r@ rA rB r rM r% rR rX r0 r; r= rC r r r r! rD [ s
rD c sB e Zd Zdd�� fdd�
Zdd� Z� fdd�Z� fd d
�Z� ZS ) �_WaitCancelFutureNr c s t � j||||d� d | _d S )Nr )r r �_done_callback)r r �eventrI r r r r! r � s z_WaitCancelFuture.__init__c C s t d��d S )Nz'_WaitCancelFuture must not be cancelled)� RuntimeErrorrL r r r! r0 � s z_WaitCancelFuture.cancelc s$ t � �|� | jd ur | �| � d S r: )r r= rZ r> r r r! r= � s
z _WaitCancelFuture.set_resultc s$ t � �|� | jd ur | �| � d S r: )r r; rZ r< r r r! r; � s
z _WaitCancelFuture.set_exception)r@ rA rB r r0 r= r; rC r r r r! rY � s rY 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_proactorrT Z CreateEvent�_event�
_event_fut)r r rH rI �proactorr r r r! r � s
z_WaitHandleFuture.__init__c sF | j d ur"t�| j � d | _ d | _| j�| j� d | _t� �|� d S r: ) r_ rK � CloseHandler` r^ � _unregisterr r rR rP r r r! rR � s
z%_WaitHandleFuture._unregister_wait_cbc
C s� | j s
d S d| _ | j}d | _zt�|| j� W nf ty� } zN|jtjkr�d|| d�}| jrf| j|d< | j �
|� W Y d }~d S W Y d }~n
d }~0 0 | j � | j| j
�| _d S rS )rG rF rT ZUnregisterWaitExr_ r1 rU rV r r2 r3 r^ � _wait_cancelrR r` rW r r r! rX � s( �
$
�z"_WaitHandleFuture._unregister_wait)r@ rA rB r rR rX rC r r r r! r] � s r] c @ s8 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� ZeZd S ) �
PipeServerc 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)rk rm )r �tmpr r r! �_get_unconnected_pipe s z PipeServer._get_unconnected_pipec
C sr | � � r d S tjtjB }|r&|tjO }t�| j|tjtjB tj B tj
t j t j tj
tj�}t �|�}| j�|� |S r: )�closedrK ZPIPE_ACCESS_DUPLEXZFILE_FLAG_OVERLAPPEDZ FILE_FLAG_FIRST_PIPE_INSTANCEZCreateNamedPiperg ZPIPE_TYPE_MESSAGEZPIPE_READMODE_MESSAGEZ PIPE_WAITZPIPE_UNLIMITED_INSTANCESr
�BUFSIZEZNMPWAIT_WAIT_FOREVER�NULL�
PipeHandlerj �add)r �first�flags�h�piper r r! rm s"
��
z PipeServer._server_pipe_handlec C s
| j d u S r: )rg rL r r r! rq s zPipeServer.closedc C sR | j d ur| j �� d | _ | jd urN| jD ] }|�� q*d | _d | _| j�� d S r: )rl r0 rg rj �closerk �clear)r ry r r r! rz s
zPipeServer.closeN) r@ rA rB r rp rm rq rz �__del__r r r r! re � s
re c @ s e Zd ZdS )�_WindowsSelectorEventLoopN)r@ rA rB r r r r! r} , s r} c sD e Zd Zd � fdd� Z� fdd�Zdd� Zdd � Zd
d
d �Z� ZS )r
Nc s |d u rt � }t� �|� d S r: )r r r )r ra r r r! r 3 s zProactorEventLoop.__init__c s� zP| � | j� t� �� W | jd ur�| jj}| j�� |d urJ| j�|� d | _n8| jd ur�| jj}| j�� |d ur�| j�|� d | _0 d S r: ) � call_soonZ_loop_self_readingr � run_foreverZ_self_reading_futurer r0 r^ rc �r r r r r! r 8 s
�
z ProactorEventLoop.run_foreverc � s8 | j �|�}|I d H }|� }| j||d|id�}||fS )N�addr��extra)r^ � connect_pipe�_make_duplex_pipe_transport)r �protocol_factoryr' �fry �protocol�transr r r! �create_pipe_connectionK s
�z(ProactorEventLoop.create_pipe_connectionc � s. t � ��d� ����fdd� ����� �gS )Nc
s d }zn| rN| � � }�j�|� ��� r4|�� W d S �� }�j||d� id� ��� }|d u rdW d S �j�|�} W n� t y� } zN|r�|�
� dkr��� d||d�� |�� n�j r�t
jd|dd� W Y d }~n8d }~0 tjy� |r�|�� Y n0 | �_| ��� d S ) Nr� r� r zPipe accept failed)r, r- ry z Accept pipe failed on pipe %rT)�exc_info)r? rj �discardrq rz r� rp r^ � accept_piper1 �filenor3 Z_debugr �warningr �CancelledErrorrl �add_done_callback)r� ry r� r4 �r' �loop_accept_piper� r Zserverr r! r� V sB
��
�z>ProactorEventLoop.start_serving_pipe.<locals>.loop_accept_pipe)N)re r~ )r r� r' r r� r! �start_serving_pipeS s (
z$ProactorEventLoop.start_serving_pipec � s� | � � }
t| |||||||f|
|d�| ��} z|
I d H W n@ ttfyR � Y n* tyz | �� | �� I d H � Y n0 | S )N)�waiterr� )�
create_future�_WindowsSubprocessTransport�
SystemExit�KeyboardInterrupt�
BaseExceptionrz �_wait) r r� �args�shell�stdin�stdout�stderr�bufsizer� �kwargsr� Ztranspr r r! �_make_subprocess_transport� s"
��� z,ProactorEventLoop._make_subprocess_transport)N)N) r@ rA rB r r r� r� r� rC r r r r! r
0 s 0 �r
c @ s� e Zd Zd:dd�Zdd� Zdd� Zdd � Zd;d d �Zd
d� Zd<dd�Z d=dd�Z
d>dd�Z d?dd�Z d@dd�Z
dd� Zd d � Zd d � Zd d!� Zd"d#� ZdAd$d%�Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� ZdBd2d3�Zd4d5� Zd6d7� Z d8d9� Z d
S )Cr r c C sD d | _ g | _t�tjtd|�| _i | _t� � | _
g | _ t� � | _ d S rJ )
r2 �_resultsrT �CreateIoCompletionPort�INVALID_HANDLE_VALUErs �_iocp�_cacherh ri rG �
_unregistered�_stopped_serving)r Z concurrencyr r r! r � s
�
zIocpProactor.__init__c C s | j d u rtd��d S )NzIocpProactor is closed)r� r\ rL r r r! �
_check_closed� s
zIocpProactor._check_closedc C sF dt | j� dt | j� g}| jd u r0|�d� d| jjd�|�f S )Nzoverlapped#=%sz
result#=%srq z<%s %s>� )�lenr� r� r� rO r r@ �join)r r) r r r! �__repr__� s �
zIocpProactor.__repr__c C s
|| _ d S r: )r2 )r r r r r! �set_loop� s zIocpProactor.set_loopNc C s | j s| �|� | j }g | _ |S r: )r� rM )r �timeoutro r r r! �select� s
zIocpProactor.selectc C s | j �� }|�|� |S r: )r2 r� r= )r �valuerQ r r r! �_result� s
zIocpProactor._resultr c C s| | � |� t�t�}z4t|tj�r6|�|�� ||� n|�|�� |� W n t yd | �
d� Y S 0 dd� }| � |||�S )N� c
S sT z
|� � W S tyN } z,|jtjtjfv r8t|j� �n� W Y d }~n
d }~0 0 d S r: �� getresultr1 rU rT ZERROR_NETNAME_DELETEDZERROR_OPERATION_ABORTED�ConnectionResetErrorr� �r� �keyr r4 r r r! � finish_recv� s
� z&IocpProactor.recv.<locals>.finish_recv) �_register_with_iocprT �
Overlappedrs �
isinstance�socketZWSARecvr� ZReadFile�BrokenPipeErrorr� � _register�r �conn�nbytesrw r r� r r r! �recv� s
zIocpProactor.recvc C s| | � |� t�t�}z4t|tj�r6|�|�� ||� n|�|�� |� W n t yd | �
d� Y S 0 dd� }| � |||�S )Nr c
S sT z
|� � W S tyN } z,|jtjtjfv r8t|j� �n� W Y d }~n
d }~0 0 d S r: r� r� r r r! r� � s
� z+IocpProactor.recv_into.<locals>.finish_recv) r� rT r� rs r� r� Z WSARecvIntor� Z ReadFileIntor� r� r� )r r� �bufrw r r� r r r! � recv_into� s
zIocpProactor.recv_intoc C s^ | � |� t�t�}z|�|�� ||� W n tyF | �d� Y S 0 dd� }| �|||�S )N)r� Nc
S sT z
|� � W S tyN } z,|jtjtjfv r8t|j� �n� W Y d }~n
d }~0 0 d S r: r� r� r r r! r� � s
� z*IocpProactor.recvfrom.<locals>.finish_recv) r� rT r� rs Z WSARecvFromr� r� r� r� r� r r r! �recvfrom� s
zIocpProactor.recvfromc C s> | � |� t�t�}|�|�� |||� dd� }| �|||�S )Nc
S sT z
|� � W S tyN } z,|jtjtjfv r8t|j� �n� W Y d }~n
d }~0 0 d S r: r� r� r r r! � finish_send s
� z(IocpProactor.sendto.<locals>.finish_send)r� rT r� rs Z WSASendTor� r� )r r� r� rw r� r r� r r r! �sendto� s
zIocpProactor.sendtoc C sZ | � |� t�t�}t|tj�r4|�|�� ||� n|�|�� |� dd� }| � |||�S )Nc
S sT z
|� � W S tyN } z,|jtjtjfv r8t|j� �n� W Y d }~n
d }~0 0 d S r: r� r� r r r! r� s
� z&IocpProactor.send.<locals>.finish_send)
r� rT r� rs r� r� ZWSASendr� Z WriteFiler� )r r� r� rw 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_SOCKETrT ZSO_UPDATE_ACCEPT_CONTEXT�
settimeout�
gettimeout� getpeername)r� r� r r� �r� �listenerr r! �
finish_accept* s �z*IocpProactor.accept.<locals>.finish_acceptc � s2 z| I d H W n t jy, |�� � Y n0 d S r: )r r� rz )r. r� r r r! � accept_coro3 s
z(IocpProactor.accept.<locals>.accept_coror ) r� �_get_accept_socket�familyrT r� rs ZAcceptExr� r� r Z
ensure_futurer2 )r r� r r� r� r. �coror r� r! �accept$ s
zIocpProactor.acceptc
s� � j tjkr4t�� �� |� | j�� }|�d � |S | � � � zt�
� �� � j � W nD t y� } z,|j
tjkrr� � �� d dkr�� W Y d }~n
d }~0 0 t�t�}|�� �� |� � fdd�}| �|� |�S )Nr r c s |� � � �tjtjd� � S rJ )r� r� r� r� rT ZSO_UPDATE_CONNECT_CONTEXT�r� r� r �r� r r! �finish_connectV s
�z,IocpProactor.connect.<locals>.finish_connect)�typer� �
SOCK_DGRAMrT Z
WSAConnectr� r2 r� r= r� Z BindLocalr� r1 rU �errnoZ WSAEINVAL� getsocknamer� rs Z ConnectExr� )r r� r' rQ �er r� r r� r! �connect@ s"
zIocpProactor.connectc C sb | � |� t�t�}|d@ }|d? d@ }|�|�� t�|�� �|||dd� dd� }| �|||�S )Nr � r c
S sT z
|� � W S tyN } z,|jtjtjfv r8t|j� �n� W Y d }~n
d }~0 0 d S r: r� r� r r r! �finish_sendfilei s
� z.IocpProactor.sendfile.<locals>.finish_sendfile) r� rT r� rs Z TransmitFiler� �msvcrtZ
get_osfhandler� ) r �sock�file�offset�countr Z
offset_lowZ offset_highr� r r r! �sendfile_ s
� zIocpProactor.sendfilec sJ | � � � t�t�}|�� �� �}|r0| �� �S � fdd�}| �|� |�S )Nc s |� � � S r: )r� r� �ry r r! �finish_accept_pipe s z4IocpProactor.accept_pipe.<locals>.finish_accept_pipe)r� rT r� rs ZConnectNamedPiper� r� r� )r ry r Z connectedr� r r� r! r� t s
zIocpProactor.accept_pipec
� st t }zt�|�}W qjW n2 tyH } z|jtjkr4� W Y d }~n
d }~0 0 t|d t�}t� |�I d H qt
� |�S )N� ) �CONNECT_PIPE_INIT_DELAYrT Z ConnectPiper1 rU ZERROR_PIPE_BUSY�min�CONNECT_PIPE_MAX_DELAYr �sleepr
rt )r r' �delayrH r4 r r r! r� � s
zIocpProactor.connect_pipec C s | � ||d�S rn )�_wait_for_handle)r rH r� r r r! �wait_for_handle� s z IocpProactor.wait_for_handlec C s | � |d d�}||_|S rf )r� rZ )r r[ Z
done_callbackrQ r r r! rd � s zIocpProactor._wait_cancelc s� | � � |d u rtj}nt�|d �}t�t�}t�|| j |j
|�}|r\t |||| j d�� nt
|||| | j d�� � jr~� jd= � fdd�}� |d|f| j|j
< � S )N� @�@r r c s � � � S r: )rM r� �r� r r! �finish_wait_for_handle� s z=IocpProactor._wait_for_handle.<locals>.finish_wait_for_handler )r� rK �INFINITE�math�ceilrT r� rs ZRegisterWaitWithQueuer� r' rY r2 r] r r� )r rH r� Z
_is_cancel�msr rI r� r r� r! r� � s$
�
� z IocpProactor._wait_for_handlec C s0 || j vr,| j �|� t�|�� | jdd� d S rJ )rG ru rT r� r� r� �r �objr r r! r� � s
z IocpProactor._register_with_iocpc
C s� | � � t|| jd�}|jr$|jd= |jstz|d d |�}W n. tyh } z|�|� W Y d }~nd }~0 0 |�|� ||||f| j|j < |S r )
r� r r2 r r" r1 r; r= r� r' )r r r� �callbackr� r� r� r r r! r� � s
zIocpProactor._registerc C s | � � | j�|� d S r: )r� r� rO r� r r r! rc � s zIocpProactor._unregisterc C s t � |�}|�d� |S rJ )r� r� )r r� �sr r r! r� � s
z IocpProactor._get_accept_socketc C s� |d u rt }n0|dk r td��n t�|d �}|t kr>td��t�| j|�}|d u rX�qZd}|\}}}}z| j�|�\}} }
} W nV t y� | j
� � r�| j
� dd||||f d�� |dtj
fvr�t�|� Y q>Y n0 |
| jv r�|�� q>|�� s>z| ||| �} W n< t�y@ }
z"|�|
� | j�|� W Y d }
~
q>d }
~
0 0 |�| � | j�|� q>| jD ]} | j�| jd � �q`| j�� d S )Nr znegative timeoutr� ztimeout too bigz8GetQueuedCompletionStatus() returned an unexpected eventz)err=%s transferred=%s key=%#x address=%#x)r, �status)r� �
ValueErrorr� r� rT ZGetQueuedCompletionStatusr� r� �pop�KeyErrorr2 Z get_debugr3 r� rK rb r� r0 �doner1 r; r� rO r= r� r' r{ )r r� r� r �errZ transferredr� r' r� r r� r� r� r� r r r! rM sL
��
"
zIocpProactor._pollc C s | j �|� d S r: )r� ru r� r r r! �
_stop_serving9 s zIocpProactor._stop_servingc C s | j d u rd S t| j�� �D ]�\}\}}}}|�� r6q t|t�rBq z |�� W q ty� } z>| j d ur�d||d�}|j
r�|j
|d< | j � |� W Y d }~q d }~0 0 q d}t �
� } | | }
| jr�|
t �
� kr�t�d| t �
� | � t �
� | }
| �|� q�g | _t�| j � d | _ d S )NzCancelling a future failedr+ r/ g �?z,%r is running after closing for %.1f seconds)r� �listr� �items� cancelledr� rY r0 r1 r2 r r3 �time� monotonicr �debugrM r� rK rb ) r r' rQ r r� r� r4 r5 Z
msg_updateZ
start_timeZnext_msgr r r! rz ? s>
�
$ � zIocpProactor.closec C s | � � d S r: )rz rL r r r! r| n s zIocpProactor.__del__)r )N)r )r )r )r N)r )N)N) r@ rA rB r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rd r� r� r� rc r� rM r rz r| r r r r! r � s6
"
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�pollZ_process_exited)r� �
returncoderL r r! r� y s
z4_WindowsSubprocessTransport._start.<locals>.callback) r
�Popenr r2 r^ r� �intrE r� )
r r� r� r� r� r� r� r� r� r� r rL r! �_startt s ��� z"_WindowsSubprocessTransport._startN)r@ rA rB r r r r r! r� r s r� c @ s e Zd ZeZdS )r N)r@ rA rB r �
_loop_factoryr r r r! r � s r c @ s e Zd ZeZdS )r N)r@ rA rB r
r r r r r! r � s r ).rT rK r� r� r� r� r� r rh � r r r r r r r r
�logr �__all__rs r� ZERROR_CONNECTION_REFUSEDZERROR_CONNECTION_ABORTEDr� r� �Futurer rD rY r] �objectre ZBaseSelectorEventLoopr} ZBaseProactorEventLoopr
r ZBaseSubprocessTransportr� r ZBaseDefaultEventLoopPolicyr r r r r r r! �<module> sP 0J4;e `