python (3.11.7)
eVO 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 </BuggyBox/python/3.11.7/bootstrap/lib/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)<<<<<r" c Z | dd | d S )Nzunhandled close eventre )r r r s r r; zdispatcher.handle_close s(
-y999
r" NNr$ )r ),r r r debugrk rJ r closingrm frozensetr rr r} r rn ro AF_INET SOCK_STREAMr rj r rG rH r r r r r r r r r r% r r. r1 r' r r r r r r r; r! r" r rd rd s4 EIIJG D y)-- @ < < <! ! ! ! $*>8J
" ' ' ' & & & / / / $
5 5 5. . . .
(F F F9 9 9: : :< < <( ( (
= = = r" rd c . e Zd ZddZd Zd Zd Zd ZdS )dispatcher_with_sendNc L t | || d| _ d S r )rd rr
out_bufferr s r rr z dispatcher_with_send.__init__ s% D$,,, r" c d}t | | j d d }| j |d | _ d S )Nr i )rd r r )rp num_sents r
initiate_sendz"dispatcher_with_send.initiate_send s; ??4 %)@AA /())4r" c . | d S r$ )r r s r r z!dispatcher_with_send.handle_write
s r" c : | j pt | j S r$ )rk lenr r s r rH z dispatcher_with_send.writable
s N";s4?';';;r" c | j r%| dt | z | j |z | _ | d S )Nz
sending %s)r r ry r r )rp r s r r zdispatcher_with_send.send sO : 5 MM,d3 4 4 4 /D0 r" r )r r r rr r r rH r r! r" r r r sd 5 5 5
< < < r" r c f t j \ } }}g }|st d |rQ| |j j j |j j j t |j f |j
}|Q~|d \ }}}d d |D }|||f| ||fS )Nztraceback does not existrv c g | ]}d |z S )z
[%s|%s|%s]r! ).0xs r
<listcomp>z%compact_traceback.<locals>.<listcomp>+ s 666!\A%666r" ) r exc_infoAssertionErrorrI tb_framef_code co_filenameco_namer tb_linenotb_nextrz )r r tbr filefunctionliner s r r r s |~~HAq"
F
9 7888
K * K &
Z
!":D(D 8866v666 7 7D (D !1a --r" c & | t } t | D ]Q} | # t $ r }|j t k rn|s Y d }~;d }~wt $ r |s Y OxY w| d S r$ ) rD rE valuesr r< r= r r& clear)rO
ignore_allr s r close_allr . s
{
#**,,
GGIIII w%
#
IIKKKKKs A
A:
A&&A:posixc B e Zd Zd Zd Zd Zd Zd dZeZeZ d Z
d Z dS )
file_wrapperc 8 t j | | _ d S r$ )r duprR rp rR s r rr zfile_wrapper.__init__S s fRjjDGGGr" c | j dk r t j d| z t | | d S )Nr zunclosed file %r)source)rR warningswarnResourceWarningr r s r __del__zfile_wrapper.__del__V sD w!||
04 7 %)+ + + + JJLLLLLr" c 0 t j | j g|R S r$ )r r* rR rp argss r r zfile_wrapper.recv\ s 747*T*** *r" c 0 t j | j g|R S r$ )r r/ rR r s r r zfile_wrapper.send_ s 8DG+d+++ +r" Nc h |t j k r|t j k r|sdS t d )Nr z-Only asyncore specific behaviour implemented.)ro r r NotImplementedError)rp leveloptnamebuflens r r zfile_wrapper.getsockoptb sA ***6?** +q% '5 6 6
6r" c d | j dk rd S | j }d| _ t j | d S )Nr r )rR r r r s r r zfile_wrapper.closem s1 w{{BDG HRLLLLLr" c | j S r$ )rR r s r r zfile_wrapper.filenot s 7Nr" r$ ) r r r rr r r r r r* r/ r r r! r" r r r N s
! ! ! + + + , , , 6 6 6 6 r" r c e Zd ZddZd ZdS )file_dispatcherNc t | d | d| _ | }n# t $ r Y nw xY w| | t
j |d d S )NTF)rd rr rk r AttributeErrorset_filer set_blocking)rp rR rO s r rr zfile_dispatcher.__init__y s dC 0 0 0 !DN
YY[[!
MM" OB & & & & &s :
AAc t | | _ | j | _ | d S r$ )r ro r rh r r s r r zfile_dispatcher.set_file s> &r**DK ;--//DL r" r$ )r r r rr r r! r" r r r w s7 ' ' ' ' r" r )rB N)r[ FNNr )1__doc__r4 ro r rK r r r= r r r r r r r r
r r r
r r _DEPRECATION_MSG _deprecatedr r r> rD r r Exceptionr KeyboardInterrupt
SystemExitr& r* r/ r2 rA rU rZ poll3rb rd r r r r r r r! r" r <module>r) s 8 *
N X / @ @ @ @ :xL% " # #
JJ JJJ' ' ' i !2J? (% % % % N" " " "4 $a a a a a a a aP : 6. . .( > 7g' ' ' ' ' ' ' 'R * U s A# #A-,A-
Browse
Usage
Versions