o
0i,O @ sx d Z ddlZddlZddlZddlZddlZddlZddlmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZ ejdedd ee e
eeeehZze W n eyY i ZY nw dd ZG d d
d
e Z e e e fZ d d Z!d
d Z"dd Z#dd Z$d)ddZ%d)ddZ&e&Z'd*ddZ(G d d d Z)G d d d e)Z*d d! Z+d+d"d#Z,ej-d$krG d%d& d&Z.G d'd( d(e)Z/dS 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
ECONNRESETEINVALENOTCONN ESHUTDOWNEISCONNEBADF ECONNABORTEDEPIPEEAGAIN errorcodezlThe asyncore module is deprecated and will be removed in Python 3.12. The recommended replacement is asyncio )
stacklevelc
C sB zt | W S tttfy | tv rt| Y S d| Y S w )NzUnknown error %s)osstrerror
ValueError
OverflowError NameErrorr )err r //opt/alt/python310/lib64/python3.10/asyncore.py _strerrorK s r c @ s e Zd ZdS )ExitNowN)__name__
__module__ __qualname__r r r r r S s r c C 2 z| W d S ty | Y d S N)handle_read_event_reraised_exceptions handle_errorobjr r r readX r% c C r r )handle_write_eventr! r" r# r r r write` r& r( c C r r )handle_expt_eventr! r" r# r r r
_exceptionh r& r* c
C s z0|t j@ r
| |t j@ r| |t j@ r | |t jt jB t j B @ r.|
W d S W d S t yX } z |j t
vrB| n |
W Y d }~d S W Y d }~d S d }~w ty_ | Y d S r )selectPOLLINr POLLOUTr' POLLPRIr) ZPOLLHUPZPOLLERRZPOLLNVAL handle_closeOSErrorerrno
_DISCONNECTEDr" r! )r$ flagser r r readwritep s(
r5 c C s6 |d u rt }|rg }g }g }t| D ]&\}}| }| }|r'|| |r1|js1|| |s5|r:|| qg | krJ| krJ|krSn nt| d S t |||| \}}}|D ]}|
|}|d u rlq`t | q`|D ]}|
|}|d u rqst | qs|D ]}|
|}|d u rqt
| qd S d S r )
socket_maplistitemsreadablewritableappend acceptingtimesleepr+ getr% r( r* ) timeoutmaprwr4 fdr$ Zis_rZis_wr r r poll sF
"
rF c C s |d u rt }| d urt| d } t }|r^t| D ]&\}}d}| r.|tjtjB O }| r:|j
s:|tj O }|rB| || q || }|D ]\}}|
|}|d u rXqJt|| qJd S d S )Ni r )r7 intr+ rF r8 r9 r: r, r. r; r= r- registerr@ r5 )rA rB ZpollsterrE r$ r3 rC r r r poll2 s.
rI >@Fc C s |d u rt }|rttdrt}nt}|d u r#|r!|| | |sd S d S |r:|dkr>|| | |d }|r<|dks)d S d S d S d S )NrF r )r7 hasattrr+ rI rF )rA Zuse_pollrB countZpoll_funr r r loop s
rN c @ s2 e Zd ZdZdZdZdZdZdZe dhZ
dAddZ dd Z dBdd Z
dBd
d Zejejfd d
ZdBddZdd Zdd Zdd Zdd Zdd Zdd Zd d Zd d Zd d! Z d"d# Z d$d% Z dCd'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 )D
dispatcherFNwarningc
C s |d u rt | _n|| _d | _|rK|d | || d| _z| | _W d S tyJ } z|j t
t fv r9d| _n| | W Y d }~d S d }~ww d | _
d S )NFT)r7 _map_fileno setblocking
set_socket connectedZ getpeernameaddrr0 r1 r r del_channelsocket)selfsockrB 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 nw dd |t
| f S )N.Z listeningrU z%s:%dz <%s at %#x> ) __class__r r r= rV r< rU TypeErrorreprjoinid)rY Zstatusr r r __repr__ s
zdispatcher.__repr__c C s |d u r| j }| || j< d S r )rQ rR )rY rB r r r add_channel s zdispatcher.add_channelc C s, | j }|d u r
| j}||v r||= d | _ d S r )rR rQ )rY rB rE r r r rW s
zdispatcher.del_channelc C s. ||f| _ t||}|d | | d S NF)Zfamily_and_typerX rS rT )rY ZfamilytyperZ r r r
create_socket s
zdispatcher.create_socketc C s || _ | | _| | d S r )rX filenorR rd rY rZ rB r r r rT % s
zdispatcher.set_socketc C sB z| j t jt j| j t jt jdB W d S ty Y d S w )NrK )rX Z
setsockopt
SOL_SOCKETZ SO_REUSEADDR
getsockoptr0 rY r r r set_reuse_addr* s
zdispatcher.set_reuse_addrc C dS NTr rl r r r r: ; zdispatcher.readablec C rn ro r rl r r r r; > rp zdispatcher.writablec C s( d| _ tjdkr|dkrd}| j|S )NTnt )r= r namerX listen)rY Znumr r r rt E s zdispatcher.listenc C s || _ | j|S r )rV rX bind)rY rV r r r ru K s zdispatcher.bindc C sn d| _ d| _| j|}|tttfv s |tkr!tj dkr!|| _
d S |dt fv r0|| _
| d S t
|t| )NFTrq r )rU
connectingrX Z
connect_exr r r r r rs rV r handle_connect_eventr0 r )rY Zaddressr r r r connectO s zdispatcher.connectc
C sd z | j \}}W ||fS ty Y d S ty1 } z|jtttfv r,W Y d }~d S d }~ww r )rX acceptr_ r0 r1 r r r
)rY ZconnrV whyr r r ry ] s zdispatcher.acceptc
C sf z | j |}|W S ty2 } z |jtkr W Y d }~dS |jtv r-| W Y d }~dS d }~ww Nr )rX sendr0 r1 r r2 r/ )rY dataresultrz r r r r| k s
zdispatcher.sendc
C s` z| j |}|s| W dS |W S ty/ } z|jtv r*| W Y d }~dS d }~ww N )rX recvr/ r0 r1 r2 )rY Z buffer_sizer} rz r r r r x s
zdispatcher.recvc
C sp d| _ d| _d| _| | jd ur6z| j W d S ty5 } z|jtt fvr* W Y d }~d S d }~ww d S re )
rU r= rv rW rX closer0 r1 r r
)rY rz r r r r s
zdispatcher.closec C s t jdt| d S )Nzlog: %s
)sysstderrr( str)rY messager r r log s zdispatcher.loginfoc C s" || j vrtd||f d S d S )Nz%s: %s)ignore_log_typesprint)rY r rf r r r log_info s
zdispatcher.log_infoc C s> | j r | d S | js| jr| | d S | d S r )r=
handle_acceptrU rv rw handle_readrl r r r r s z dispatcher.handle_read_eventc C s@ | j t jt j}|dkrt|t|| d| _d| _d S )Nr TF) rX rk rj SO_ERRORr0 r handle_connectrU rv rY r r r r rw s
z dispatcher.handle_connect_eventc C s* | j rd S | js| jr| | d S r )r= rU rv rw handle_writerl r r r r' s z dispatcher.handle_write_eventc C s2 | j t jt j}|dkr| d S | d S r{ )rX rk rj r r/ handle_exptr r r r r) s z dispatcher.handle_expt_eventc C sT t \}}}}zt| }W n
dt| }Y | 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` rb r r/ )rY ZniltvtbinfoZ self_reprr r r r" s zdispatcher.handle_errorc C | dd d S )Nz!unhandled incoming priority eventrP r rl r r r r zdispatcher.handle_exptc C r )Nzunhandled read eventrP r rl r r r r r zdispatcher.handle_readc C r )Nzunhandled write eventrP r rl r r r r r zdispatcher.handle_writec C r )Nzunhandled connect eventrP r rl r r r r r zdispatcher.handle_connectc C s" | }|d ur| j| d S d S r )ry handle_accepted)rY Zpairr r r r s zdispatcher.handle_acceptc C s | | dd d S )Nzunhandled accepted eventrP )r r )rY rZ rV r r r r s zdispatcher.handle_acceptedc C s | dd | d S )Nzunhandled close eventrP )r r rl r r r r/ s zdispatcher.handle_closeNNr )r ),r r r debugrU r= rv closingrV frozensetr r[ rc rd rW rX ZAF_INETZ SOCK_STREAMrg rT rm r: r; rt ru rx ry r| r r r r r rw r' r) r" r r r r r r r/ r r r r rO sL
rO c @ s6 e Zd Zd ddZdd Zdd Zdd Zd
d ZdS )
dispatcher_with_sendNc C s t | || d| _d S r )rO r[
out_bufferri r r r r[ s
z dispatcher_with_send.__init__c C s. d}t | | jd d }| j|d | _d S )Nr i )rO r| r )rY Znum_sentr r r
initiate_send s z"dispatcher_with_send.initiate_sendc C s | d S r )r rl r r r r s z!dispatcher_with_send.handle_writec C s | j pt| jS r )rU lenr rl r r r r; s z dispatcher_with_send.writablec C s0 | j r | dt| | j| | _| d S )Nz
sending %s)r r r` r r )rY r} r r r r| s zdispatcher_with_send.sendr )r r r r[ r r r; r| r r r r r s
r c C s t \} }}g }|std|r'||jjj|jjjt|j f |j
}|s~|d \}}}d dd |D }|||f| ||fS )Nztraceback does not existr] c S s g | ]}d | qS )z
[%s|%s|%s]r ).0xr r r
- s z%compact_traceback..) r exc_infoAssertionErrorr< tb_framef_code co_filenameco_namer tb_linenotb_nextra )r r tbr fileZfunctionliner r r r r s r c C s | d u rt } t| D ]1}z| W q ty/ } z|jtkr"n|s% W Y d }~q d }~w ty6 |s< Y q | d S r ) r7 r8 valuesr r0 r1 r
r! clear)rB Z
ignore_allr r r r close_all0 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 duprE rY rE r r r r[ U r zfile_wrapper.__init__c C s* | j dkrtjd| t| d | d S )Nr zunclosed file %r)source)rE warningswarnResourceWarningr rl r r r __del__X s
zfile_wrapper.__del__c G t j| jg|R S r )r r% rE rY argsr r r r ^ zfile_wrapper.recvc G r r )r r( rE r r r r r| a r zfile_wrapper.sendNc C s$ |t jkr|t jkr|sdS td)Nr z-Only asyncore specific behaviour implemented.)rX rj r NotImplementedError)rY levelZoptnameZbuflenr r r rk d s
zfile_wrapper.getsockoptc C s( | j dk rd S | j }d| _ t| d S )Nr r )rE r r r r r r r o s
zfile_wrapper.closec C s | j S r )rE rl r r r rh v s zfile_wrapper.filenor ) r r r r[ r r r| rk r% r( r rh r r r r r P s
r c @ s e Zd ZdddZdd ZdS )file_dispatcherNc C sN t | d | d| _z| }W n ty Y nw | | t|d d S )NTF)rO r[ rU rh AttributeErrorset_filer set_blocking)rY rE rB r r r r[ { s
zfile_dispatcher.__init__c C s" t || _| j | _| d S r )r rX rh rR rd r r r r r s
zfile_dispatcher.set_filer )r r r r[ r r r r r r y s
r )r6 N)rJ FNNre )0__doc__r+ rX r r> r r r1 r r r r r r r r r
r r r
r r DeprecationWarningr r2 r7 r r Exceptionr KeyboardInterrupt
SystemExitr! r% r( r* r5 rF rI Zpoll3rN rO r r r rs r r r r r r sT <
'
*
)