File "proactor_events.cpython-34.pyc"
Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python34/lib64/python3.4/asyncio/__pycache__/proactor_events.cpython-34.pyc
File size: 17.59 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit
j fN @ s_ d Z d g Z d d l Z d d l Z d d l m Z d d l m Z d d l m Z d d l m Z d d l m Z d d
l m
Z
d d l m Z Gd d
d
e
j
e
j Z Gd d d e e
j Z Gd d d e e
j Z Gd d d e Z Gd d d e e e
j Z Gd d d e e e
j Z Gd d d e j Z d S)zEvent 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)loggerc s e Z d Z d Z d d d f d d Z d d Z d d Z d d
Z d d Z e j
ru d
d Z n d d d Z d d Z
d d Z d d Z S)_ProactorBasePipeTransportz*Base class for pipe and socket transports.Nc s t j | | | j | | | _ | | _ | | _ d | _ d | _ d | _ d | _ d | _
d | _ d | _ | j d k r | j j
n | j j | j j | | d k r | j j t j | d n d S)Nr F)super__init__
_set_extra_sock _protocol_server_buffer _read_fut
_write_fut_pending_write
_conn_lost_closing _eof_writtenZ_attach_loop call_soonZconnection_mader Z _set_result_unless_cancelled)selfloopsockprotocolwaiterextraserver) __class__ </opt/alt/python34/lib64/python3.4/asyncio/proactor_events.pyr
s$
z#_ProactorBasePipeTransport.__init__c C s | j j g } | j d k r. | j d n | j rG | j d n | j d k rs | j d | j j n | j d k r | j d | j n | j d k r | j d | j n | j r t | j } | j d | n | j
r| j d n d d j | S)
Nclosedclosingzfd=%szread=%szwrite=%rzwrite_bufsize=%sz EOF writtenz<%s> ) r" __name__r appendr filenor r r lenr join)r infobufsizer# r# r$ __repr__/ s" z#_ProactorBasePipeTransport.__repr__c C s | | j d <d S)Npipe)_extra)r r r# r# r$ r B s z%_ProactorBasePipeTransport._set_extrac C s | j S)N)r )r r# r# r$
is_closingE s z%_ProactorBasePipeTransport.is_closingc C s | j r
d Sd | _ | j d 7_ | j rW | j d k rW | j j | j d n | j d k r | j j d | _ n d S)NTr ) r r r r r r _call_connection_lostr cancel)r r# r# r$ closeH s
z _ProactorBasePipeTransport.closec C s4 | j d k r0 t j d | t | j n d S)Nzunclosed transport %r)r warningswarnResourceWarningr5 )r r# r# r$ __del__W s z"_ProactorBasePipeTransport.__del__z Fatal error on pipe transportc C s t | t t f rC | j j rr t j d | | d d qr n/ | j j i | d 6| d 6| d 6| j d 6 | j | d S)Nz%r: %sexc_infoTmessage exceptionZ transportr )
isinstanceBrokenPipeErrorConnectionResetErrorr get_debugr
debugcall_exception_handlerr _force_close)r excr; r# r# r$ _fatal_error\ s z'_ProactorBasePipeTransport._fatal_errorc C s | j r
d Sd | _ | j d 7_ | j rG | j j d | _ n | j ri | j j d | _ n d | _ d | _ | j j | j | d S)NTr r )
r r r r4 r r r r r r3 )r rD r# r# r$ rC i s
z'_ProactorBasePipeTransport._force_closec C s z | j j | Wd t | j d r? | j j t j n | j j d | _ | j } | d k r | j d | _ n Xd S)Nshutdown)
r Zconnection_losthasattrr rF socketZ SHUT_RDWRr5 r Z_detach)r rD r! r# r# r$ r3 x s
z0_ProactorBasePipeTransport._call_connection_lostc C s2 | j } | j d k r. | t | j 7} n | S)N)r r r+ )r sizer# r# r$ get_write_buffer_size s z0_ProactorBasePipeTransport.get_write_buffer_size)r(
__module__ __qualname____doc__r
r/ r r2 r5 r ZPY34r9 rE rC r3 rJ r# r# )r" r$ r s
r c sX e Z d Z d Z d d d f d d Z d d Z d d Z d d d
Z S) _ProactorReadPipeTransportzTransport for read pipes.Nc s? t j | | | | | | d | _ | j j | j d S)NF)r r
_pausedr r
_loop_reading)r r r r r r r! )r" r# r$ r
s z#_ProactorReadPipeTransport.__init__c C s_ | j r t d n | j r0 t d n d | _ | j j r[ t j d | n d S)Nz#Cannot pause_reading() when closingzAlready pausedTz%r pauses reading)r RuntimeErrorrO r r@ r
rA )r r# r# r$
pause_reading s z(_ProactorReadPipeTransport.pause_readingc C sm | j s t d n d | _ | j r. d S| j j | j | j | j j ri t j d | n d S)Nz
Not pausedFz%r resumes reading)
rO rQ r r r rP r r@ r
rA )r r# r# r$ resume_reading s z)_ProactorReadPipeTransport.resume_readingc C s% | j r
d Sd } zy | d k rj | j | k sR | j d k rL | j sR t d | _ | j } n | j r} d } d S| d k r d S| j j j | j d | _ Wn t k
r} zF | j s | j
| d n% | j j rt j
d d d n WYd d } ~ Xn t k
rE} z | j | WYd d } ~ Xnk t k
ry} z | j
| d WYd d } ~ Xn7 t j k
r| j s n Yn X| j j | j Wd | r| j j | nS | d k r | j j rt j
d | n | j j } | s | j q n Xd S)N i z"Fatal read error on pipe transportz*Read error on pipe transport while closingr: Tz%r received EOF)rO r r AssertionErrorresultr _proactorrecvr ConnectionAbortedErrorrE r@ r
rA r? rC OSErrorr CancelledErroradd_done_callbackrP r Z
data_receivedZ eof_receivedr5 )r futdatarD Z keep_openr# r# r$ rP sJ " " z(_ProactorReadPipeTransport._loop_reading)r( rK rL rM r
rR rS rP r# r# )r" r$ rN s
rN c @ sX e Z d Z d Z d d Z d d d d Z d d Z d d
Z d d Z d S)
_ProactorBaseWritePipeTransportzTransport for write pipes.c C s t | t t t f s0 t d t | n | j rH t d n | sR d S| j r | j t j
k r} t j d n | j d 7_ d S| j
d k r | j d k s t | j d t | n? | j s t | | _ | j n | j j | | j d S)Nz#data argument must be byte-ish (%r)zwrite_eof() already calledz socket.send() raised exception.r r^ )r= bytes bytearray
memoryview TypeErrortyper rQ r r Z!LOG_THRESHOLD_FOR_CONNLOST_WRITESr
warningr r rU
_loop_writing_maybe_pause_protocolextend)r r^ r# r# r$ write s(
z%_ProactorBaseWritePipeTransport.writeNc C s y7| | j k s t d | _ d | _ | r= | j n | d k r^ | j } d | _ n | s | j r | j j | j d n | j r | j
j t j
n | j n | j j j | j
| | _ | j j s#| j d k s t t | | _ | j j | j | j n | j j | j Wnf t k
rk} z | j | WYd d } ~ Xn5 t k
r} z | j | d WYd d } ~ Xn Xd S)Nr z#Fatal write error on pipe transport)r rU r rV r r r r r3 r r rF rH SHUT_WRZ_maybe_resume_protocolrW senddoner+ r\ rf rg r? rC rZ rE )r fr^ rD r# r# r$ rf s4
z-_ProactorBaseWritePipeTransport._loop_writingc C s d S)NTr# )r r# r# r$
can_write_eof( s z-_ProactorBaseWritePipeTransport.can_write_eofc C s | j d S)N)r5 )r r# r# r$ write_eof+ s z)_ProactorBaseWritePipeTransport.write_eofc C s | j d d S)N)rC )r r# r# r$ abort. s z%_ProactorBaseWritePipeTransport.abort) r( rK rL rM ri rf rn ro rp r# r# r# r$ r_ s ## r_ c s. e Z d Z f d d Z d d Z S)_ProactorWritePipeTransportc sH t j | | | j j j | j d | _ | j j | j d S)N ) r r
r rW rX r r r\ _pipe_closed)r argskw)r" r# r$ r
3 s z$_ProactorWritePipeTransport.__init__c C s | j r d S| j d k s( t | j rJ | j d k sF t d S| | j k sn t | | j f d | _ | j d k r | j t n
| j d S)NrT ) Z cancelledrV rU r r r rC r> r5 )r r] r# r# r$ rs 8 s $ z(_ProactorWritePipeTransport._pipe_closed)r( rK rL r
rs r# r# )r" r$ rq 2 s rq c @ s. e Z d Z d Z d d Z d d Z d S) _ProactorDuplexPipeTransportzTransport for duplex pipes.c C s d S)NFr# )r r# r# r$ rn M s z*_ProactorDuplexPipeTransport.can_write_eofc C s
t d S)N)NotImplementedError)r r# r# r$ ro P s z&_ProactorDuplexPipeTransport.write_eofN)r( rK rL rM rn ro r# r# r# r$ rv H s rv c @ s: e Z d Z d Z d d Z d d Z d d Z d S) _ProactorSocketTransportz Transport for connected sockets.c C s | | j d <y | j | j d <WnC t j t f k
ri | j j re t j d | d d n Yn Xd | j k r y | j | j d <Wq t j t f k
r | j j r t j d | d d n Yq Xn d S)NrH Zsocknamezgetsockname() failed on %rr: Tpeernamezgetpeername() failed on %r)
r1 Z getsocknamerH errorAttributeErrorr r@ r
re Z getpeername)r r r# r# r$ r Y s
z#_ProactorSocketTransport._set_extrac C s d S)NTr# )r r# r# r$ rn i s z&_ProactorSocketTransport.can_write_eofc C sH | j s | j r d Sd | _ | j d k rD | j j t j n d S)NT)r r r r rF rH rj )r r# r# r$ ro l s
z"_ProactorSocketTransport.write_eofN)r( rK rL rM r rn ro r# r# r# r$ rx T s rx c sK e Z d Z f d d Z d d d d d Z d d d d d d d d
d d d Z d d d
d Z d d d d Z d d d d Z f d d Z d d Z
d d Z d d Z d d Z
d d Z d d Z d! d" Z d d# d$ Z d% d& Z d d d' d( Z d) d* Z d+ d, Z d- d. Z S)/r c sb t j t j d | j j | | _ | | _ d | _ i | _ | j
| | j d S)NzUsing proactor: %s) r r
r
rA r" r( rW _selector_self_reading_future_accept_futuresZset_loop_make_self_pipe)r Zproactor)r" r# r$ r
v s
z BaseProactorEventLoop.__init__Nc C s t | | | | | | S)N)rx )r r r r r r! r# r# r$ _make_socket_transport s z,BaseProactorEventLoop._make_socket_transport server_sideFserver_hostnamer r! c
C s\ t j s t d n t j | | | | | | } t | | | d | d | | j S)NzOProactor event loop requires Python 3.5 or newer (ssl.MemoryBIO) to support SSLr r! )r Z_is_sslproto_availablerw Z SSLProtocolrx Z_app_transport)
r Zrawsockr
sslcontextr r r r r! Z ssl_protocolr# r# r$ _make_ssl_transport s
z)BaseProactorEventLoop._make_ssl_transportc C s t | | | | | S)N)rv )r r r r r r# r# r$ _make_duplex_pipe_transport s z1BaseProactorEventLoop._make_duplex_pipe_transportc C s t | | | | | S)N)rN )r r r r r r# r# r$ _make_read_pipe_transport s z/BaseProactorEventLoop._make_read_pipe_transportc C s t | | | | | S)N)rq )r r r r r r# r# r$ _make_write_pipe_transport s z0BaseProactorEventLoop._make_write_pipe_transportc so | j r t d n | j r+ d S| j | j | j j d | _ d | _ t j d S)Nz!Cannot close a running event loop) Z
is_runningrQ is_closed_stop_accept_futures_close_self_piperW r5 r| r )r )r" r# r$ r5 s
zBaseProactorEventLoop.closec C s | j j | | S)N)rW rX )r r nr# r# r$ sock_recv s z BaseProactorEventLoop.sock_recvc C s | j j | | S)N)rW rk )r r r^ r# r# r$ sock_sendall s z"BaseProactorEventLoop.sock_sendallc C sv y t j | | WnH t k
r^ } z( t j d | } | j | | SWYd d } ~ Xn X| j j | | Sd S)Nr )r Z_check_resolved_address
ValueErrorr ZFutureZ
set_exceptionrW Zconnect)r r Zaddresserrr] r# r# r$ sock_connect s
z"BaseProactorEventLoop.sock_connectc C s | j j | S)N)rW accept)r r r# r# r$ sock_accept s z!BaseProactorEventLoop.sock_acceptc C s
t d S)N)rw )r r# r# r$ _socketpair s z!BaseProactorEventLoop._socketpairc C sg | j d k r( | j j d | _ n | j j d | _ | j j d | _ | j d 8_ d S)Nr )r} r4 _ssockr5 _csock
_internal_fds)r r# r# r$ r s
z&BaseProactorEventLoop._close_self_pipec C s[ | j \ | _ | _ | j j d | j j d | j d 7_ | j | j d S)NFr )r r r Z setblockingr r _loop_self_reading)r r# r# r$ r s
z%BaseProactorEventLoop._make_self_pipec C s y5 | d k r | j n | j j | j d } Wn_ t j k
rP d SYn` t k
r } z' | j i d d 6| d 6| d 6 WYd d } ~ Xn X| | _ | j | j
d S)Ni z.Error on reading from the event loop self piper; r< r ) rV rW rX r r r[ ExceptionrB r} r\ r )r rm rD r# r# r$ r s
z(BaseProactorEventLoop._loop_self_readingc C s | j j d d S)Ns )r rk )r r# r# r$ _write_to_self s z$BaseProactorEventLoop._write_to_selfc s5 d f d d j d S)Nc s y | d k r | j \ } } j rC t j d | | n } d k r j | | d d d i | d 6d q j | | d i | d 6d n j r d S j j } Wn t k
rZ} zh j
d k r& j i d d 6| d
6 d 6 j n" j rHt j d d
d n WYd d } ~ Xn? t
j k
rx j Yn! X| j j
<| j d S)Nz#%r got a new connection from %r: %rr Tr ry r! r zAccept failed on a socketr; r< rH zAccept failed on socket %rr: )rV Z_debugr
rA r r r rW r rZ r* rB r5 r r[ r~ r\ )rm ZconnZaddrr rD )r protocol_factoryr r! r r r# r$ r s>
"z2BaseProactorEventLoop._start_serving.<locals>.loop)r )r r r r 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 s5 x! | j j D] } | j q W| j j d S)N)r~ valuesr4 clear)r Zfuturer# r# r$ r s z*BaseProactorEventLoop._stop_accept_futuresc C s( | j | j j | | j d S)N)r rW
_stop_servingr5 )r r r# r# r$ r # s
z#BaseProactorEventLoop._stop_serving)r( rK rL r
r r r r r r5 r r r r r r r r r r r r r r# r# )r" r$ r t s4
( )rM __all__rH r6 r r r r r r logr
Z_FlowControlMixinZ
BaseTransportr Z
ReadTransportrN ZWriteTransportr_ rq Z Transportrv rx Z
BaseEventLoopr r# r# r# r$ <module> s0 z M S