xn0 d Z ddlZddlZddlZddlZddlZddlZddlmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZ dZ ej eed ee e
eeeeh Z e n
# e$ r i ZY nw xY wd Z G d d e Z e e e fZ!d
Z"d Z#d Z$d
Z%d dZ&d dZ'e'Z(d dZ) G d d Z* G d de* Z+d Z,d!dZ-ej. dk r G d d Z/ G d d e* Z0dS 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 errorcodeznThe {name} module is deprecated and will be removed in Python {remove}. The recommended replacement is asyncio) )removec t j | S # t t t f$ r | t
v rt
| cY S d| z cY S w xY w)NzUnknown error %s)osstrerror
ValueError
OverflowError NameErrorr )errs //opt/alt/python311/lib64/python3.11/asyncore.py _strerrorr I se '{3
y 1 ' ' ' ) S> ! ! !!3&&&&'s -A
A
A
c e Zd ZdS )ExitNowN)__name__
__module__ __qualname__ r r r Q s Dr" r c | | d S # t $ r | Y d S xY wN)handle_read_event_reraised_exceptions handle_errorobjs r readr* V X
;c | | d S # t $ r | Y d S xY wr$ )handle_write_eventr& r' r( s r writer/ ^ sX
r, c | | d S # t $ r | Y d S xY wr$ )handle_expt_eventr& r' r( s r
_exceptionr2 f r+ r, c D |t j z r| |t j z r| |t j z r| |t j t j z t j z z r|
d S d S # t $ rH}|j t vr| n|
Y d }~d S Y d }~d S d }~wt $ r | Y d S xY wr$ )selectPOLLINr% POLLOUTr. POLLPRIr1 POLLHUPPOLLERRPOLLNVAL handle_closeOSErrorerrno
_DISCONNECTEDr' r& )r) flagses r readwriterA n sT 6= $ ! ! # # # 6> ! % " " $ $ $ 6> ! $ ! ! # # # FNV^3foE F 7- ' '
s B&B, ,
D 67C99#D c |t }|rog }g }g }t | D ]{\ }}| }| }|r| | |r |j s| | |s|r| | |g |cxk r
|cxk r|k rn nt j | d S t j |||| \ }}}|D ])}|
| }|t | *|D ])}|
| }|t | *|D ]+}|
| }|t | *d S d S r$ )
socket_maplistitemsreadablewritableappend acceptingtimesleepr4 getr* r/ r2 ) timeoutmaprwr@ fdr) is_ris_ws r pollrU s
{
" BBCIIKK(( GB<<>>D<<>>D
CM
t
a 1 Jw F-1a111a B''"++C{ IIII B''"++C{ #JJJJ B''"++C{ sOOOOE" " < r" c . |t }| t | dz } t j }|rt | D ]y\ }}d}| r |t j t j z z }| r|j
s|t j z }|r| || z| | }|D ]/\ }}|
| }| t || .d S d S )Ni r )rD intr4 rU rE rF rG r5 r7 rH rJ r6 registerrM rA )rN rO pollsterrR r) r? rP s r poll2rZ s'
{gdl##{}}H
"CIIKK(( - -GBE||~~
8 77||~~
(cm
( '
-!!"e,,, MM' " " " "IB''"++C{ c5 ! ! ! !!" " " "r" >@Fc |t }|r t t d rt }nt }||r || | |d S d S |r!|dk r || | |dz
}|r
|dk d S d S d S d S )NrU r )rD hasattrr4 rZ rU )rN use_pollrO countpoll_funs r looprb s
{ GFF++ } # HWc " " " # # # # # eaii HWc " " "AIE eaiiii iir" c e Zd ZdZdZdZdZdZdZ e dh Z
d#dZ d Z d$dZ
d$dZej ej fdZd$d Zd
Zd Zd Zd
Zd Zd Zd Zd Zd Z d Z d Z d%dZ d Z d Z!d Z"d Z#d Z$d Z%d Z&d Z'd Z(d Z)d! Z*d" Z+dS )&
dispatcherFNwarningc |
t | _ n|| _ d | _ |r| d | || d| _ | | _ d S # t $ r>}|j t t fv rd| _ n| | Y d }~d S d }~ww xY wd | _
d S )NFT)rD _map_fileno setblocking
set_socket connected getpeernameaddrr< r= r r del_channelsocket)selfsockrO r s r __init__zdispatcher.__init__ s ;"DIIDI
U # # # OOD# & & & !DN
, , . .
96 222 &+DNN
$$S)))
#NNNNN
DKKKs A. .
B683B11B6c | j j dz | j j z g}| j r | j r| d n | j r| d | j V | d| j z n7# t $ r* | t | j Y nw xY wdd | t | fz S )N. listeningrk z%s:%dz <%s at %#x> ) __class__r r rJ rm rI rk TypeErrorreprjoinid)rp statuss r __repr__zdispatcher.__repr__ s .+C/0KKL > 'di ' MM+ & & & &
^ ' MM+ & & & 9
/
g 12222
/
/
/
d49oo.....
/ 0 0"T(( ;;;s & B 1B87B8c , || j }| || j < d S r$ )rg rh )rp rO s r add_channelzdispatcher.add_channel s ;)C DLr" c B | j }|| j }||v r||= d | _ d S r$ )rh rg )rp rO rR s r rn zdispatcher.del_channel s0
\ ;)C
99B r" c ||f| _ t j || }| d | | d S NF)family_and_typero ri rj )rp familytyperq s r
create_socketzdispatcher.create_socket sK %t| }VT** r" c p || _ | | _ | | d S r$ )ro filenorh r rp rq rO s r rj zdispatcher.set_socket# s2 {{}} r" c | j t j t j | j t j t j dz d S # t
$ r Y d S w xY w)Nr] )ro
setsockopt
SOL_SOCKET SO_REUSEADDR
getsockoptr< rp s r set_reuse_addrzdispatcher.set_reuse_addr( s K " "!6#6 &&v'8'-':< <>?@
DD s A A$ $
A21A2c dS NTr! r s r rG zdispatcher.readable9 tr" c dS r r! r s r rH zdispatcher.writable< r r" c t d| _ t j dk r|dk rd}| j | S )NTnt )rJ r namero listen)rp nums r r zdispatcher.listenC s7
7d??sQwwC{!!#&&&r" c D || _ | j | S r$ )rm ro bind)rp rm s r r zdispatcher.bindI s { %%%r" c L d| _ d| _ | j | }|t t
t fv s|t k rt j dk r || _
d S |dt fv r || _
| d S t |t | )NFTr r )rk
connectingro
connect_exr r r r r r rm r
handle_connect_eventr< r )rp addressr s r connectzdispatcher.connectM s k$$W-- ;+6 6 6 &==RW__ DI F 1g, DI % % ' ' ' ' '#y~.. .r" c | j \ }}||fS # t $ r Y d S t $ r'}|j t
t t fv rY d }~d S d }~ww xY wr$ )ro acceptrx r< r= r r r )rp connrm whys r r zdispatcher.accept[ s
++--JD$ : 44 y[, ???ttttt s "
A A AAA c | j | }|S # t $ rD}|j t k rY d }~dS |j t
v r| Y d }~dS d }~ww xY wNr )ro sendr< r= r r> r; )rp dataresultr s r r zdispatcher.sendi s
[%%d++FM yK''qqqqqm++!!###qqqqq s
A,A'"A'&A''A,c | j | }|s| dS |S # t $ r.}|j t
v r| Y d }~dS d }~ww xY wNr" )ro recvr; r< r= r> )rp buffer_sizer r s r r zdispatcher.recvv s ;##K00D
!!###s yM))!!###sssss
s 06 6
A. "A)(A))A.c d| _ d| _ d| _ | | j J | j d S # t $ r!}|j t t fvr Y d }~d S d }~ww xY wd S r )
rk rJ r rn ro closer< r= r r )rp r s r r zdispatcher.close s ; "
!!#####
9Xu$555 655555
# "s A
A8A33A8c d t j dt | z d S )Nzlog: %s
)sysstderrr/ str)rp messages r logzdispatcher.log s)
s7||344444r" infoc D || j vrt |d| d S d S )Nz: )ignore_log_typesprint)rp r r s r log_infozdispatcher.log_info s7 t, , , dddGG, - - - - - - ,r" c | j r| d S | j s1| j r| | d S | d S r$ )rJ
handle_acceptrk r r handle_readr s r r% z dispatcher.handle_read_event s| >
,))+++ r" c | j t j t j }|dk r t |t | | d| _ d| _ d S )Nr TF) ro r r SO_ERRORr< r handle_connectrk r rp r s r r z dispatcher.handle_connect_event sa k$$V%6HH !88#y~~.. . r" c | j rd S | j s| j r| | d S r$ )rJ rk r r handle_writer s r r. z dispatcher.handle_write_event sQ >
F~ ,
,))+++ r" c | j t j t j }|dk r| d S | d S r )ro r r r r; handle_exptr s r r1 z dispatcher.handle_expt_event s[ k$$V%6HH !88
r" c t \ }}}} t | }n# dt | z }Y nxY w| d|d|d|d|d d | d S )Nz)<__repr__(self) failed for object at %0x>z-uncaptured python exception, closing channel z (:rv )error)compact_tracebackry r{ r r; )rp niltvtbinfo self_reprs r r' zdispatcher.handle_error s - / /Q6 O T
II OCbhhNIII
s % ;c 2 | dd d S )Nz!unhandled incoming priority eventre r r s r r zdispatcher.handle_expt s
99EEEEEr" c 2 | dd d S )Nzunhandled read eventre r r s r r zdispatcher.handle_read s
,i88888r" c 2 | dd d S )Nzunhandled write eventre r r s r r zdispatcher.handle_write s
-y99999r" c 2 | dd d S )Nzunhandled connect eventre r r s r r zdispatcher.handle_connect s
/;;;;;r" c J | }| | j | d S d S r$ )r handle_accepted)rp pairs r r zdispatcher.handle_accept s3 {{}} D $ ' ' ' ' r" c Z | | dd d S )Nzunhandled accepted eventre )r r )rp rq rm s r r zdispatcher.handle_accepted s*
0)<<<<