B
Wã X]`âã @ sh d Z ddlZddlZddlZddlZddlZddlZddlmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZ ee e
eeeehƒZye 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 s> y
t | ¡S tttfk
r8 | tkr0t| S d| S X d S )NzUnknown error %s)ÚosÚstrerrorÚ
ValueErrorÚ
OverflowErrorÚ NameErrorr )Úerr© r ú-/opt/alt/python37/lib64/python3.7/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: y | ¡ 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: y | ¡ W n( tk
r" ‚ Y n | ¡ Y nX d S )N)Úhandle_write_eventr r )r r r r ÚwriteY s r" c C s: y | ¡ W n( tk
r" ‚ Y n | ¡ Y nX d S )N)Úhandle_expt_eventr r )r r r r Ú
_exceptiona s r$ c
C sÆ yX|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 d 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"
r/ ç c C sL |d kr t }|rHg }g }g }x\t| ¡ ƒD ]L\}}| ¡ }| ¡ }|rR| |¡ |rf|jsf| |¡ |sn|r,| |¡ q,W g | krš| krš|kr¬n nt | ¡ d S t |||| ¡\}}}x(|D ] }|
|¡}|d kràqÈt |ƒ qÈW x*|D ]"}|
|¡}|d kr qòt |ƒ qòW x.|D ]&}|
|¡}|d kr:q t
|ƒ q W d S )N)Ú
socket_mapÚlistÚitemsÚreadableÚwritableÚappendÚ acceptingÚtimeZsleepr% Úgetr r" r$ ) ÚtimeoutÚmapÚrÚwr. Úfdr Zis_rZis_wr r r Úpoll} sD
"
r? c C sÈ |d kr t }| d k r t| d ƒ} t ¡ }|rÄx\t| ¡ ƒD ]L\}}d}| ¡ r^|tjtjB O }| ¡ rv|j
sv|tj O }|r:| ||¡ q:W | | ¡}x.|D ]&\}}|
|¡}|d kr¶qšt||ƒ qšW d S )Niè r )r1 Úintr% r? r2 r3 r4 r& r( r5 r7 r' Úregisterr9 r/ )r: r; Zpollsterr> r r- r< r r r Úpoll2¤ s(
rB ç >@Fc C sj |d kr t }|r ttdƒr t}nt}|d krBx8|r>|| |ƒ q.W n$x"|rd|dkrd|| |ƒ |d }qDW d S )Nr? r é )r1 Úhasattrr% rB r? )r: Zuse_pollr; ÚcountZpoll_funr r r ÚloopÀ s
rG c @ s6 e Zd ZdZdZdZdZdZdZe dhƒZ
dAdd„Z dd„ Z e Z
dBdd „ZdCd
d „Zejejfd d
„ZdDdd„Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ Zdd„ Zd d „ Zd d „ Z d 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| _y| ¡ | _W qœ tk
r’ } z*|j d t
t fkrvd| _n | |¡ ‚ W d d }~X Y qœX nd | _
d S )Nr TF)r1 Ú_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‚y| d| j ¡ W n$ tk
r€ | t| jƒ¡ Y nX dd |¡t
| ƒf S )NÚ.Z listeningrN z%s:%dz <%s at %#x>ú ) Ú __class__r r r7 rO r6 rN Ú TypeErrorÚreprÚjoinÚid)rR Zstatusr r r Ú__repr__ü s
zdispatcher.__repr__c C s |d kr| j }| || j< d S )N)rJ rK )rR r; r r r Ú add_channel s zdispatcher.add_channelc C s, | j }|d kr| j}||kr"||= d | _ d S )N)rK rJ )rR r; r> r r r rP s zdispatcher.del_channelc C s. ||f| _ t ||¡}| d¡ | |¡ d S )Nr )Zfamily_and_typerQ rL rM )rR ZfamilyÚtyperS r r r Ú
create_socket s
zdispatcher.create_socketc C s || _ | ¡ | _| |¡ d S )N)rQ ÚfilenorK r] )rR rS r; r r r rM s
zdispatcher.set_socketc C sD y*| j t jt j| j t jt j¡dB ¡ W n tk
r> Y nX d S )NrD )rQ Z
setsockoptÚ
SOL_SOCKETZ SO_REUSEADDRÚ
getsockoptr* )rR r r r Úset_reuse_addr% s
zdispatcher.set_reuse_addrc C s dS )NTr )rR r r r r4 6 s zdispatcher.readablec C s dS )NTr )rR r r r r5 9 s zdispatcher.writablec C s( d| _ tjdkr |dkr d}| j |¡S )NTÚnté )r7 r ÚnamerQ Úlisten)rR Znumr r r rg @ s zdispatcher.listenc C s || _ | j |¡S )N)rO rQ Úbind)rR rO r r r rh F s zdispatcher.bindc C sp d| _ d| _| j |¡}|tttfks8|tkrBtj dkrB|| _
d S |dt fkr^|| _
| ¡ nt
|t| ƒ‚d S )NFTrd r )rN Ú
connectingrQ Z
connect_exr r r r r rf rO r Úhandle_connect_eventr* r )rR Zaddressr r r r ÚconnectJ s
zdispatcher.connectc
C sn y| j ¡ \}}W nN tk
r& d S tk
r` } z |jd tttfkrNd S ‚ W d d }~X Y n
X ||fS d S )Nr )rQ ÚacceptrX r* r+ r r r
)rR ZconnrO Úwhyr r r rl X s zdispatcher.acceptc
C sf y| j |¡}|S tk
r` } z2|jd tkr4dS |jd tkrN| ¡ dS ‚ W d d }~X Y nX d S )Nr )rQ Úsendr* r+ r r, r) )rR ÚdataÚresultrm r r r rn f s zdispatcher.sendc
C sh y$| j |¡}|s | ¡ dS |S W n> tk
rb } z |jd tkrP| ¡ dS ‚ W d d }~X Y nX d S )Nó r )rQ Úrecvr) r* r+ r, )rR Ú buffer_sizero rm r r r rr s s zdispatcher.recvc
C sn d| _ d| _d| _| ¡ | jd k rjy| j ¡ W n6 tk
rh } z|jd tt fkrX‚ W d d }~X Y nX d S )NFr )
rN r7 ri rP rQ Úcloser* r+ r r
)rR rm r r r rt … s
zdispatcher.closec C s t j dt|ƒ ¡ d S )Nzlog: %s
)ÚsysÚstderrr" Ústr)rR Úmessager r r Úlog• s zdispatcher.logÚinfoc C s || j krtd||f ƒ d S )Nz%s: %s)Úignore_log_typesÚprint)rR rx r^ r r r Úlog_info˜ s
zdispatcher.log_infoc C s: | j r| ¡ n&| js.| jr$| ¡ | ¡ n| ¡ d S )N)r7 Ú
handle_acceptrN ri rj Ú handle_read)rR 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) rQ rb ra ÚSO_ERRORr* r Úhandle_connectrN ri )rR r r r r rj ¨ s z dispatcher.handle_connect_eventc C s* | j r
d S | js | jr | ¡ | ¡ d S )N)r7 rN ri rj Ú handle_write)rR r r r r! ° s z dispatcher.handle_write_eventc C s0 | j t jt j¡}|dkr$| ¡ n| ¡ d S )Nr )rQ rb ra r€ r) Ú handle_expt)rR r r r r r# » s
z dispatcher.handle_expt_eventc C sX t ƒ \}}}}y 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_tracebackrY r[ r} r) )rR ZnilÚtÚvÚtbinfoZ self_reprr r r r Ê s zdispatcher.handle_errorc C s | dd¡ d S )Nz!unhandled incoming priority eventrI )r} )rR r r r rƒ Þ s zdispatcher.handle_exptc C s | dd¡ d S )Nzunhandled read eventrI )r} )rR r r r r á s zdispatcher.handle_readc C s | dd¡ d S )Nzunhandled write eventrI )r} )rR r r r r‚ ä s zdispatcher.handle_writec C s | dd¡ d S )Nzunhandled connect eventrI )r} )rR r r r r ç s zdispatcher.handle_connectc C s | ¡ }|d k r| j|Ž d S )N)rl Úhandle_accepted)rR Zpairr r r r~ ê s zdispatcher.handle_acceptc C s | ¡ | dd¡ d S )Nzunhandled accepted eventrI )rt r} )rR rS rO r r r r‰ ï s zdispatcher.handle_acceptedc C s | dd¡ | ¡ d S )Nzunhandled close eventrI )r} rt )rR r r r r) ó s zdispatcher.handle_close)NN)N)N)N)rz )-r r r ÚdebugrN r7 ri ÚclosingrO Ú frozensetr{ rT r\ Ú__str__r] rP rQ ZAF_INETZ SOCK_STREAMr_ rM rc r4 r5 rg rh rk rl rn rr rt ry r} r rj r! r# r rƒ r r‚ r r~ r‰ r) r r r r rH Ò sL
rH c @ s6 e Zd Zd dd„Zdd„ Zdd„ Zdd „ Zd
d „ ZdS )
Údispatcher_with_sendNc C s t | ||¡ d| _d S )Nrq )rH rT Ú
out_buffer)rR rS r; r r r rT þ s z dispatcher_with_send.__init__c C s. d}t | | jd d… ¡}| j|d … | _d S )Nr i )rH rn r )rR Znum_sentr r r Ú
initiate_send s z"dispatcher_with_send.initiate_sendc C s | ¡ d S )N)r )rR r r r r‚ s z!dispatcher_with_send.handle_writec C s | j pt| jƒS )N)rN Úlenr )rR r r r r5
s z dispatcher_with_send.writablec C s0 | j r| dt|ƒ ¡ | j| | _| ¡ d S )Nz
sending %s)rŠ r} rY r r )rR ro r r r rn
s zdispatcher_with_send.send)NN)r r r rT r r‚ r5 rn r r r r rŽ ü s
rŽ c C s† t ¡ \} }}g }|s tdƒ‚x0|rN| |jjj|jjjt|j ƒf¡ |j
}q W ~|d \}}}d dd„ |D ƒ¡}|||f| ||fS )Nztraceback does not existéÿÿÿÿrV c S s g | ] }d | ‘qS )z
[%s|%s|%s]r )Ú.0Úxr r r ú
( s z%compact_traceback..) ru Úexc_infoÚAssertionErrorr6 Útb_frameÚf_codeÚ co_filenameÚco_namerw Ú tb_linenoÚtb_nextrZ )r† r‡ Útbrˆ ÚfileZfunctionÚlinerz r r r r… s
r… c C s˜ | d kr t } x~t| ¡ ƒD ]n}y | ¡ W q tk
rb } z|jd tkrLn|sR‚ W d d }~X Y q tk
rv ‚ Y q |s‚‚ Y qX qW | ¡ d S )Nr ) r1 r2 Úvaluesrt 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 )N)r Údupr> )rR r> r r r rT P s zfile_wrapper.__init__c C s* | j dkr tjd| t| d | ¡ d S )Nr zunclosed file %r)Úsource)r> ÚwarningsÚwarnÚResourceWarningrt )rR r r r Ú__del__S s
zfile_wrapper.__del__c G s t j| jf|žŽ S )N)r r r> )rR r+ r r r rr Y s zfile_wrapper.recvc G s t j| jf|žŽ S )N)r r" r> )rR r+ r r r rn \ s zfile_wrapper.sendNc C s( |t jkr |t jkr |s dS tdƒ‚d S )Nr z-Only asyncore specific behaviour implemented.)rQ ra r€ ÚNotImplementedError)rR ÚlevelZoptnameZbuflenr r r rb _ s
zfile_wrapper.getsockoptc C s( | j dk rd S | j }d| _ t |¡ d S )Nr r’ )r> r rt )rR r> r r r rt j s
zfile_wrapper.closec C s | j S )N)r> )rR r r r r` q s zfile_wrapper.fileno)N) r r r rT r« rr rn rb r r" rt r` r r r r r¥ K s
r¥ c @ s e Zd Zddd„Zdd„ ZdS )Úfile_dispatcherNc C sP t | d |¡ d| _y | ¡ }W n tk
r4 Y nX | |¡ t |d¡ d S )NTF)rH rT rN r` ÚAttributeErrorÚset_filer Ú set_blocking)rR r> r; r r r rT v s
zfile_dispatcher.__init__c C s" t |ƒ| _| j ¡ | _| ¡ d S )N)r¥ rQ r` rK r] )rR r> r r r r° s
zfile_dispatcher.set_file)N)r r r rT r° r r r r r® t s
r® )r0 N)r0 N)rC FNN)NF).Ú__doc__r% rQ ru r8 r¨ r Úerrnor r r r r r r r r
r r r
r rŒ r, r1 r r Ú Exceptionr ÚKeyboardInterruptÚ
SystemExitr r r" r$ r/ r? rB Zpoll3rG rH rŽ r… r£ rf r¥ r® r r r r Ú/ sB <
'
,
)