/snap/core24/1643/usr/lib/python3.12/test/support/__pycache__
Edit: /snap/core24/1643/usr/lib/python3.12/test/support/__pycache__/asyncore.cpython-312.pyc (24987B)
ЦiO d Z ddlZddlZddlZddlZddlZddlZddlmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZ ee e
eeeeh Z e d Z G d de Zee e fZ d Z d Z d Z!d
Z"dd Z#dd Z$e$Z%dd
Z& G d d Z' G d de' Z(d Z)ddZ*ejV dk( r G d d Z, G d de' Z-yy# e$ r i ZY xw xY w) 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 errorcodec t j | S # t t t f$ r | t
v r t
| cY S d| z cY S w xY w)NzUnknown error %s)osstrerror
ValueError
OverflowError NameErrorr )errs ,/usr/lib/python3.12/test/support/asyncore.py _strerrorr J sI '{{3
y 1 ' ) S> !!3&&'s %AAAc e Zd Zy)ExitNowN)__name__
__module__ __qualname__ r r r R s r r c f | j y # t $ r | j Y y xY wN)handle_read_event_reraised_exceptions handle_errorobjs r readr' W 1
0c f | j y # t $ r | j Y y xY wr! )handle_write_eventr# r$ r% s r writer, _ s1
r) c f | j y # t $ r | j Y y xY wr! )handle_expt_eventr# r$ r% s r
_exceptionr/ g r( r) c 6 |t j z r| j |t j z r| j |t j
z r| j
|t j t j z t j z z r| j y y # t $ rB}|j t vr| j n| j Y d }~y Y d }~y d }~wt $ r | j Y y xY wr! )selectPOLLINr" POLLOUTr+ POLLPRIr. POLLHUPPOLLERRPOLLNVAL handle_closeOSErrorerrno
_DISCONNECTEDr$ r# )r& flagses r readwriter> o s 6== ! ! # 6>> ! " " $ 6>> ! ! ! # FNNV^^3fooE F G 77- '
s B.B2 2 D;3C88 Dc |t }|rHg }g }g }t |j D ]m \ }}|j }|j }|r|j | |r |j s|j | |s|s]|j | o g |cxk( r |cxk( r|k( rn nt j | y t j |||| \ }}}|D ]! }|j | }|t | # |D ]! }|j | }|t | # |D ]! }|j | }|t | # y y r! )
socket_maplistitemsreadablewritableappend acceptingtimesleepr1 getr' r, r/ ) timeoutmaprwr= fdr& is_ris_ws r pollrQ sI
{
BBCIIK( GB<<>D<<>D CMM t a 1 JJw --1a11a B''"+C{ I B''"+C{ #J B''"+C{ sO = r c |t }| t | dz } t j }|rt |j D ] \ }}d}|j
r$|t j t j z z }|j r |j s|t j z }|sn|j || |j | }|D ]% \ }}|j | }|t || ' y y )Ni r )r@ intr1 rQ rA rB rC r2 r4 rD rF r3 registerrI r> )rJ rK pollsterrN r& r< rL s r poll2rV s
{gdl#{{}H
CIIK( -GBE||~ 77||~cmm '!!"e, -
MM' " "IB''"+C{ c5 ! " r c |t }|rt t d rt }nt }||r
|| | |r y y |r |dkD r || | |dz
}|r|dkD ry y y y )NrQ r )r@ hasattrr1 rV rQ )rJ use_pollrK countpoll_funs r loopr] sh
{GFF+ } Wc " eai Wc "AIE eaicicr 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+y)%
dispatcherFNwarningc ` | t | _ n|| _ d | _ |rA|j d | j || d| _ |j
| _ y d | _
y # t $ r<}|j t t fv rd| _ n| j | Y d }~y d }~ww xY w)NFT)r@ _map_fileno setblocking
set_socket connected getpeernameaddrr9 r: r r del_channelsocket)selfsockrK r s r __init__zdispatcher.__init__ s ;"DIDI
U # OOD# & !DN
, , . DK
996 22 &+DN
$$S)
#
s
A( ( B-12B((B-c | j j dz | j j z g}| j r | j r|j d n | j r|j d | j |j d| j z ddj | t | fz S # t $ r' |j t | j Y Nw xY w)N. listeningrf z%s:%dz <%s at %#x> ) __class__r r rF rh rE rf TypeErrorreprjoinid)rk statuss r __repr__zdispatcher.__repr__ s ..++C/0K0KKL >>dii MM+ &
^^ MM+ & 99
/
g 12 0"T( ;;;
/
d499o.
/s C -C32C3c > | | j }| || j < y r! )rb rc )rk rK s r add_channelzdispatcher.add_channel s ;))C DLLr c T | j }| | j }||v r||= d | _ y r! )rc rb )rk rK rN s r ri zdispatcher.del_channel s.
\\ ;))C
9B r c ||f| _ t j || }|j d | j | y NF)family_and_typerj rd re )rk familytyperl s r
create_socketzdispatcher.create_socket s8 %t| }}VT* r c ^ || _ |j | _ | j | y r! )rj filenorc rz rk rl rK s r re zdispatcher.set_socket$ s$ {{} r c | j j t j t j | j j t j t j dz y # t
$ r Y y w xY w)NrX )rj
setsockopt
SOL_SOCKET SO_REUSEADDR
getsockoptr9 rk s r set_reuse_addrzdispatcher.set_reuse_addr) sj KK " "!!6#6#6 &&v'8'8'-':':<>?@
s A2A5 5 B Bc yNTr r s r rC zdispatcher.readable: r c yr r r s r rD zdispatcher.writable= r r c z d| _ t j dk( r|dkD rd}| j j | S )NTnt )rF r namerj listen)rk nums r r zdispatcher.listenD s4
77d?sQwC{{!!#&&r c F || _ | j j | S r! )rh rj bind)rk rh s r r zdispatcher.bindJ s {{ %%r c , d| _ d| _ | j j | }|t t
t fv s |t k( rt j dk( r|| _
y |dt fv r|| _
| j y t |t | )NFTr r )rf
connectingrj
connect_exr r r r r r rh r
handle_connect_eventr9 r )rk addressr s r connectzdispatcher.connectN s~ kk$$W- ;+6 6 &=RWW_ DI 1g, DI % % '#y~. .r c | j j \ }}||fS # t $ r Y y t $ r(}|j t
t t fv rY d }~y d }~ww xY wr! )rj acceptrs r9 r: r r r )rk connrh whys r r zdispatcher.accept\ s_
++-JD$ : yy[, ?? s # A A AAA c | j j | }|S # t $ rE}|j t k( rY d }~y|j t
v r| j
Y d }~y d }~ww xY wNr )rj sendr9 r: r r; r8 )rk dataresultr s r r zdispatcher.sendj s]
[[%%d+FM yyK'm+!!# s A-A( "A('A((A-c | j j | }|s| j y|S # t $ r-}|j t
v r| j Y d }~y d }~ww xY wNr )rj recvr8 r9 r: r; )rk buffer_sizer r s r r zdispatcher.recvw sb ;;##K0D !!# yyM)!!#
s -2 2 A("A#"A##A(c d| _ d| _ d| _ | j | j | j j y y # t $ r#}|j t t fvr Y d }~y d }~ww xY wr} )
rf rF r ri rj closer9 r: r r )rk r s r r zdispatcher.close sr ;; "
!!# #
99Xu$55 6
s A A;A66A;c Z t j j dt | z y )Nzlog: %s
)sysstderrr, str)rk messages r logzdispatcher.log s
s7|34r c B || j vrt |d| y y )Nz: )ignore_log_typesprint)rk r r s r log_infozdispatcher.log_info s" t,, , dG, - -r c | j r| j y | j s-| j r| j | j y | j y r! )rF
handle_acceptrf r r handle_readr s r r" z dispatcher.handle_read_event sI >>
))+ r c | j j t j t j }|dk7 rt |t | | j
d| _ d| _ y )Nr TF) rj r r SO_ERRORr9 r handle_connectrf r rk r s r r z dispatcher.handle_connect_event sT kk$$V%6%6H !8#y~. . r c | j ry | j s | j r| j | j y r! )rF rf r r handle_writer s r r+ z dispatcher.handle_write_event s4 >>
~~))+ r c | j j t j t j }|dk7 r| j y | j y r )rj r r r r8 handle_exptr s r r. z dispatcher.handle_expt_event sE kk$$V%6%6H !8
r c t \ }}}} t | }| j d|d|d|d|d d | j y # dt | z }Y BxY w)Nz)<__repr__(self) failed for object at %0x>z-uncaptured python exception, closing channel z (:rq )error)compact_tracebackrt rv r r8 )rk niltvtbinfo self_reprs r r$ zdispatcher.handle_error sj - /Q6 O T
I
OCbhNIs A A c ( | j dd y )Nz!unhandled incoming priority eventr` r r s r r zdispatcher.handle_expt s
99Er c ( | j dd y )Nzunhandled read eventr` r r s r r zdispatcher.handle_read s
,i8r c ( | j dd y )Nzunhandled write eventr` r r s r r zdispatcher.handle_write s
-y9r c ( | j dd y )Nzunhandled connect eventr` r r s r r zdispatcher.handle_connect s
/;r c H | j }| | j | y y r! )r handle_accepted)rk pairs r r zdispatcher.handle_accept s( {{} D $ ' r c H |j | j dd y )Nzunhandled accepted eventr` )r r )rk rl rh s r r zdispatcher.handle_accepted s
0)
>8J8J
"' & / $
5.
(F9:<(
=r r_ c , e Zd ZddZd Zd Zd Zd Zy)dispatcher_with_sendNc @ t j | || d| _ y r )r_ rm
out_bufferr s r rm z dispatcher_with_send.__init__ s D$, r c v d}t j | | j d d }| j |d | _ y )Nr i )r_ r r )rk num_sents r
initiate_sendz"dispatcher_with_send.initiate_send s4 ??4 %)@A //()4r c $ | j y r! )r r s r r z!dispatcher_with_send.handle_write s r c J | j xs t | j S r! )rf lenr r s r rD z dispatcher_with_send.writable s NN";s4??';;r c | j r | j dt | z | j |z | _ | j y )Nz
sending %s)r r rt r r )rk r s r r zdispatcher_with_send.send s: :: MM,d3 4 //D0 r r )r r r rm r r rD r r r r r r s 5
< r r c t j } | j }|s t d g }|rr|j |j
j j |j
j j t |j f |j }|rr~|d \ }}}dj |D cg c] }d|z c} }|||ft | | |fS c c}w )Nztraceback does not existrq z
[%s|%s|%s])r exception
__traceback__AssertionErrorrE tb_framef_code co_filenameco_namer tb_linenotb_nextru r )exctbr filefunctionlinexr s r r r s
--/C B
788
F
KK * * KK & &
ZZ
!":D(D 88v6!\A%6 7D (D !49c4 77 7s = C"c | t } t | j D ] } |j | j y # t $ r!}|j
t k( rn|s Y d }~Ld }~wt $ r |s Y _xY wr! ) r@ rA valuesr r9 r: r r# clear)rK
ignore_allr s r close_allr 0 s}
{
#**,
GGI IIK ww% # s A BA..Bposixc @ e Zd Zd Zd Zd Zd Zd dZeZeZ d Z
d Z y)
file_wrapperc 8 t j | | _ y r! )r duprN rk rN s r rm zfile_wrapper.__init__U s ffRjDGr c | j dk\ r t j d| z t | | j y )Nr zunclosed file %r)source)rN warningswarnResourceWarningr r s r __del__zfile_wrapper.__del__X s/ ww!|
04 7 %)+ JJLr c B t j | j g| S r! )r r' rN rk argss r r zfile_wrapper.recv^ s 77477*T* *r c B t j | j g| S r! )r r, rN r s r r zfile_wrapper.senda s 88DGG+d+ +r Nc j |t j k( r|t j k( r|syt d )Nr z-Only asyncore specific behaviour implemented.)rj r r NotImplementedError)rk leveloptnamebuflens r r zfile_wrapper.getsockoptd s4 ***6??*% '5 6
6r c t | j dk ry | j }d| _ t j | y )Nr r )rN r r r s r r zfile_wrapper.closeo s+ ww{BDG HHRLr c | j S r! )rN r s r r zfile_wrapper.filenov s 77Nr r! ) r r r rm r r r r r' r, r r r r r r r P s1
! + , 6 r r c e Zd ZddZd Zy)file_dispatcherNc t j | d | d| _ |j }| j | t
j |d y # t $ r Y 3w xY w)NTF)r_ rm rf r AttributeErrorset_filer set_blocking)rk rN rK s r rm zfile_dispatcher.__init__{ s[ dC 0 !DN
YY[
MM" OOB & "
s A A$#A$c t | | _ | j j | _ | j y r! )r rj r rc rz r s r r zfile_dispatcher.set_file s. &r*DK ;;--/DL r r! )r r r rm r r r r r r y s ' r r )g N)g >@FNNr} ).__doc__r1 rj r rG r r r: r r r r r r r r
r r r
r r r r; r@ r r Exceptionr KeyboardInterrupt
SystemExitr# r' r, r/ r> rQ rV poll3r] r_ r r r r r r r r r r! s
B*
:xL% " #
' i !2J? (% N"4 $a aP : 68*> 77g' 'R * U Q Js B9 9CC