a DOgN@sbddlZddlZddlZddlZddlZddlZddlmZmZm Z m Z m Z m Z m Z mZmZmZmZmZmZee e e eeehZzeWneyiZYn0ddZGdddeZeeefZddZd d Zd d Z d dZ!d%ddZ"d&ddZ#e#Z$d'ddZ%GdddZ&Gddde&Z'ddZ(d(ddZ)ej*d kr^Gd!d"d"Z+Gd#d$d$e&Z,dS))N) EALREADY EINPROGRESS EWOULDBLOCK ECONNRESETEINVALENOTCONN ESHUTDOWNEISCONNEBADF ECONNABORTEDEPIPEEAGAIN errorcodec CsFz t|WStttfy@|tvr4t|YSd|YS0dS)NzUnknown error %s)osstrerror ValueError OverflowError NameErrorr)errr /usr/lib64/python3.9/asyncore.py _strerrorDs   rc@s eZdZdS)ExitNowN)__name__ __module__ __qualname__rrrrrLsrcCs8z |Wn&ty Yn|Yn0dSN)handle_read_event_reraised_exceptions handle_errorobjrrrreadQs   r"cCs8z |Wn&ty Yn|Yn0dSr)handle_write_eventrrr rrrwriteYs   r$cCs8z |Wn&ty Yn|Yn0dSr)handle_expt_eventrrr rrr _exceptionas   r&c CszX|tj@r||tj@r&||tj@r8||tjtjBtj B@rV| Wnht y}z,|j dt vr|n| WYd}~n.d}~0tyYn|Yn0dSNr)selectPOLLINrPOLLOUTr#POLLPRIr%POLLHUPPOLLERRPOLLNVAL handle_closeOSErrorargs _DISCONNECTEDrr)r!flagserrr readwriteis"      r5c Cs<|dur t}|r8g}g}g}t|D]L\}}|}|}|rP|||rd|jsd|||sl|r*||q*g|kr|kr|krnnt|dSt ||||\}}}|D] }| |}|durqt |q|D]"}| |}|durqt |q|D]&}| |}|dur,qt |qdSr) socket_maplistitemsreadablewritableappend acceptingtimesleepr(getr"r$r&) timeoutmaprwr4fdr!Zis_rZis_wrrrpoll}s@     "        rFcCs|dur t}|dur t|d}t}|rt|D]L\}}d}|r\|tjtjBO}| rt|j st|tj O}|r8| ||q8||}|D]&\}}| |}|durqt||qdS)Nir)r7intr(rFr8r9r:r)r+r;r=r*registerr@r5)rArBZpollsterrEr!r3rCrrrpoll2s(     rI>@FcCsb|dur t}|r ttdr t}nt}|dur>|r^|||q,n |r^|dkr^||||d}q>dS)NrFr)r7hasattrr(rIrF)rAZuse_pollrBcountZpoll_funrrrloops  rNc@s2eZdZdZdZdZdZdZdZe dhZ dAddZ ddZ dBdd Z dCd d Zejejfd d ZdDddZddZddZddZddZddZddZddZddZd d!Zd"d#Zd$d%ZdEd'd(Zd)d*Z d+d,Z!d-d.Z"d/d0Z#d1d2Z$d3d4Z%d5d6Z&d7d8Z'd9d:Z(d;d<Z)d=d>Z*d?d@Z+dS)F dispatcherFNwarningc Cs|durt|_n||_d|_|r|d|||d|_z||_Wqty}z2|j dt t fvrtd|_n | |WYd}~qd}~00nd|_ dS)NFTr)r7_map_fileno setblocking set_socket connected getpeernameaddrr0r1rr del_channelsocket)selfsockrBrrrr__init__s    zdispatcher.__init__cCs|jjd|jjg}|jr.|jr.|dn|jr>|d|jdurz|d|jWn"ty~|t|jYn0dd |t |fS)N.Z listeningrUz%s:%dz <%s at %#x> ) __class__rrr=rWr<rU TypeErrorreprjoinid)rZstatusrrr__repr__s     zdispatcher.__repr__cCs|dur|j}|||j<dSr)rQrR)rZrBrrr add_channel szdispatcher.add_channelcCs,|j}|dur|j}||vr"||=d|_dSr)rRrQ)rZrBrErrrrXs zdispatcher.del_channelcCs.||f|_t||}|d||dS)NF)Zfamily_and_typerYrSrT)rZfamilytyper[rrr create_sockets   zdispatcher.create_socketcCs||_||_||dSr)rYfilenorRrfrZr[rBrrrrTs zdispatcher.set_socketcCsBz*|jtjtj|jtjtjdBWnty<Yn0dS)NrK)rY setsockopt SOL_SOCKET SO_REUSEADDR getsockoptr0rZrrrset_reuse_addr#s  zdispatcher.set_reuse_addrcCsdSNTrrprrrr:4szdispatcher.readablecCsdSrrrrprrrr;7szdispatcher.writablecCs(d|_tjdkr|dkrd}|j|S)NTnt)r=rnamerYlisten)rZnumrrrrv>szdispatcher.listencCs||_|j|Sr)rWrYbind)rZrWrrrrxDszdispatcher.bindcCspd|_d|_|j|}|tttfvs8|tkrBtj dkrB||_ dS|dt fvr^||_ | nt |t|dS)NFTrsr)rU connectingrY connect_exrrrrrrurWr handle_connect_eventr0r)rZaddressrrrrconnectHs   zdispatcher.connectc Cszz|j\}}WnZty&YdStyl}z0|jdtttfvrVWYd}~dSWYd}~nd}~00||fSdSr')rYacceptr`r0r1rr r )rZconnrWwhyrrrr~Vs zdispatcher.acceptc Cs~z|j|}|WStyx}zN|jdtkr>WYd}~dS|jdtvrb|WYd}~dSWYd}~n d}~00dSr')rYsendr0r1rr2r/)rZdataresultrrrrrds zdispatcher.sendc Csxz(|j|}|s |WdS|WSWnJtyr}z2|jdtvr\|WYd}~dSWYd}~n d}~00dS)Nr)rYrecvr/r0r1r2)rZZ buffer_sizerrrrrrqs  zdispatcher.recvc Cspd|_d|_d|_||jdurlz|jWn8tyj}z |jdtt fvrVWYd}~n d}~00dS)NFr) rUr=ryrXrYcloser0r1rr )rZrrrrrs zdispatcher.closecCstjdt|dS)Nzlog: %s )sysstderrr$str)rZmessagerrrlogszdispatcher.loginfocCs||jvrtd||fdS)Nz%s: %s)ignore_log_typesprint)rZrrhrrrlog_infos zdispatcher.log_infocCs:|jr|n&|js.|jr$||n|dSr)r= handle_acceptrUryr{ handle_readrprrrrs  zdispatcher.handle_read_eventcCs@|jtjtj}|dkr(t|t||d|_d|_dS)NrTF) rYrormSO_ERRORr0rhandle_connectrUryrZrrrrr{s zdispatcher.handle_connect_eventcCs*|jr dS|js|jr||dSr)r=rUryr{ handle_writerprrrr#s zdispatcher.handle_write_eventcCs0|jtjtj}|dkr$|n|dSr')rYrormrr/ handle_exptrrrrr%s zdispatcher.handle_expt_eventcCsXt\}}}}z t|}Wndt|}Yn0|d||||fd|dS)Nz)<__repr__(self) failed for object at %0x>z:uncaptured python exception, closing channel %s (%s:%s %s)error)compact_tracebackrarcrr/)rZniltvtbinfoZ self_reprrrrrs  zdispatcher.handle_errorcCs|dddS)Nz!unhandled incoming priority eventrPrrprrrrszdispatcher.handle_exptcCs|dddS)Nzunhandled read eventrPrrprrrrszdispatcher.handle_readcCs|dddS)Nzunhandled write eventrPrrprrrrszdispatcher.handle_writecCs|dddS)Nzunhandled connect eventrPrrprrrrszdispatcher.handle_connectcCs|}|dur|j|dSr)r~handle_accepted)rZZpairrrrrszdispatcher.handle_acceptcCs||dddS)Nzunhandled accepted eventrP)rr)rZr[rWrrrrszdispatcher.handle_acceptedcCs|dd|dS)Nzunhandled close eventrP)rrrprrrr/s zdispatcher.handle_close)NN)N)N)N)r),rrrdebugrUr=ryclosingrW frozensetrr\rerfrXrYAF_INET SOCK_STREAMrirTrqr:r;rvrxr}r~rrrrrrr{r#r%rrrrrrrr/rrrrrOsJ         rOc@s6eZdZd ddZddZddZdd Zd d ZdS) dispatcher_with_sendNcCst|||d|_dS)Nr)rOr\ out_bufferrkrrrr\szdispatcher_with_send.__init__cCs.d}t||jdd}|j|d|_dS)Nri)rOrr)rZZnum_sentrrr initiate_sendsz"dispatcher_with_send.initiate_sendcCs |dSr)rrprrrrsz!dispatcher_with_send.handle_writecCs|j pt|jSr)rUlenrrprrrr;szdispatcher_with_send.writablecCs0|jr|dt||j||_|dS)Nz sending %s)rrrarr)rZrrrrr s zdispatcher_with_send.send)NN)rrrr\rrr;rrrrrrs  rcCst\}}}g}|std|rL||jjj|jjjt|j f|j }q~|d\}}}d dd|D}|||f|||fS)Nztraceback does not existr^cSsg|] }d|qS)z [%s|%s|%s]r).0xrrr &rz%compact_traceback..) rexc_infoAssertionErrorr<tb_framef_code co_filenameco_namer tb_linenotb_nextrb)rrtbrfilefunctionlinerrrrrsrc Cs|dur t}t|D]n}z |Wqtyb}z"|jdtkrHn|sNWYd}~qd}~0tytYq|sYq0q|dSr') r7r8valuesrr0r1r rclear)rBZ ignore_allrrrr close_all)s    rposixc@sNeZdZddZddZddZddZdd d ZeZeZ d d Z ddZ d S) file_wrappercCst||_dSr)rduprErZrErrrr\Nszfile_wrapper.__init__cCs*|jdkrtjd|t|d|dS)Nrzunclosed file %r)source)rEwarningswarnResourceWarningrrprrr__del__Qs   zfile_wrapper.__del__cGstj|jg|RSr)rr"rErZr1rrrrWszfile_wrapper.recvcGstj|jg|RSr)rr$rErrrrrZszfile_wrapper.sendNcCs(|tjkr|tjkr|sdStddS)Nrz-Only asyncore specific behaviour implemented.)rYrmrNotImplementedError)rZlevelZoptnamebuflenrrrro]s zfile_wrapper.getsockoptcCs(|jdkrdS|j}d|_t|dS)Nrr)rErrrrrrrhs  zfile_wrapper.closecCs|jSr)rErprrrrjoszfile_wrapper.fileno)N) rrrr\rrrror"r$rrjrrrrrIs rc@seZdZdddZddZdS)file_dispatcherNcCsNt|d|d|_z |}Wnty2Yn0||t|ddS)NTF)rOr\rUrjAttributeErrorset_filer set_blocking)rZrErBrrrr\ts   zfile_dispatcher.__init__cCs"t||_|j|_|dSr)rrYrjrRrfrrrrrs  zfile_dispatcher.set_file)N)rrrr\rrrrrrrs r)r6N)r6N)rJFNN)NF)-r(rYrr>rrerrnorrrrrrrr r r r r rrr2r7rr ExceptionrKeyboardInterrupt SystemExitrr"r$r&r5rFrIZpoll3rNrOrrrrurrrrrr1sB<     '  *  )