Edit File: proactor_events.cpython-37.pyc
B l}�c5d � @ s d Z dZddlZddlZddlZddlZddlmZ ddlmZ ddlm Z ddlm Z dd lm Z dd lm Z dd lm Z dd lmZ G d d� de je j�ZG dd� dee j�ZG dd� dee j�ZG dd� de�ZG dd� deee j�ZG dd� deee j�ZG dd� dej�Z dS )z�Event loop using a proactor and related classes. A proactor is a "notify-on-completion" multiplexer. Currently a proactor is only implemented on Windows with IOCP. )�BaseProactorEventLoop� N� )� base_events)� constants)�events)�futures)� protocols)�sslproto)� transports)�loggerc s| e Zd ZdZd � fdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z d dd�Z dd� Z dd� Zdd� Z� ZS ) �_ProactorBasePipeTransportz*Base class for pipe and socket transports.Nc s� t � �||� | �|� || _| �|� || _d | _d | _d | _d| _ d| _ d| _ d| _ | jd k rl| j� � | j�| jj| � |d k r�| j�tj|d � d S )Nr F)�super�__init__� _set_extra�_sock� set_protocol�_server�_buffer� _read_fut� _write_fut�_pending_write� _conn_lost�_closing� _eof_writtenZ_attach�_loop� call_soon� _protocolZconnection_mader Z _set_result_unless_cancelled)�self�loop�sock�protocol�waiter�extra�server)� __class__� �</opt/alt/python37/lib64/python3.7/asyncio/proactor_events.pyr s$ z#_ProactorBasePipeTransport.__init__c C s� | j jg}| jd kr |�d� n| jr0|�d� | jd k rP|�d| j�� � �� | jd k rl|�d| j��� | jd k r�|�d| j��� | jr�|�dt | j�� �� | j r�|�d� d� d � |��S ) N�closed�closingzfd=zread=zwrite=zwrite_bufsize=z EOF writtenz<{}>� ) r$ �__name__r �appendr �filenor r r �lenr �format�join)r �infor% r% r& �__repr__2 s z#_ProactorBasePipeTransport.__repr__c C s || j d< d S )N�pipe)�_extra)r r r% r% r& r D s z%_ProactorBasePipeTransport._set_extrac C s || _ d S )N)r )r r r% r% r& r G s z'_ProactorBasePipeTransport.set_protocolc C s | j S )N)r )r r% r% r& � get_protocolJ s z'_ProactorBasePipeTransport.get_protocolc C s | j S )N)r )r r% r% r& � is_closingM s z%_ProactorBasePipeTransport.is_closingc C s\ | j r d S d| _ | jd7 _| js>| jd kr>| j�| jd � | jd k rX| j�� d | _d S )NTr ) r r r r r r �_call_connection_lostr �cancel)r r% r% r& �closeP s z _ProactorBasePipeTransport.closec C s, | j d k r(tjd| ��t| d� | �� d S )Nzunclosed transport )�source)r �warnings�warn�ResourceWarningr8 )r r% r% r& �__del__[ s z"_ProactorBasePipeTransport.__del__� Fatal error on pipe transportc C sV zDt |t�r*| j�� rBtjd| |dd� n| j�||| | jd�� W d | �|� X d S )Nz%r: %sT)�exc_info)�message� exceptionZ transportr ) � isinstance�OSErrorr � get_debugr �debug�call_exception_handlerr � _force_close)r �excr@ r% r% r& � _fatal_errora s z'_ProactorBasePipeTransport._fatal_errorc C s� | j d k r6| j �� s6|d kr*| j �d � n | j �|� | jr@d S d| _| jd7 _| jrj| j�� d | _| jr�| j�� d | _d| _ d | _ | j � | j |� d S )NTr r )� _empty_waiter�done� set_resultZ set_exceptionr r r r7 r r r r r r6 )r rH r% r% r& rG p s" z'_ProactorBasePipeTransport._force_closec C s^ z| j �|� W d t| jd�r,| j�tj� | j�� d | _| j}|d k rX|� � d | _X d S )N�shutdown) r Zconnection_lost�hasattrr rM �socketZ SHUT_RDWRr8 r Z_detach)r rH r# r% r% r& r6 � s z0_ProactorBasePipeTransport._call_connection_lostc C s" | j }| jd k r |t| j�7 }|S )N)r r r- )r �sizer% r% r& �get_write_buffer_size� s z0_ProactorBasePipeTransport.get_write_buffer_size)NNN)r> )r* � __module__� __qualname__�__doc__r r1 r r r4 r5 r8 r= rI rG r6 rQ � __classcell__r% r% )r$ r& r s r c sT e Zd ZdZd� fdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z ddd�Z � Z S )�_ProactorReadPipeTransportzTransport for read pipes.Nc s: d | _ d| _t� �||||||� | j�| j� d| _d S )NTF)� _pending_data�_pausedr r r r � _loop_reading)r r r r r! r" r# )r$ r% r& r � s z#_ProactorReadPipeTransport.__init__c C s | j o| j S )N)rX r )r r% r% r& � is_reading� s z%_ProactorReadPipeTransport.is_readingc C s0 | j s | jrd S d| _| j�� r,t�d| � d S )NTz%r pauses reading)r rX r rD r rE )r r% r% r& � pause_reading� s z(_ProactorReadPipeTransport.pause_readingc C sn | j s | jsd S d| _| jd kr0| j�| jd � | j}d | _|d k rT| j�| j|� | j�� rjt � d| � d S )NFz%r resumes reading) r rX r r r rY rW �_data_receivedrD r rE )r �datar% r% r& �resume_reading� s z)_ProactorReadPipeTransport.resume_readingc C sd | j �� rt�d| � y| j�� }W n. tk rR } z| �|d� d S d }~X Y nX |s`| �� d S )Nz%r received EOFz1Fatal error: protocol.eof_received() call failed.) r rD r rE r Z eof_received� ExceptionrI r8 )r Z keep_openrH r% r% r& � _eof_received� s z(_ProactorReadPipeTransport._eof_receivedc C s� | j r | jd kst�|| _d S |s.| �� d S t| jtj�r�yt�| j|� W q� t k r| } z| � |d� d S d }~X Y q�X n | j� |� d S )Nz3Fatal error: protocol.buffer_updated() call failed.) rX rW �AssertionErrorr` rB r r ZBufferedProtocolZ _feed_data_to_buffered_protor_ rI Z data_received)r r] rH r% r% r& r\ � s z)_ProactorReadPipeTransport._data_receivedc C s� d }�z`y~|d k rP| j |ks0| j d kr,| js0t�d | _ |�� rH|�� }n|�� | jr^d }d S |dkrjd S | js�| jj� | j d�| _ W n� t k r� } z0| js�| � |d� n| j� � r�tjddd� W d d }~X Y n� tk r� } z| �|� W d d }~X Y nf tk �r, } z| � |d� W d d }~X Y n8 tjk �rL | j�sH� Y nX | j�sd| j �| j� W d |d k �r|| �|� X d S )N� i � z"Fatal read error on pipe transportz*Read error on pipe transport while closingT)r? )r r ra rK �resultr7 rX r � _proactor�recvr �ConnectionAbortedErrorrI rD r rE �ConnectionResetErrorrG rC r �CancelledError�add_done_callbackrY r\ )r �futr] rH r% r% r& rY � sB z(_ProactorReadPipeTransport._loop_reading)NNN)N) r* rR rS rT r rZ r[ r^ r` r\ rY rU r% r% )r$ r& rV � s rV c s^ e Zd ZdZdZ� fdd�Zdd� Zddd �Zd d � Zd d � Z dd� Z dd� Z dd� Z � Z S )� _ProactorBaseWritePipeTransportzTransport for write pipes.Tc s t � j||� d | _d S )N)r r rJ )r �args�kw)r$ r% r& r . s z(_ProactorBaseWritePipeTransport.__init__c C s� t |tttf�s$tdt|�j� ���| jr2td��| j d k rDtd��|sLd S | j rz| j t j krht �d� | j d7 _ d S | jd kr�| jd ks�t�| jt|�d� n.| js�t|�| _| �� n| j�|� | �� d S )Nz/data argument must be a bytes-like object, not zwrite_eof() already calledz(unable to write; sendfile is in progressz socket.send() raised exception.r )r] )rB �bytes� bytearray� memoryview� TypeError�typer* r � RuntimeErrorrJ r r Z!LOG_THRESHOLD_FOR_CONNLOST_WRITESr �warningr r ra � _loop_writing�_maybe_pause_protocol�extend)r r] r% r% r& �write2 s, z%_ProactorBaseWritePipeTransport.writeNc C sv �y|d k r | j d kr | jr d S || j ks.t�d | _ d| _|rF|�� |d krZ| j}d | _|s�| jrt| j�| jd � | j r�| j � t j � | �� n\| jj�| j |�| _ | j �� s�| jdks�t�t|�| _| j �| j� | �� n| j �| j� | jd k �r| j d k�r| j�d � W n\ tk �rB } z| �|� W d d }~X Y n0 tk �rp } z| �|d� W d d }~X Y nX d S )Nr z#Fatal write error on pipe transport) r r ra r rc r r r r6 r r rM rO �SHUT_WRZ_maybe_resume_protocolrd �sendrK r- ri ru rv rJ rL rg rG rC rI )r �fr] rH r% r% r& ru X s< z-_ProactorBaseWritePipeTransport._loop_writingc C s dS )NTr% )r r% r% r& � can_write_eof� s z-_ProactorBaseWritePipeTransport.can_write_eofc C s | � � d S )N)r8 )r r% r% r& � write_eof� s z)_ProactorBaseWritePipeTransport.write_eofc C s | � d � d S )N)rG )r r% r% r& �abort� s z%_ProactorBaseWritePipeTransport.abortc C s: | j d k rtd��| j�� | _ | jd kr4| j �d � | j S )NzEmpty waiter is already set)rJ rs r Z create_futurer rL )r r% r% r& �_make_empty_waiter� s z2_ProactorBaseWritePipeTransport._make_empty_waiterc C s d | _ d S )N)rJ )r r% r% r& �_reset_empty_waiter� s z3_ProactorBaseWritePipeTransport._reset_empty_waiter)NN)r* rR rS rT Z_start_tls_compatibler rx ru r| r} r~ r r� rU r% r% )r$ r& rk ( s & )rk c s$ e Zd Z� fdd�Zdd� Z� ZS )�_ProactorWritePipeTransportc s4 t � j||� | jj�| jd�| _| j�| j� d S )N� ) r r r rd re r r ri � _pipe_closed)r rl rm )r$ r% r& r � s z$_ProactorWritePipeTransport.__init__c C sv |� � r d S |�� dks t�| jr4| jd ks0t�d S || jksLt|| jf��d | _| jd k rj| �t� � n| �� d S )Nrb ) Z cancelledrc ra r r r rG �BrokenPipeErrorr8 )r rj r% r% r& r� � s z(_ProactorWritePipeTransport._pipe_closed)r* rR rS r r� rU r% r% )r$ r& r� � s r� c @ s e Zd ZdZdd� Zdd� ZdS )� _ProactorDuplexPipeTransportzTransport for duplex pipes.c C s dS )NFr% )r r% r% r& r| � s z*_ProactorDuplexPipeTransport.can_write_eofc C s t �d S )N)�NotImplementedError)r r% r% r& r} � s z&_ProactorDuplexPipeTransport.write_eofN)r* rR rS rT r| r} r% r% r% r& r� � s r� c sB e Zd ZdZejjZd � fdd� Zdd� Z dd� Z d d � Z � Z S ) �_ProactorSocketTransportz Transport for connected sockets.Nc s$ t � �||||||� t�|� d S )N)r r r Z _set_nodelay)r r r r r! r" r# )r$ r% r& r � s z!_ProactorSocketTransport.__init__c C s� || j d< y|�� | j d< W n4 tjtfk rP | j�� rLtjd|dd� Y nX d| j kr�y|� � | j d< W n4 tjtfk r� | j�� r�tjd|dd� Y nX d S )NrO Zsocknamezgetsockname() failed on %rT)r? �peernamezgetpeername() failed on %r) r3 Z getsocknamerO �error�AttributeErrorr rD r rt Z getpeername)r r r% r% r& r � s z#_ProactorSocketTransport._set_extrac C s dS )NTr% )r r% r% r& r| � s z&_ProactorSocketTransport.can_write_eofc C s2 | j s | jrd S d| _| jd kr.| j�tj� d S )NT)r r r r rM rO ry )r r% r% r& r} � s z"_ProactorSocketTransport.write_eof)NNN) r* rR rS rT r Z _SendfileModeZ TRY_NATIVEZ_sendfile_compatibler r r| r} rU r% r% )r$ r& r� � s r� c s� e Zd Z� fdd�Zd1dd�Zd2dddddd�dd �Zd3d d �Zd4d d �Zd5dd�Z� fdd�Z dd� Z dd� Z dd� Z dd� Z dd� Zd d � Zd d � Zd d!� Zd"d#� Zd6d$d%�Zd&d'� Zd7d)d*�Zd+d,� Zd-d.� Zd/d0� Z� ZS )8r c sH t � �� t�d|jj� || _|| _d | _i | _ |� | � | � � d S )NzUsing proactor: %s) r r r rE r$ r* rd � _selector�_self_reading_future�_accept_futuresZset_loop�_make_self_pipe)r Zproactor)r$ r% r& r � s z BaseProactorEventLoop.__init__Nc C s t | |||||�S )N)r� )r r r r! r" r# r% r% r& �_make_socket_transport� s z,BaseProactorEventLoop._make_socket_transportF)� server_side�server_hostnamer" r# �ssl_handshake_timeoutc C s0 t j| |||||| d�} t| || ||d� | jS )N)r� )r" r# )r Z SSLProtocolr� Z_app_transport) r Zrawsockr � sslcontextr! r� r� r" r# r� Z ssl_protocolr% r% r& �_make_ssl_transport� s z)BaseProactorEventLoop._make_ssl_transportc C s t | ||||�S )N)r� )r r r r! r" r% r% r& �_make_duplex_pipe_transport� s z1BaseProactorEventLoop._make_duplex_pipe_transportc C s t | ||||�S )N)rV )r r r r! r" r% r% r& �_make_read_pipe_transport s z/BaseProactorEventLoop._make_read_pipe_transportc C s t | ||||�S )N)r� )r r r r! r" r% r% r& �_make_write_pipe_transport s z0BaseProactorEventLoop._make_write_pipe_transportc sP | � � rtd��| �� r d S | �� | �� | j�� d | _d | _t� �� d S )Nz!Cannot close a running event loop) Z is_runningrs � is_closed�_stop_accept_futures�_close_self_piperd r8 r� r )r )r$ r% r& r8 s zBaseProactorEventLoop.closec � s | j �||�I d H S )N)rd re )r r �nr% r% r& � sock_recv s z BaseProactorEventLoop.sock_recvc � s | j �||�I d H S )N)rd Z recv_into)r r Zbufr% r% r& �sock_recv_into# s z$BaseProactorEventLoop.sock_recv_intoc � s | j �||�I d H S )N)rd rz )r r r] r% r% r& � sock_sendall& s z"BaseProactorEventLoop.sock_sendallc � s | j �||�I d H S )N)rd Zconnect)r r Zaddressr% r% r& � sock_connect) s z"BaseProactorEventLoop.sock_connectc � s | j �|�I d H S )N)rd �accept)r r r% r% r& � sock_accept, s z!BaseProactorEventLoop.sock_acceptc � s( y |� � }W n2 ttjfk r> } zt�d��W d d }~X Y nX yt�|�j}W n, t k r| } zt�d��W d d }~X Y nX |r�|n|}|s�dS t |d�}|r�t || |�n|} t ||�}d} zLxFt | | |�}|dkr�| S | j � ||||�I d H ||7 }| |7 } q�W W d | dk�r"|� |� X d S )Nznot a regular filer l �� )r, r� �io�UnsupportedOperationr ZSendfileNotAvailableError�os�fstat�st_sizerC �minrd �sendfile�seek) r r �file�offset�countr, �errZfsizeZ blocksizeZend_posZ total_sentr% r% r& �_sock_sendfile_native/ s2 z+BaseProactorEventLoop._sock_sendfile_nativec � sV |� � }|�� |�� I d H z | j|j|||dd�I d H S |�� |rP|�� X d S )NF)Zfallback)rZ r[ r Z sock_sendfiler r� r^ )r Ztranspr� r� r� r^ r% r% r& �_sendfile_nativeL s z&BaseProactorEventLoop._sendfile_nativec C sL | j d k r| j �� d | _ | j�� d | _| j�� d | _| jd8 _d S )Nr )r� r7 �_ssockr8 �_csock� _internal_fds)r r% r% r& r� X s z&BaseProactorEventLoop._close_self_pipec C sF t �� \| _| _| j�d� | j�d� | jd7 _| �| j� d S )NFr )rO Z socketpairr� r� Z setblockingr� r �_loop_self_reading)r r% r% r& r� b s z%BaseProactorEventLoop._make_self_pipec C s� y$|d k r|� � | j�| jd�}W nH tjk r: d S tk rl } z| �d|| d�� W d d }~X Y nX || _|� | j � d S )Ni z.Error on reading from the event loop self pipe)r@ rA r ) rc rd re r� r rh r_ rF r� ri r� )r r{ rH r% r% r& r� j s z(BaseProactorEventLoop._loop_self_readingc C s> y| j �d� W n( tk r8 | jr4tjddd� Y nX d S )N� z3Fail to write a null byte into the self-pipe socketT)r? )r� rz rC �_debugr rE )r r% r% r& �_write_to_self| s z$BaseProactorEventLoop._write_to_self�d c s( d� ������fdd� � �� � � d S )Nc s$ y�| d k rn| � � \}}�jr,t�d�||� �� }�d k rX�j||�dd|i��d� n�j||d|i�d� ��� rzd S �j���} W n~ t k r� } zB�� � dkr� d|�d�� �� � n�jr�tjd �dd � W d d }~X Y n8 t jk �r �� � Y nX | �j�� � < | �� � d S ) Nz#%r got a new connection from %r: %rTr� )r� r" r# r� )r" r# ���zAccept failed on a socket)r@ rA rO zAccept failed on socket %r)r? )rc r� r rE r� r� r� rd r� rC r, rF r8 r rh r� ri )r{ ZconnZaddrr rH )r �protocol_factoryr r# r r� r� r% r& r � s@ z2BaseProactorEventLoop._start_serving.<locals>.loop)N)r )r r� r r� r# Zbacklogr� r% )r r� r r# r r� r� r& �_start_serving� s %z$BaseProactorEventLoop._start_servingc C s d S )Nr% )r Z event_listr% r% r& �_process_events� s z%BaseProactorEventLoop._process_eventsc C s* x| j �� D ] }|�� q W | j �� d S )N)r� �valuesr7 �clear)r �futurer% r% r& r� � s z*BaseProactorEventLoop._stop_accept_futuresc C s6 | j �|�� d �}|r |�� | j�|� |�� d S )N)r� �popr, r7 rd � _stop_servingr8 )r r r� r% r% r& r� � s z#BaseProactorEventLoop._stop_serving)NNN)N)NN)NN)NN)N)NNr� N)r* rR rS r r� r� r� r� r� r8 r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� rU r% r% )r$ r& r � s< )r ) rT �__all__r� r� rO r: � r r r r r r r �logr Z_FlowControlMixinZ BaseTransportr Z ReadTransportrV ZWriteTransportrk r� Z Transportr� r� Z BaseEventLoopr r% r% r% r& �<module> s: m '