]N @ s d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z m Z m Z m
Z
m Z m Z m
Z
m Z m Z m Z m Z m Z m Z e e
e e
e e e h Z y e Wn e k
r i Z Yn Xd d Z Gd d d e Z e e e f Z d d Z d d
Z d d Z d
d Z! d d d d Z" d d d d Z# e# Z$ d d d d d d Z% Gd d d Z& Gd d d e& Z' d d Z( d d d d Z) e j* d k rGd! d" d" Z+ Gd# d$ d$ e& Z, d S)% N)
EALREADY EINPROGRESS EWOULDBLOCK
ECONNRESETEINVALENOTCONN ESHUTDOWNEISCONNEBADF ECONNABORTEDEPIPEEAGAIN errorcodec
C sO y t j | SWn7 t t t f k
rJ | t k r> t | Sd | SYn Xd S)NzUnknown error %s)osstrerror
ValueError
OverflowError NameErrorr )err r -/opt/alt/python35/lib64/python3.5/asyncore.py _strerrorD s r c @ s e Z d Z d S)ExitNowN)__name__
__module__ __qualname__r r r r r L s r c C s; y | j Wn& t k
r% Yn | j Yn Xd S)N)handle_read_event_reraised_exceptions handle_error)objr r r readQ s
r c C s; y | j Wn& t k
r% Yn | j Yn Xd S)N)handle_write_eventr r )r r r r writeY s
r" c C s; y | j Wn& t k
r% Yn | j Yn Xd S)N)handle_expt_eventr r )r r r r
_exceptiona s
r$ c C s yn | t j @r | j | t j @r1 | j | t j @rH | j | t j t j Bt j B@rm | j
Wnt t k
r } z/ | j d t
k r | j n
| j
WYd d } ~ Xn& t k
r Yn | j Yn Xd S)Nr )selectPOLLINr POLLOUTr! POLLPRIr# POLLHUPPOLLERRPOLLNVAL handle_closeOSErrorargs
_DISCONNECTEDr r )r flagser r r readwritei s"
r2 g c C s | d k r t } | rg } g } g } x t | j D]m \ } } | j } | j } | rt | j | | r | j r | j | | s | r= | j | q= Wg | k o | k o | k n r t j | d St j | | | | \ } } } x6 | D]. } | j
| } | d k r2qt | qWx6 | D]. } | j
| } | d k rkqGt | qGWx6 | D]. } | j
| } | d k rqt
| qWd S)N)
socket_maplistitemsreadablewritableappend acceptingtimesleepr% getr r" r$ ) timeoutmaprwr1 fdr Zis_rZis_wr r r poll} sD
'
!
rB c C s | d k r t } | d k r. t | d } t j } | rx t | j D]k \ } } d } | j r | t j t j BO} | j r | j
r | t j O} | rS | j | | qS W| j | } x? | D]7 \ } } | j
| } | d k rq t | | q Wd S)Ni r )r3 intr% rB r4 r5 r6 r& r( r7 r9 r' registerr< r2 )r= r> ZpollsterrA r r0 r? r r r poll2 s(
rE g >@Fc C s | d k r t } | r0 t t d r0 t } n t } | d k r_ xJ | r[ | | | qE Wn0 x- | r | d k r | | | | d } qb Wd S)NrB r )r3 hasattrr% rE rB )r= Zuse_pollr> countZpoll_funr r r loop s
rI c @ s e Z d Z d Z d Z d Z d Z d Z d Z e d h Z
d d d d Z d d Z e Z
d d d Z d d
d Z e j e j d d
Z d 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 Z d d! Z d" d# Z d$ d% Z d& d' d( Z d) d* Z! d+ d, Z" d- d. Z# d/ d0 Z$ d1 d2 Z% d3 d4 Z& d5 d6 Z' d7 d8 Z( d9 d: Z) d; d< Z* d= d> Z+ d? d@ Z, d S)A
dispatcherFNwarningc C s | d k r t | _ n | | _ d | _ | r | j d | j | | d | _ y | j | _ Wq t k
r } z: | j d t
t f k r d | _ n | j | WYd d } ~ Xq Xn d | _
d S)Nr TF)r3 _map_fileno setblocking
set_socket connected getpeernameaddrr- r. r r del_channelsocket)selfsockr> r r r r __init__ s
zdispatcher.__init__c C s | j j d | j j g } | j r? | j r? | j d n | j rU | j d | j d k r y | j d | j Wn( t k
r | j t | j Yn Xd d j | t
| f S)N.Z listeningrP z%s:%dz <%s at %#x> ) __class__r r r9 rR r8 rP TypeErrorreprjoinid)rU statusr r r __repr__ s
zdispatcher.__repr__c C s& | d k r | j } | | | j r r r add_channel s zdispatcher.add_channelc C s> | j } | d k r | j } | | k r1 | | =d | _ d S)N)rM rL )rU r> rA r r r rS s zdispatcher.del_channelc C s? | | f | _ t j | | } | j d | j | d S)Nr )Zfamily_and_typerT rN rO )rU familytyperV r r r
create_socket s
zdispatcher.create_socketc C s) | | _ | j | _ | j | d S)N)rT filenorM ra )rU rV r> r r r rO s zdispatcher.set_socketc C sR y9 | j j t j t j | j j t j t j d B Wn t k
rM Yn Xd S)NrF )rT
setsockopt
SOL_SOCKET SO_REUSEADDR
getsockoptr- )rU r r r set_reuse_addr& s
zdispatcher.set_reuse_addrc C s d S)NTr )rU r r r r6 7 s zdispatcher.readablec C s d S)NTr )rU r r r r7 : s zdispatcher.writablec C s: d | _ t j d k r* | d k r* d } | j j | S)NTnt )r9 r namerT listen)rU numr r r rn A s zdispatcher.listenc C s | | _ | j j | S)N)rR rT bind)rU rR r r r rp G s zdispatcher.bindc C s d | _ d | _ | j j | } | t t t f k sT | t k ra t j d k ra | | _
d S| d t f k r | | _
| j n t
| t | d S)NFTrk cer )rk rq )rP
connectingrT
connect_exr r r r r rm rR r handle_connect_eventr- r )rU addressr r r r connectK s
zdispatcher.connectc C s y | j j \ } } Wn] t k
r1 d SYnR t k
rx } z( | j d t t t f k rc d S WYd d } ~ Xn X| | f Sd S)Nr )rT acceptr[ r- r. r r r
)rU connrR whyr r r rw Y s
zdispatcher.acceptc C s y | j j | } | SWn` t k
r| } z@ | j d t k rF d S| j d t k rg | j d S WYd d } ~ Xn Xd S)Nr )rT sendr- r. r r/ r, )rU dataresultry r r r rz g s
zdispatcher.sendc C s~ y. | j j | } | s) | j d S| SWnI t k
ry } z) | j d t k rd | j d S WYd d } ~ Xn Xd S)N r )rT recvr, r- r. r/ )rU Z buffer_sizer{ ry r r r r~ t s
zdispatcher.recvc C s d | _ d | _ d | _ | j | j d k r y | j j WnA t k
r } z! | j d t t f k rv WYd d } ~ Xn Xd S)NFr )
rP r9 rr rS rT closer- r. r r
)rU ry r r r r s
zdispatcher.closec C s t j j d t | d S)Nzlog: %s
)sysstderrr" str)rU messager r r log s zdispatcher.loginfoc C s' | | j k r# t d | | f d S)Nz%s: %s)ignore_log_typesprint)rU r rc r r r log_info s zdispatcher.log_infoc C sM | j r | j n3 | j s? | j r2 | j | j n
| j d S)N)r9
handle_acceptrP rr rt handle_read)rU r r r r s
z dispatcher.handle_read_eventc C s\ | j j t j t j } | d k r< t | t | | j d | _ d | _ d S)Nr TF) rT ri rg SO_ERRORr- r handle_connectrP rr )rU r r r r rt s
z dispatcher.handle_connect_eventc C s7 | j r
d S| j s) | j r) | j | j d S)N)r9 rP rr rt handle_write)rU r r r r! s
z dispatcher.handle_write_eventc C sB | j j t j t j } | d k r4 | j n
| j d S)Nr )rT ri rg r r, handle_expt)rU r r r r r# s
z dispatcher.handle_expt_eventc C sn t \ } } } } y t | } Wn d t | } Yn X| j d | | | | f d | j d S)Nz)<__repr__(self) failed for object at %0x>z:uncaptured python exception, closing channel %s (%s:%s %s)error)compact_tracebackr\ r^ r r, )rU niltvtbinfoZ self_reprr r r r s zdispatcher.handle_errorc C s | j d d d S)Nz!unhandled incoming priority eventrK )r )rU r r r r s zdispatcher.handle_exptc C s | j d d d S)Nzunhandled read eventrK )r )rU r r r r s zdispatcher.handle_readc C s | j d d d S)Nzunhandled write eventrK )r )rU r r r r s zdispatcher.handle_writec C s | j d d d S)Nzunhandled connect eventrK )r )rU r r r r s zdispatcher.handle_connectc C s) | j } | d k r% | j | d S)N)rw handle_accepted)rU Zpairr r r r s zdispatcher.handle_acceptc C s | j | j d d d S)Nzunhandled accepted eventrK )r r )rU rV rR r r r r s
zdispatcher.handle_acceptedc C s | j d d | j d S)Nzunhandled close eventrK )r r )rU r r r r, s zdispatcher.handle_close)-r r r debugrP r9 rr closingrR frozensetr rW r` __str__ra rS rT AF_INET SOCK_STREAMrd rO rj r6 r7 rn rp rv rw rz r~ r r r r rt r! r# r r r r r r r r, r r r r rJ sL
rJ c @ sR e Z d Z d d d d Z d d Z d d Z d d Z d
d Z d S) dispatcher_with_sendNc C s t j | | | d | _ d S)Nr} )rJ rW
out_buffer)rU rV r> r r r rW s z dispatcher_with_send.__init__c C s? d } t j | | j d d } | j | d | _ d S)Nr i )rJ rz r )rU Znum_sentr r r
initiate_send s z"dispatcher_with_send.initiate_sendc C s | j d S)N)r )rU r r r r s z!dispatcher_with_send.handle_writec C s | j p t | j S)N)rP lenr )rU r r r r7 s z dispatcher_with_send.writablec C s> | j r | j d t | | j | | _ | j d S)Nz
sending %s)r r r\ r r )rU r{ r r r rz s zdispatcher_with_send.send)r r r rW r r r7 rz r r r r r s
r c C s t j \ } } } g } | s- t d xD | rs | j | j j j | j j j t | j f | j
} q0 W~ | d \ } } } d j d d | D } | | | f | | | f S)Nztraceback does not existrF rY c S s g | ] } d | q S)z
[%s|%s|%s]r ).0xr r r
) s z%compact_traceback..) r exc_infoAssertionErrorr8 tb_framef_code co_filenameco_namer tb_linenotb_nextr] )r r tbr filefunctionliner r r r r s
r c C s | d k r t } x t | j D] } y | j Wq% t k
r } z$ | j d t k rd n | sm WYd d } ~ Xq% t k
r Yq% | s Yq% Xq% W| j d S)Nr ) r3 r4 valuesr r- r. r
r clear)r> Z
ignore_allr r r r close_all, s
r posixc @ ss e Z d Z d d Z d d Z d d Z d d Z d d
d Z e Z e Z d d
Z
d d Z d S) file_wrapperc C s t j | | _ d S)N)r duprA )rU rA r r r rW Q s zfile_wrapper.__init__c C s1 | j d k r# t j d | t | j d S)Nr zunclosed file %r)rA warningswarnResourceWarningr )rU r r r __del__T s zfile_wrapper.__del__c G s t j | j | S)N)r r rA )rU r. r r r r~ Y s zfile_wrapper.recvc G s t j | j | S)N)r r" rA )rU r. r r r rz \ s zfile_wrapper.sendNc C s9 | t j k r) | t j k r) | r) d St d d S)Nr z-Only asyncore specific behaviour implemented.)rT rg r NotImplementedError)rU levelZoptnamebuflenr r r ri _ s
zfile_wrapper.getsockoptc C s0 | j d k r d St j | j d | _ d S)Nr rF r )rA r r )rU r r r r j s zfile_wrapper.closec C s | j S)N)rA )rU r r r re p s zfile_wrapper.fileno) r r r rW r r~ rz ri r r" r re r r r r r L s r c @ s+ e Z d Z d d d Z d d Z d S)file_dispatcherNc C sb t j | d | d | _ y | j } Wn t k
r@ Yn X| j | t j | d d S)NTF)rJ rW rP re AttributeErrorset_filer set_blocking)rU rA r> r r r rW u s
zfile_dispatcher.__init__c C s/ t | | _ | j j | _ | j d S)N)r rT re rM ra )rU rA r r r r s zfile_dispatcher.set_file)r r r rW r r r r r r s s r )-r% rT r r: r r errnor r r r r r r r r
r r r
r r r/ r3 r r Exceptionr KeyboardInterrupt
SystemExitr r r" r$ r2 rB rE Zpoll3rI rJ r r r rm r r r r r r 1 s> X
' , '