File: //lib64/python3.8/__pycache__/asyncore.cpython-38.pyc
U
e5d~N ã @ sh d Z ddlZddlZddlZddlZddlZddlZddlmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZ ee e
eeeehƒZze W n ek
r¤ i ZY nX dd„ ZG dd„ deƒZee e fZ dd „ Z d
d „ Z d d
„ Z!dd„ Z"d&dd„Z#d'dd„Z$e$Z%d(dd„Z&G dd„ dƒZ'G dd „ d e'ƒZ(d d „ Z)d)d d „Z*ej+d!krdG d"d#„ d#ƒZ,G d$d%„ d%e'ƒZ-dS )*a Basic infrastructure for asynchronous socket service clients and servers.
There are only two ways to have a program on a single processor do "more
than one thing at a time". Multi-threaded programming is the simplest and
most popular way to do it, but there is another very different technique,
that lets you have nearly all the advantages of multi-threading, without
actually using multiple threads. it's really only practical if your program
is largely I/O bound. If your program is CPU bound, then pre-emptive
scheduled threads are probably what you really need. Network servers are
rarely CPU-bound, however.
If your operating system supports the select() system call in its I/O
library (and nearly all do), then you can use it to juggle multiple
communication channels at once; doing other work while your I/O is taking
place in the "background." Although this strategy can seem strange and
complex, especially at first, it is in many ways easier to understand and
control than multi-threaded programming. The module documented here solves
many of the difficult problems for you, making the task of building
sophisticated high-performance network servers and clients a snap.
é N)
ÚEALREADYÚ EINPROGRESSÚ EWOULDBLOCKÚ
ECONNRESETÚEINVALÚENOTCONNÚ ESHUTDOWNÚEISCONNÚEBADFÚ ECONNABORTEDÚEPIPEÚEAGAINÚ errorcodec
C sH z t | ¡W S tttfk
rB | tkr6t| Y S d| Y S X d S )NzUnknown error %s)ÚosÚstrerrorÚ
ValueErrorÚ
OverflowErrorÚ NameErrorr )Úerr© r ú /usr/lib64/python3.8/asyncore.pyÚ _strerrorD s r c @ s e Zd ZdS )ÚExitNowN)Ú__name__Ú
__module__Ú __qualname__r r r r r L s r c C s: z | ¡ W n( tk
r" ‚ Y n | ¡ Y nX d S ©N)Úhandle_read_eventÚ_reraised_exceptionsÚ handle_error©Úobjr r r ÚreadQ s r" c C s: z | ¡ W n( tk
r" ‚ Y n | ¡ Y nX d S r )Úhandle_write_eventr r r r r r ÚwriteY s r$ c C s: z | ¡ W n( tk
r" ‚ Y n | ¡ Y nX 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 k
rš } z$|j d t
kr‚| ¡ n|
¡ W 5 d }~X Y n( tk
r® ‚ Y n | ¡ Y nX 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 kr t }|r8g }g }g }t| ¡ ƒD ]L\}}| ¡ }| ¡ }|rP| |¡ |rd|jsd| |¡ |sl|r*| |¡ q*g | kr–| kr–|kr¨n nt | ¡ d S t |||| ¡\}}}|D ] }|
|¡}|d krÚqÂt |ƒ qÂ|D ]"}|
|¡}|d krqèt |ƒ qè|D ]&}|
|¡}|d kr,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} sD
"
rC c C sÀ |d kr t }| d k r t| d ƒ} t ¡ }|r¼t| ¡ ƒD ]L\}}d}| ¡ r\|tjtjB O }| ¡ rt|j
st|tj O }|r8| ||¡ q8| | ¡}|D ]&\}}|
|¡}|d kr°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 kr t }|r ttdƒr t}nt}|d kr>|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 krt | _n|| _d | _|r–| d¡ | ||¡ d| _z| ¡ | _W qœ tk
r’ } z*|j d t
t fkrvd| _n | |¡ ‚ W 5 d }~X Y qœX nd | _
d S ©Nr TF)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 k r‚z| d| j ¡ W n$ tk
r€ | t| jƒ¡ Y nX dd |¡t
| ƒf S )NÚ.Z listeningrS z%s:%dz <%s at %#x>ú ) Ú __class__r r r: rT r9 rS Ú TypeErrorÚreprÚjoinÚid)rW Zstatusr r r Ú__repr__ü s
zdispatcher.__repr__c C s |d kr| j }| || j< d S r )rO rP )rW r? r r r Ú add_channel s zdispatcher.add_channelc C s, | j }|d kr| j}||kr"||= d | _ d S r )rP rO )rW r? rB r r r rU s zdispatcher.del_channelc C s. ||f| _ t ||¡}| d¡ | |¡ d S r' )Zfamily_and_typerV rQ rR )rW ZfamilyÚtyperX r r r Ú
create_socket s
zdispatcher.create_socketc C s || _ | ¡ | _| |¡ d S r )rV ÚfilenorP rb ©rW rX r? r r r rR s
zdispatcher.set_socketc C sD z*| j t jt j| j t jt j¡dB ¡ W n tk
r> Y nX d S )NrH )rV Z
setsockoptÚ
SOL_SOCKETZ SO_REUSEADDRÚ
getsockoptr- ©rW r r r Úset_reuse_addr# s
ÿÿþzdispatcher.set_reuse_addrc C s dS ©NTr ri r r r r7 4 s zdispatcher.readablec C s dS rk r ri r r r r8 7 s zdispatcher.writablec C s( d| _ tjdkr |dkr d}| j |¡S )NTÚnté )r: r ÚnamerV Úlisten)rW Znumr r r ro > s zdispatcher.listenc C s || _ | j |¡S r )rT rV Úbind)rW rT r r r rp D s zdispatcher.bindc C sp d| _ d| _| j |¡}|tttfks8|tkrBtj dkrB|| _
d S |dt fkr^|| _
| ¡ nt
|t| ƒ‚d S )NFTrl r )rS Ú
connectingrV Z
connect_exr r r r r rn rT r Úhandle_connect_eventr- r )rW Zaddressr r r r ÚconnectH s ÿÿ
zdispatcher.connectc
C sv z| j ¡ \}}W nV tk
r( Y d S tk
rh } z$|jd tttfkrVW Y ¢
d S ‚ W 5 d }~X Y n
X ||fS d S r' )rV Úacceptr] r- r. r r r
)rW ZconnrT Úwhyr r r rt V s
zdispatcher.acceptc
C st z| j |¡}|W S tk
rn } z>|jd tkr<W Y ¢*dS |jd tkr\| ¡ W Y ¢
dS ‚ W 5 d }~X Y nX d S r' )rV Úsendr- r. r r/ r, )rW ÚdataÚresultru r r r rv d s
zdispatcher.sendc
C sr z(| j |¡}|s | ¡ W dS |W S W nD tk
rl } z&|jd tkrZ| ¡ W Y ¢
dS ‚ W 5 d }~X Y nX d S )Nó r )rV Úrecvr, r- r. r/ )rW Z buffer_sizerw ru r r r rz q s
zdispatcher.recvc
C sn d| _ d| _d| _| ¡ | jd k rjz| j ¡ W n6 tk
rh } z|jd tt fkrX‚ W 5 d }~X Y nX d S )NFr )
rS r: rq rU rV Úcloser- r. r r
)rW ru r r r r{ ƒ s
zdispatcher.closec C s t j dt|ƒ ¡ d S )Nzlog: %s
)ÚsysÚstderrr$ Ústr)rW Úmessager r r Úlog“ s zdispatcher.logÚinfoc C s || j krtd||f ƒ d S )Nz%s: %s)Úignore_log_typesÚprint)rW r rc r r r Úlog_info– s
zdispatcher.log_infoc C s: | j r| ¡ n&| js.| jr$| ¡ | ¡ n| ¡ d S r )r: Ú
handle_acceptrS rq rr Ú handle_readri r r r r š s
z dispatcher.handle_read_eventc C s@ | j t jt j¡}|dkr(t|t|ƒƒ‚| ¡ d| _d| _d S rN ) rV rh rg ÚSO_ERRORr- r Úhandle_connectrS rq ©rW r r r r rr ¦ s z dispatcher.handle_connect_eventc C s* | j r
d S | js | jr | ¡ | ¡ d S r )r: rS rq rr Ú handle_writeri r r r r# ® s z dispatcher.handle_write_eventc C s0 | j t jt j¡}|dkr$| ¡ n| ¡ d S r' )rV rh rg r‡ r, Ú handle_exptr‰ r r r r% ¹ s
z dispatcher.handle_expt_eventc C sX t ƒ \}}}}z t| ƒ}W n dt| ƒ }Y nX | 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, )rW ZnilÚtÚvÚtbinfoZ self_reprr r r r È s üù zdispatcher.handle_errorc C s | dd¡ d S )Nz!unhandled incoming priority eventrM ©r„ ri r r r r‹ Ü s zdispatcher.handle_exptc C s | dd¡ d S )Nzunhandled read eventrM r‘ ri r r r r† ß s zdispatcher.handle_readc C s | dd¡ d S )Nzunhandled write eventrM r‘ ri r r r rŠ â s zdispatcher.handle_writec C s | dd¡ d S )Nzunhandled connect eventrM r‘ ri r r r rˆ å s zdispatcher.handle_connectc C s | ¡ }|d k r| j|Ž d S r )rt Úhandle_accepted)rW Zpairr r r r… è s zdispatcher.handle_acceptc C s | ¡ | dd¡ d S )Nzunhandled accepted eventrM )r{ r„ )rW rX rT r r r r’ í s zdispatcher.handle_acceptedc C s | dd¡ | ¡ d S )Nzunhandled close eventrM )r„ r{ ri r r r r, ñ s zdispatcher.handle_close)NN)N)N)N)r ),r r r ÚdebugrS r: rq ÚclosingrT Ú frozensetr‚ rY ra rb rU rV ZAF_INETZ SOCK_STREAMrd rR rj r7 r8 ro rp rs rt rv rz r{ r€ r„ r rr 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 )Nry )rL rY Ú
out_bufferrf r r r rY ü s z dispatcher_with_send.__init__c C s. d}t | | jd d… ¡}| j|d … | _d S )Nr i )rL rv r— )rW Znum_sentr r r Ú
initiate_send s z"dispatcher_with_send.initiate_sendc C s | ¡ d S r )r˜ ri r r r rŠ s z!dispatcher_with_send.handle_writec C s | j pt| jƒS r )rS Úlenr— ri 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˜ )rW rw r r r rv s zdispatcher_with_send.send)NN)r r r rY r˜ rŠ r8 rv 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éÿÿÿÿr[ c S s g | ] }d | ‘qS )z
[%s|%s|%s]r )Ú.0Úxr r r Ú
<listcomp>& s z%compact_traceback.<locals>.<listcomp>) 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 kr t } t| ¡ ƒD ]n}z | ¡ W q tk
r` } z|jd tkrJn|sP‚ W 5 d }~X Y q tk
rt ‚ Y q |s€‚ Y qX q| ¡ d S r' ) r4 r5 Úvaluesr{ 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 ©rW rB r r r rY N s zfile_wrapper.__init__c C s* | j dkr tjd| t| d | ¡ d S )Nr zunclosed file %r)Úsource)rB ÚwarningsÚwarnÚResourceWarningr{ ri r r r Ú__del__Q s
ÿzfile_wrapper.__del__c G s t j| jf|žŽ S r )r r" rB ©rW r. r r r rz W s zfile_wrapper.recvc G s t j| jf|žŽ S r )r r$ rB rµ r r r rv Z s zfile_wrapper.sendNc C s( |t jkr |t jkr |s dS tdƒ‚d S )Nr z-Only asyncore specific behaviour implemented.)rV rg r‡ ÚNotImplementedError)rW ÚlevelZoptnameZbuflenr r r rh ] s
ÿþzfile_wrapper.getsockoptc C s( | j dk rd S | j }d| _ t |¡ d S )Nr rš )rB r r{ r¯ r r r r{ h s
zfile_wrapper.closec C s | j S r )rB ri r r r re o s zfile_wrapper.fileno)N) r r r rY r´ rz rv rh r" r$ r{ re r r r r r I s
r c @ s e Zd Zddd„Zdd„ ZdS )Úfile_dispatcherNc C sP t | d |¡ d| _z | ¡ }W n tk
r4 Y nX | |¡ t |d¡ d S )NTF)rL rY rS re ÚAttributeErrorÚset_filer Ú set_blocking)rW rB r? r r r rY t s
zfile_dispatcher.__init__c C s" t |ƒ| _| j ¡ | _| ¡ d S r )r rV re rP rb r¯ r r r rº s
zfile_dispatcher.set_file)N)r r r rY rº r r r r r¸ r s
r¸ )r3 N)r3 N)rG FNN)NF).Ú__doc__r( rV 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« rn r r¸ r r r r Ú<module> sD < ÿ
'
*
)