��Yf�N�@s_dZdgZddlZddlZddlmZddlmZddlmZddlmZdd lm Z dd lm Z ddlmZGdd �d e j e j�ZGdd�dee j�ZGdd�dee j�ZGdd�de�ZGdd�deee j�ZGdd�deee j�ZGdd�dej�ZdS)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)�compat)� constants)�futures)�sslproto)� transports)�loggercs�eZdZdZddd�fdd�Zdd�Zdd�Zd d �Zdd�Zd d�Z dd�Z ejr�dd�Z ddd�Zdd�Zdd�Zdd�Z�S)�_ProactorBasePipeTransportz*Base class for pipe and socket transports.Ncs�t�j||�|j|�||_||_||_d|_d|_d|_d|_ d|_ d|_d|_|jdk r�|jj �|jj|jj|�|dk r�|jjtj|d�dS)NrF)�super�__init__� _set_extra�_sock� _protocol�_server�_buffer� _read_fut� _write_fut�_pending_write� _conn_lost�_closing�_eof_writtenZ_attach�_loop� call_soonZconnection_maderZ_set_result_unless_cancelled)�self�loop�sock�protocol�waiter�extra�server)� __class__�� )r"�__name__r�appendr�filenorrr�lenr�join)r�info�bufsizer#r#r$�__repr__/s" z#_ProactorBasePipeTransport.__repr__cCs||jdr)rVrWrXr�rr\� ExceptionrBr�r]r�)rrorDr#r#r$r��s z(BaseProactorEventLoop._loop_self_readingcCs|jjd�dS)Ns)r�rm)rr#r#r$�_write_to_self�sz$BaseProactorEventLoop._write_to_self�dcs5d��fdd��j��dS)Ncs�y�|dk r�|j�\}}�jr@tjd�||��}�dk r��j||�dddd|id��n"�j||dd|id��j�r�dS�jj��}Wn�t k rL}zb�j �dkr�jdd d |d�i��j�n�jr:tjd�d d�WYdd}~Xn?t jk rj�j�Yn!X|�j�j �<|j��dS)Nz#%r got a new connection from %r: %rr�Tr r|r!rr=zAccept failed on a socketr>rHzAccept failed on socket %rr<��)rVZ_debugr rAr�r�r�rWr�r[r*rBr7rr\r�r])roZconnZaddrrrD)r�protocol_factoryrr!rr�r#r$r�s> z2BaseProactorEventLoop._start_serving..loop)r)rr�rr�r!Zbacklogr#)rr�rr!rr�r$�_start_serving�s$$z$BaseProactorEventLoop._start_servingcCsdS)Nr#)rZ event_listr#r#r$�_process_eventssz%BaseProactorEventLoop._process_eventscCs5x!|jj�D]}|j�qW|jj�dS)N)r��valuesr6�clear)rZfuturer#r#r$r�sz*BaseProactorEventLoop._stop_accept_futurescCs(|j�|jj|�|j�dS)N)r�rW� _stop_servingr7)rrr#r#r$r�#s z#BaseProactorEventLoop._stop_serving)r(rKrLr r�r�r�r�r�r7r�r�r�r�r�r�r�r�r�r�r�r�r�r#r#)r"r$r{s4 ()rM�__all__rHr8�rrrrrr �logr Z_FlowControlMixinZ BaseTransportrZ ReadTransportrNZWriteTransportr`rsZ Transportryr{Z BaseEventLooprr#r#r#r$�s0 �MT