관리-도구
편집 파일: windows_events.cpython-310.opt-2.pyc
o 6��f�� � @ s� d dl Z e jdkred��d dlZd dlZd dlZd dlZd dlZd dlZd dl Z d dl Z d dl Z ddl m Z ddl mZ ddl mZ ddl mZ dd l mZ dd l mZ dd l mZ dd l mZ dd lmZ dZd ZdZdZdZdZ dZ G dd� dej �Z G dd� dej �Z G dd� de �Z!G dd� de �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'e j-�Z.G d(d)� d)e j-�Z/e/Z0dS )*� NZwin32z 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 Z dd�� 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__� �=/opt/alt/python310/lib64/python3.10/asyncio/windows_events.pyr 6 s z_OverlappedFuture.__init__c sH t � �� }| jd ur"| jjrdnd}|�dd|� d| jjd�d�� |S )N�pendingZ 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)r6 r r0 �r r9 r r r! r0 S � z_OverlappedFuture.cancelc s t � �|� | �� d S �N)r � set_exceptionr6 �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! r? [ s z _OverlappedFuture.set_resultr< ) �__name__� __module__� __qualname__r r% r6 r0 r= r? � __classcell__r r r r! r 0 s r c sn e Zd Z dd�� 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 c s z _BaseWaitHandleFuture.__init__c C s t �| jd�t jkS �Nr )�_winapiZWaitForSingleObjectrG Z 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# ZsignaledZwaitingz wait_handle=)r r% �appendrG rO rH 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+ r/ ) rI rH � _overlappedZUnregisterWaitr1 �winerror�ERROR_IO_PENDINGr r2 r3 rS �r rK r4 r5 r r r! �_unregister_wait� s* � ��� z&_BaseWaitHandleFuture._unregister_waitc r7 r8 )rY r r0 r: r r r! r0 � r; z _BaseWaitHandleFuture.cancelc � | � � t� �|� d S r< )rY r r= r> r r r! r= � � z#_BaseWaitHandleFuture.set_exceptionc rZ r< )rY r r? r@ r r r! r? � r[ z _BaseWaitHandleFuture.set_resultr< ) rB rC rD r rO r% rS rY r0 r= r? rE r r r r! rF ` s rF c sD e Zd Z dd�� 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 �eventrK r r r r! r � s z_WaitCancelFuture.__init__c C s t d��)Nz'_WaitCancelFuture must not be cancelled)� RuntimeErrorrN r r r! r0 � s z_WaitCancelFuture.cancelc �( t � �|� | jd ur| �| � d S d S r< )r r? r] r@ r r r! r? � � �z _WaitCancelFuture.set_resultc r` r< )r r= r] r> r r r! r= � ra z _WaitCancelFuture.set_exception)rB rC rD r r0 r? r= rE r r r r! r\ � s r\ 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_proactorrU Z CreateEvent�_event� _event_fut)r r rJ rK �proactorr r r r! r � s z_WaitHandleFuture.__init__c sF | j d urt�| j � d | _ d | _| j�| j� d | _t� �|� d S r< ) rd rM � CloseHandlere rc � _unregisterr r rS rQ r r r! rS � 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 rT )rI rH rU ZUnregisterWaitExrd r1 rV rW r r2 r3 rc � _wait_cancelrS re rX r r r! rY � s. � ��� �z"_WaitHandleFuture._unregister_wait)rB rC rD r rS rY rE r r r r! rb � s rb c @ s: e Zd Z dd� 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)rp rr )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< )�closedrM ZPIPE_ACCESS_DUPLEXZFILE_FLAG_OVERLAPPEDZ FILE_FLAG_FIRST_PIPE_INSTANCEZCreateNamedPiperl ZPIPE_TYPE_MESSAGEZPIPE_READMODE_MESSAGEZ PIPE_WAITZPIPE_UNLIMITED_INSTANCESr ZBUFSIZEZNMPWAIT_WAIT_FOREVER�NULL� PipeHandlero �add)r �first�flags�h�piper r r! rr s" �� z PipeServer._server_pipe_handlec C s | j d u S r< )rl rN r r r! rv � zPipeServer.closedc C sV | j d ur | j �� d | _ | jd ur)| jD ]}|�� qd | _d | _| j�� d S d S r< )rq r0 rl ro �closerp �clear)r r} r r r! r " s �zPipeServer.closeN) rB rC rD r ru rr rv r �__del__r r r r! rj � s rj c @ s e Zd ZdS )�_WindowsSelectorEventLoopN)rB rC rD r r r r! r� 1 s r� c sH e Zd Z d � fdd� Z� fdd�Zdd� Zdd � Z d d d �Z� ZS ) r Nc s |d u rt � }t� �|� d S r< )r r r )r rf r r r! r 8 s zProactorEventLoop.__init__c s� z.| � | j� t� �� W | jd ur-| jj}| j�� |d ur(|js(| j� |� d | _d S d S | jd urM| jj}| j�� |d urJ|jsJ| j� |� d | _w r< ) � call_soonZ_loop_self_readingr � run_foreverZ_self_reading_futurer r0 r" rc rh �r r r r r! r� = s � z ProactorEventLoop.run_foreverc � s: �| j �|�}|I d H }|� }| j||d|id�}||fS )N�addr��extra)rc � 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 sT d }z7| r'| � � }�j�|� ��� r|�� W d S �� }�j||d� id� ��� }|d u r2W d S �j�|�} W nf t yT |rL|� � dkrL|�� �� �� Y d S t y� } z-|rq|� � dkrq�� d||d�� |�� n �jr|tjd|dd� �� �� 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)rA ro �discardrv r r� ru rc � accept_pipe�BrokenPipeError�filenor� r1 r3 Z_debugr Zwarningr �CancelledErrorrq �add_done_callback)r� r} r� r4 �r' �loop_accept_piper� r Zserverr r! r� [ sR � � ����z>ProactorEventLoop.start_serving_pipe.<locals>.loop_accept_piper< )rj 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 Z_wait) r r� �args�shell�stdin�stdout�stderr�bufsizer� �kwargsr� Ztranspr r r! �_make_subprocess_transport� s& � ��� � �z,ProactorEventLoop._make_subprocess_transportr< ) rB rC rD r r� r� r� r� rE r r r r! r 5 s 5�r c @ s� e Zd Z d: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#� Zd;d$d%�Zd&d'� Zd(d)� Zd*d+� Zd,d-� Zd.d/� Zd0d1� Zd;d2d3�Zd4d5� Zd6d7� Z d8d9� Z d S )>r r c C sD d | _ g | _t�tjtd|�| _i | _t� � | _ g | _ t� � | _ d S rL ) r2 �_resultsrU �CreateIoCompletionPort�INVALID_HANDLE_VALUErw �_iocp�_cacherm rn rI � _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� r_ rN 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#=%srv z<%s %s>� )�lenr� r� r� rP r rB �join)r r) r r r! �__repr__� s � zIocpProactor.__repr__c C s || _ d S r< )r2 )r r r r r! �set_loop� r~ zIocpProactor.set_loopNc C s. | j s| �|� | j }g | _ z|W d }S d }w r< )r� rO )r �timeoutrt r r r! �select� s zIocpProactor.selectc C s | j �� }|�|� |S r< )r2 r� r? )r �valuerR 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< �� getresultr1 rV rU ZERROR_NETNAME_DELETEDZERROR_OPERATION_ABORTED�ConnectionResetErrorr� �r� �keyr r4 r r r! � finish_recv� � � ��z&IocpProactor.recv.<locals>.finish_recv) �_register_with_iocprU � Overlappedrw � isinstance�socketZWSARecvr� ZReadFiler� r� � _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� rU r� rw 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� rU r� rw 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� rU r� rw 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� rU r� rw r� r� ZWSASendr� Z 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� �structZpackr� � setsockoptr� � SOL_SOCKETrU ZSO_UPDATE_ACCEPT_CONTEXT� settimeoutZ gettimeoutZ getpeername)r� r� r r� �r� �listenerr r! � finish_accept8 s � z*IocpProactor.accept.<locals>.finish_acceptc � s. �z| I d H W d S t jy |�� � w r< )r r� r )r. r� r r r! � accept_coroA s ��z(IocpProactor.accept.<locals>.accept_coror ) r� �_get_accept_socket�familyrU r� rw ZAcceptExr� r� r Z ensure_futurer2 )r r� r r� r� r. �coror r� r! �accept2 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 rL )r� r� r� r� rU ZSO_UPDATE_CONNECT_CONTEXT�r� r� r �r� r r! �finish_connectd s �z,IocpProactor.connect.<locals>.finish_connect)�typer� Z SOCK_DGRAMrU Z WSAConnectr� r2 r� r? r� Z BindLocalr� r1 rV �errnoZ WSAEINVALZ getsocknamer� rw Z ConnectExr� )r r� r' rR �er r� r r� r! �connectN 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_sendfilew r� z.IocpProactor.sendfile.<locals>.finish_sendfile) r� rU r� rw Z TransmitFiler� �msvcrtZ get_osfhandler� ) r Zsock�file�offset�countr Z offset_lowZ offset_highr� r r r! �sendfilem 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� rU r� rw ZConnectNamedPiper� r� r� )r r} r Z connectedr� r r� r! r� � 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_DELAYrU Z ConnectPiper1 rV ZERROR_PIPE_BUSY�min�CONNECT_PIPE_MAX_DELAYr �sleepr rx )r r' ZdelayrJ r4 r r r! r� � s � ���� zIocpProactor.connect_pipec C s | � ||d�S rs )�_wait_for_handle)r rJ r� r r r! �wait_for_handle� s z IocpProactor.wait_for_handlec C s | � |d d�}||_|S rk )r� r] )r r^ Z done_callbackrR r r r! ri � 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< )rO r� �r� r r! �finish_wait_for_handle� s z=IocpProactor._wait_for_handle.<locals>.finish_wait_for_handler )r� rM �INFINITE�math�ceilrU r� rw ZRegisterWaitWithQueuer� r' r\ r2 rb r r� )r rJ r� Z _is_cancel�msr rK r� r r� r! r� � s$ � � z IocpProactor._wait_for_handlec C s4 || j vr| j �|� t�|�� | jdd� d S d S rL )rI ry rU 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 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� rP r� r r r! rh s zIocpProactor._unregisterc C s t � |�}|�d� |S rL )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|�� n=|�� s�z5z| ||| �} W n ty� } z|�| � | j�|� W Y d } ~ nd } ~ ww |�| � | j�|� W d }nd }w 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� rU ZGetQueuedCompletionStatusr� r� �pop�KeyErrorr2 Z get_debugr3 r� rM rg r� r0 Zdoner1 r= r� rP r? r� r' r� )r r� r� r �errZ transferredr� r' r� r r� r r� r� r r r! rO sZ �� � �� � � )zIocpProactor._pollc C s | j �|� d S r< )r� ry r� r r r! � _stop_servingI 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+ r/ g �?z,%r is running after closing for %.1f seconds)r� �listr� �itemsZ cancelledr� r\ r0 r1 r2 r r3 �time� monotonicr �debugrO r� rM rg ) r r' rR r r� r r4 r5 Z msg_updateZ start_timeZnext_msgr r r! r O sD � �� � � zIocpProactor.closec C s | � � d S r< )r rN r r r! r� ~ s zIocpProactor.__del__)r r< )r )r N) rB rC rD r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� ri r� r� r� rh r� rO r r r� r r r r! r � s: " 9 /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< )�_procZpollZ_process_exited)r� � returncoderN r r! r � s z4_WindowsSubprocessTransport._start.<locals>.callback) r �Popenr r2 rc r� �intrG r� ) r r� r� r� r� r� r� r� r r� r rN r! �_start� s ��� z"_WindowsSubprocessTransport._startN)rB rC rD r r r r r! r� � s r� c @ � e Zd ZeZdS )r N)rB rC rD r � _loop_factoryr r r r! r � � r c @ r )r N)rB rC rD r r r r r r! r � r r )1�sys�platform� ImportErrorrU rM r� r� r� r� r� r rm � r r r r r r r r �logr �__all__rw r� ZERROR_CONNECTION_REFUSEDZERROR_CONNECTION_ABORTEDr� r� ZFuturer rF r\ rb �objectrj ZBaseSelectorEventLoopr� ZBaseProactorEventLoopr r ZBaseSubprocessTransportr� r ZBaseDefaultEventLoopPolicyr r r r r r r! �<module> sZ 0J4;j f