a
XC?h†N ã @ sb d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZ ee
e e
eeehƒZze W n eyž i ZY n0 dd„ ZG dd„ deƒZeee fZ dd„ Z d d
„ Z d d „ Z d
d„ Z!d%dd„Z"d&dd„Z#e#Z$d'dd„Z%G dd„ dƒZ&G dd„ de&ƒZ'd d „ Z(d(d d „Z)ej*d kr^G d!d"„ d"ƒZ+G d#d$„ d$e&ƒZ,dS ))é N)
ÚEALREADYÚ EINPROGRESSÚ EWOULDBLOCKÚ
ECONNRESETÚEINVALÚENOTCONNÚ ESHUTDOWNÚEISCONNÚEBADFÚ ECONNABORTEDÚEPIPEÚEAGAINÚ errorcodec
C sF z t | ¡W S tttfy@ | tv r4t| Y S d| Y S 0 d S )NzUnknown error %s)ÚosÚstrerrorÚ
ValueErrorÚ
OverflowErrorÚ NameErrorr )Úerr© r ú-/opt/alt/python39/lib64/python3.9/asyncore.pyÚ _strerrorD s r c @ s e Zd ZdS )ÚExitNowN)Ú__name__Ú
__module__Ú __qualname__r r r r r L s r c C s8 z | ¡ W n& ty ‚ Y n | ¡ Y n0 d S ©N)Úhandle_read_eventÚ_reraised_exceptionsÚ handle_error©Úobjr r r ÚreadQ s r" c C s8 z | ¡ W n& ty ‚ Y n | ¡ Y n0 d S r )Úhandle_write_eventr r r r r r ÚwriteY s r$ c C s8 z | ¡ W n& ty ‚ Y n | ¡ Y n0 d S r )Úhandle_expt_eventr r r r r r Ú
_exceptiona s r& c
C sÆ zX|t j@ r| ¡ |t j@ r&| ¡ |t j@ r8| ¡ |t jt jB t j B @ rV|
¡ W nh t yœ } z,|j d t
vr€| ¡ n|
¡ W Y d }~n.d }~0 ty® ‚ Y n | ¡ Y n0 d S ©Nr )ÚselectÚPOLLINr ÚPOLLOUTr# ÚPOLLPRIr% ZPOLLHUPZPOLLERRZPOLLNVALÚ handle_closeÚOSErrorÚargsÚ
_DISCONNECTEDr r )r! ÚflagsÚer r r Ú readwritei s"
r2 ç c C s< |d u r t }|r8g }g }g }t| ¡ ƒD ]L\}}| ¡ }| ¡ }|rP| |¡ |rd|jsd| |¡ |sl|r*| |¡ q*g | kr–| kr–|kr¨n nt | ¡ d S t |||| ¡\}}}|D ] }|
|¡}|d u rÚqÂt |ƒ qÂ|D ]"}|
|¡}|d u rqèt |ƒ qè|D ]&}|
|¡}|d u r,qt
|ƒ qd S r )Ú
socket_mapÚlistÚitemsÚreadableÚwritableÚappendÚ acceptingÚtimeÚsleepr( Úgetr" r$ r& ) ÚtimeoutÚmapÚrÚwr1 Úfdr! Zis_rZis_wr r r Úpoll} s@
"
rC c C sÀ |d u r t }| d ur t| d ƒ} t ¡ }|r¼t| ¡ ƒD ]L\}}d}| ¡ r\|tjtjB O }| ¡ rt|j
st|tj O }|r8| ||¡ q8| | ¡}|D ]&\}}|
|¡}|d u r°q”t||ƒ q”d S )Niè r )r4 Úintr( rC r5 r6 r7 r) r+ r8 r: r* Úregisterr= r2 )r> r? ZpollsterrB r! r0 r@ r r r Úpoll2¤ s(
rF ç >@Fc C sb |d u r t }|r ttdƒr t}nt}|d u r>|r^|| |ƒ q,n |r^|dkr^|| |ƒ |d }q>d S )NrC r é )r4 Úhasattrr( rF rC )r> Zuse_pollr? ÚcountZpoll_funr r r ÚloopÀ s
rK c @ s2 e Zd ZdZdZdZdZdZdZe dhƒZ
dAdd„Z dd„ Z dBdd „Z
dCd
d „Zejejfd d
„ZdDdd„Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ Zd d „ Zd d „ Zd d!„ Z d"d#„ Z d$d%„ Z dEd'd(„Z d)d*„ Z d+d,„ Z!d-d.„ Z"d/d0„ Z#d1d2„ Z$d3d4„ Z%d5d6„ Z&d7d8„ Z'd9d:„ Z(d;d<„ Z)d=d>„ Z*d?d@„ Z+dS )FÚ
dispatcherFNÚwarningc
C s¢ |d u rt | _n|| _d | _|r˜| d¡ | ||¡ d| _z| ¡ | _W qž ty” } z2|j d t
t fv rtd| _n | |¡ ‚ W Y d }~qžd }~0 0 nd | _
d S )NFTr )r4 Ú_mapÚ_filenoÚ setblockingÚ
set_socketÚ connectedZ getpeernameÚaddrr- r. r r Ú del_channelÚsocket)ÚselfÚsockr? r r r r Ú__init__Ü s
zdispatcher.__init__c C s– | j jd | j j g}| jr.| jr.| d¡ n| jr>| d¡ | jd ur€z| d| j ¡ W n" ty~ | t| jƒ¡ Y n0 dd |¡t
| ƒf S )NÚ.Z listeningrR z%s:%dz <%s at %#x>ú ) Ú __class__r r r: rS r9 rR Ú TypeErrorÚreprÚjoinÚid)rV Zstatusr r r Ú__repr__ü s
zdispatcher.__repr__c C s |d u r| j }| || j< d S r )rN rO )rV r? r r r Ú add_channel s zdispatcher.add_channelc C s, | j }|d u r| j}||v r"||= d | _ d S r )rO rN )rV r? rB r r r rT s zdispatcher.del_channelc C s. ||f| _ t ||¡}| d¡ | |¡ d S )NF)Zfamily_and_typerU rP rQ )rV ZfamilyÚtyperW r r r Ú
create_socket s
zdispatcher.create_socketc C s || _ | ¡ | _| |¡ d S r )rU ÚfilenorO ra ©rV rW r? r r r rQ s
zdispatcher.set_socketc C sB z*| j t jt j| j t jt j¡dB ¡ W n ty< Y n0 d S )NrH )rU Z
setsockoptÚ
SOL_SOCKETZ SO_REUSEADDRÚ
getsockoptr- ©rV r r r Úset_reuse_addr# s
ÿÿþ zdispatcher.set_reuse_addrc C s dS ©NTr rh r r r r7 4 s zdispatcher.readablec C s dS rj r rh r r r r8 7 s zdispatcher.writablec C s( d| _ tjdkr |dkr d}| j |¡S )NTÚnté )r: r ÚnamerU Úlisten)rV Znumr r r rn > s zdispatcher.listenc C s || _ | j |¡S r )rS rU Úbind)rV rS r r r ro D s zdispatcher.bindc C sp d| _ d| _| j |¡}|tttfv s8|tkrBtj dkrB|| _
d S |dt fv r^|| _
| ¡ nt
|t| ƒ‚d S )NFTrk r )rR Ú
connectingrU Z
connect_exr r r r r rm rS r Úhandle_connect_eventr- r )rV Zaddressr r r r ÚconnectH s ÿÿ
zdispatcher.connectc
C sz z| j ¡ \}}W nZ ty& Y d S tyl } z0|jd tttfv rVW Y d }~d S ‚ W Y d }~nd }~0 0 ||fS d S r' )rU Úacceptr\ r- r. r r r
)rV ZconnrS Úwhyr r r rs V s zdispatcher.acceptc
C s~ z| j |¡}|W S tyx } zN|jd tkr>W Y d }~dS |jd tv rb| ¡ W Y d }~dS ‚ W Y d }~n
d }~0 0 d S r' )rU Úsendr- r. r r/ r, )rV ÚdataÚresultrt r r r ru d s zdispatcher.sendc
C sx z(| j |¡}|s | ¡ W dS |W S W nJ tyr } z2|jd tv r\| ¡ W Y d }~dS ‚ W Y d }~n
d }~0 0 d S )Nó r )rU Úrecvr, r- r. r/ )rV Z buffer_sizerv rt r r r ry q s
zdispatcher.recvc
C sp d| _ d| _d| _| ¡ | jd urlz| j ¡ W n8 tyj } z |jd tt fvrV‚ W Y d }~n
d }~0 0 d S )NFr )
rR r: rp rT rU Úcloser- r. r r
)rV rt r r r rz ƒ s
zdispatcher.closec C s t j dt|ƒ ¡ d S )Nzlog: %s
)ÚsysÚstderrr$ Ústr)rV Úmessager r r Úlog“ s zdispatcher.logÚinfoc C s || j vrtd||f ƒ d S )Nz%s: %s)Úignore_log_typesÚprint)rV r~ rb r r r Úlog_info– s
zdispatcher.log_infoc C s: | j r| ¡ n&| js.| jr$| ¡ | ¡ n| ¡ d S r )r: Ú
handle_acceptrR rp rq Ú handle_readrh r r r r š s
z dispatcher.handle_read_eventc C s@ | j t jt j¡}|dkr(t|t|ƒƒ‚| ¡ d| _d| _d S )Nr TF) rU rg rf ÚSO_ERRORr- r Úhandle_connectrR rp ©rV r r r r rq ¦ s z dispatcher.handle_connect_eventc C s* | j r
d S | js | jr | ¡ | ¡ d S r )r: rR rp rq Ú handle_writerh r r r r# ® s z dispatcher.handle_write_eventc C s0 | j t jt j¡}|dkr$| ¡ n| ¡ d S r' )rU rg rf r† r, Ú handle_exptrˆ r r r r% ¹ s
z dispatcher.handle_expt_eventc C sX t ƒ \}}}}z t| ƒ}W n dt| ƒ }Y n0 | d||||f d¡ | ¡ 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, )rV ZnilÚtÚvÚtbinfoZ self_reprr r r r È s üù zdispatcher.handle_errorc C s | dd¡ d S )Nz!unhandled incoming priority eventrM ©rƒ rh r r r rŠ Ü s zdispatcher.handle_exptc C s | dd¡ d S )Nzunhandled read eventrM r rh r r r r… ß s zdispatcher.handle_readc C s | dd¡ d S )Nzunhandled write eventrM r rh r r r r‰ â s zdispatcher.handle_writec C s | dd¡ d S )Nzunhandled connect eventrM r rh r r r r‡ å s zdispatcher.handle_connectc C s | ¡ }|d ur| j|Ž d S r )rs Úhandle_accepted)rV Zpairr r r r„ è s zdispatcher.handle_acceptc C s | ¡ | dd¡ d S )Nzunhandled accepted eventrM )rz rƒ )rV rW rS r r r r‘ í s zdispatcher.handle_acceptedc C s | dd¡ | ¡ d S )Nzunhandled close eventrM )rƒ rz rh r r r r, ñ s zdispatcher.handle_close)NN)N)N)N)r€ ),r r r ÚdebugrR r: rp ÚclosingrS Ú frozensetr rX r` ra rT rU ZAF_INETZ SOCK_STREAMrc rQ ri r7 r8 rn ro rr rs ru ry rz r rƒ r rq r# r% r rŠ r… r‰ r‡ r„ r‘ r, r r r r rL Ò sJ
rL c @ s6 e Zd Zd dd„Zdd„ Zdd„ Zdd „ Zd
d „ ZdS )
Údispatcher_with_sendNc C s t | ||¡ d| _d S )Nrx )rL rX Ú
out_bufferre r r r rX ü s z dispatcher_with_send.__init__c C s. d}t | | jd d… ¡}| j|d … | _d S )Nr i )rL ru r– )rV Znum_sentr r r Ú
initiate_send s z"dispatcher_with_send.initiate_sendc C s | ¡ d S r )r— rh r r r r‰ s z!dispatcher_with_send.handle_writec C s | j pt| jƒS r )rR Úlenr– rh r r r r8 s z dispatcher_with_send.writablec C s0 | j r| dt|ƒ ¡ | j| | _| ¡ d S )Nz
sending %s)r’ rƒ r] r– r— )rV rv r r r ru s zdispatcher_with_send.send)NN)r r r rX r— r‰ r8 ru r r r r r• ú s
r• c C s‚ t ¡ \} }}g }|s tdƒ‚|rL| |jjj|jjjt|j ƒf¡ |j
}q ~|d \}}}d dd„ |D ƒ¡}|||f| ||fS )Nztraceback does not existéÿÿÿÿrZ c S s g | ] }d | ‘qS )z
[%s|%s|%s]r )Ú.0Úxr r r Ú
& rx z%compact_traceback..) r{ Úexc_infoÚAssertionErrorr9 Útb_frameÚf_codeÚ co_filenameÚco_namer} Ú tb_linenoÚtb_nextr^ )r rŽ Útbr ÚfileZfunctionÚliner€ r r r rŒ s ýrŒ c C s” | d u r t } t| ¡ ƒD ]n}z | ¡ W q tyb } z"|jd tkrHn|sN‚ W Y d }~qd }~0 tyt ‚ Y q |s€‚ Y q0 q| ¡ d S r' ) r4 r5 Úvaluesrz r- r. r
r Úclear)r? Z
ignore_allr› r r r Ú close_all) s
rª Úposixc @ sN e Zd Zdd„ Zdd„ Zdd„ Zdd„ Zdd
d „ZeZeZ d d
„ Z
dd„ Z d S )Ú file_wrapperc C s t |¡| _d S r )r ÚduprB ©rV rB r r r rX N s zfile_wrapper.__init__c C s* | j dkr tjd| t| d | ¡ d S )Nr zunclosed file %r)Úsource)rB ÚwarningsÚwarnÚResourceWarningrz rh r r r Ú__del__Q s
ÿzfile_wrapper.__del__c G s t j| jg|¢R Ž S r )r r" rB ©rV r. r r r ry W s zfile_wrapper.recvc G s t j| jg|¢R Ž S r )r r$ rB r´ r r r ru Z s zfile_wrapper.sendNc C s( |t jkr |t jkr |s dS tdƒ‚d S )Nr z-Only asyncore specific behaviour implemented.)rU rf r† ÚNotImplementedError)rV ÚlevelZoptnameZbuflenr r r rg ] s
ÿþzfile_wrapper.getsockoptc C s( | j dk rd S | j }d| _ t |¡ d S )Nr r™ )rB r rz r® r r r rz h s
zfile_wrapper.closec C s | j S r )rB rh r r r rd o s zfile_wrapper.fileno)N) r r r rX r³ ry ru rg r" r$ rz rd r r r r r¬ I s
r¬ c @ s e Zd Zddd„Zdd„ ZdS )Úfile_dispatcherNc C sN t | d |¡ d| _z | ¡ }W n ty2 Y n0 | |¡ t |d¡ d S )NTF)rL rX rR rd ÚAttributeErrorÚset_filer Ú set_blocking)rV rB r? r r r rX t s
zfile_dispatcher.__init__c C s" t |ƒ| _| j ¡ | _| ¡ d S r )r¬ rU rd rO ra r® r r r r¹ s
zfile_dispatcher.set_file)N)r r r rX r¹ r r r r r· r s
r· )r3 N)r3 N)rG FNN)NF)-r( rU r{ r; r° r Úerrnor r r r r r r r r
r r r
r r” r/ r4 r r Ú Exceptionr ÚKeyboardInterruptÚ
SystemExitr r" r$ r& r2 rC rF Zpoll3rK rL r• rŒ rª rm r¬ r· r r r r Ú1 sB < ÿ
'
*
)