!y[l9 g d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
Z
ddl m Z ddl m
Z
mZ ddlmZ ej Z ddlZddlmZmZmZmZ n# e$ r ej dk r dZY nw xY wd Zd
Z e j Z d Z d gZ e ed rd Z e d gz
Z ej dk rd
Z e d
gz
Z efdZ!d Z"d Z#d Z$d Z% G d d Z&er G d de& Z' G d de& Z( G d de) Z*d hZ?d>d3Z@n#ddlAZA e eAd4 reAjB ZCneAjD ZCd>d5Z@ej dk r0d6 ZEd7 ZF ejG e(eE d8 ZHd9 ZI ejG e'eH dS d: ZEd; ZF ejG e(eE dS )?)ClientListenerPipewait N )util)AuthenticationErrorBufferTooShort) reduction)
WAIT_OBJECT_0WAIT_ABANDONED_0 WAIT_TIMEOUTINFINITEwin32i g 4@AF_INETAF_UNIXAF_PIPEc . t j | z S Ntime monotonic)timeouts G/opt/alt/python-internal/lib64/python3.11/multiprocessing/connection.py
_init_timeoutr < s > g %% c 0 t j | k S r r )ts r _check_timeoutr ? s > a r c | dk rdS | dk r't j dt j S | dk r>t j dt j t
t fz d S t d )
Nr ) localhostr r z listener-)prefixdirr z\\.\pipe\pyc-%d-%d- zunrecognized family) tempfilemktempr get_temp_dirosgetpidnext
_mmap_counter
ValueErrorfamilys r arbitrary_addressr/ F s 9 kt7H7J7JKKKK 9 &< " T--@-@ A'BGIK K K K .///r c t j dk r| dk rt d| z t j dk r-| dk r)t t | st d| z d S d S d S )Nr r z Family %s is not recognized.r )sysplatformr, hasattrsocketr- s r _validate_familyr5 T s |w 6Y#6#67&@AAA
|w 6Y#6#6vv&& F ;f DEE E #6#6 F Fr c t | t k rdS t | t u r| d rdS t | t u st j | rdS t
d| z )Nr z\\r r z address type of %r unrecognized)typetuplestr
startswithr is_abstract_socket_namespacer, )addresss r address_typer= ` s
G}} y
g # '"4"4V"<"< y
g # !B7!K!K y:WDEEEr c e Zd ZdZddZd Zd Zd Zd Zd Z e
d Z e
d
Z e
d Z
d Zd
ZddZd ZddZddZd Zd dZd Zd ZdS ) _ConnectionBaseNTc | }|dk rt d |s|st d || _ || _ || _ d S )Nr zinvalid handlez6at least one of `readable` and `writable` must be True) __index__r, _handle _readable _writable)selfhandlereadablewritables r __init__z_ConnectionBase.__init__v sm !!## A:: -.. . J J HJ J
J !!r c @ | j | d S d S r rB _closerE s r __del__z_ConnectionBase.__del__ s# < # KKMMMMM $ #r c 2 | j t d d S )Nhandle is closed)rB OSErrorrM s r
_check_closedz _ConnectionBase._check_closed s! < ,-- - r c 2 | j st d d S )Nzconnection is write-only)rC rQ rM s r _check_readablez _ConnectionBase._check_readable s% ~ 6455 5 6 6r c 2 | j st d d S )Nzconnection is read-only)rD rQ rM s r _check_writablez _ConnectionBase._check_writable s% ~ 5344 4 5 5r c f | j rd| _ n| t d )NFzbad message length)rD rC closerQ rM s r _bad_message_lengthz#_ConnectionBase._bad_message_length s1 > "DNN JJLLL*+++r c | j d u S r rB rM s r closedz_ConnectionBase.closed s .|t##r c | j S r )rC rM s r rG z_ConnectionBase.readable
0~ r c | j S r )rD rM s r rH z_ConnectionBase.writable r^ r c : | | j S r )rR rB rM s r filenoz_ConnectionBase.fileno s 9 |r c j | j * | d | _ d S # d | _ w xY wd S r rK rM s r rX z_ConnectionBase.close sE " < #
$
# t #### $ #s ' 0r c | | t | }|j dk r| d }|j }|dk rt
d ||k rt
d |||z
}n-|dk rt
d ||z |k rt
d | ||||z d S )Nr Br zoffset is negativezbuffer length < offsetzsize is negativez buffer length < offset + size)rR rV
memoryviewitemsizecastnbytesr, _send_bytes)rE bufoffsetsizemns r
send_bytesz_ConnectionBase.send_bytes s : sOO :>>s A
H A:: 122 2 v:: 566 6 <v:DD
AXX /00 0
d]Q
<== = 6&4-/011111r c | | | t | d S r )rR rV ri _ForkingPicklerdumpsrE objs r sendz_ConnectionBase.send sQ ' ..s3344444r c | | ||dk rt d | | }|| | S )Nr znegative maxlength)rR rT r, _recv_bytesrY getvalue)rE maxlengthrj s r
recv_bytesz_ConnectionBase.recv_bytes s
Y]] 122 2 y)) ; $ $ & & &||~~ r c J | | t | 5 }|j }|t | z }|dk rt d ||k rt d | }| }|||z k r!t | |
d | |||z ||z |z |cd d d S # 1 swxY w Y d S )Nr znegative offsetzoffset too large) rR rT re rf lenr, rw tellr
rx seekreadinto)rE rj rk rm rf bytesizeresultrl s r recv_bytes_intoz _ConnectionBase.recv_bytes_into so
__ zH #a&&(Hzz !2333("" !3444%%''F;;==D&4-''$V__%6%6777 KKNNN OOAf 0 %} 9 : ;
<
<
<! s CDD D c | | | }t | S r )rR rT rw rq loads getbuffer)rE rj s r recvz_ConnectionBase.recv sV * $$S]]__555r c ~ | | | | S r )rR rT _pollrE r s r pollz_ConnectionBase.poll s; = zz'"""r c | S r rM s r __enter__z_ConnectionBase.__enter__ r c . | d S r rX rE exc_type exc_valueexc_tbs r __exit__z_ConnectionBase.__exit__
r )TT)r Nr )r )r )__name__
__module__ __qualname__rB rI rN rR rT rV rY propertyr\ rG rH ra rX ro ru rz r r r r r r r r r? r? s ss G " " " " . . .6 6 65 5 5, , , $ $ X$ X X
$ $ $2 2 2 2(5 5 5 26 6 6# # # # r r? c F e Zd Z dZdZej fdZd ZddZ d Z
d Z dS ) PipeConnectionFNc ` | j }|| || j d S r )_send_ovcancelrB )rE _CloseHandleovs r rL zPipeConnection._close s3 B~ L & & & & &r c | j t d t j | j |d \ }}|| _ |t j k r!t j |j gdt }n# | xY wd | _ |
d \ }}n$# d | _ |
d \ }}w xY w|t j k rt t j d d S )Nz/concurrent send_bytes() calls are not supportedT
overlappedFrP )r r, _winapi WriteFilerB ERROR_IO_PENDINGWaitForMultipleObjectseventr r GetOverlappedResultERROR_OPERATION_ABORTEDrQ errnoEPIPE)rE rj r errwaitresnwrittens r ri zPipeConnection._send_bytes s }( "5 6 6 6 ' cdKKKGB DM
='222 % <
E8 5 5G
$
" 6 6t < <
## !%
" 6 6t < <
#<<<<g555 ek+=>>> 65s 1A0 /B* 0BB* *!C c | j rd| _ t j S |dnt |d } t j | j |d \ }} |t j k r!t j |j gdt }n# | xY w| d \ }}|dk r>> &
OPP Psg F2 1B D$ B D$ #AF2 =%F2 #F2 $A F.F2 (F.+F2 -F..F2 2
G < GG c | j s#t j | j d dk rdS t t | g| S )Nr T)r r
PeekNamedPiperB boolr r s r r zPipeConnection._pollV sI '
-dl;;A>!CCtdVW--.. .r c | }t j }| | t j | j d }|*t | |z |k r| t j | j |d \ }}|
d \ }}| | |S )Nr Tr ) r r r r r r rB r| rY r r )rE r r rj r leftr rbytess r r z PipeConnection._get_more_data\ s ,,..C
A
GGCLLL( 66q9D"s3xx$'@'@((*** &t|TdKKKGB 0066KFC
GGBLLNN # # #Hr r ) r r r r r r CloseHandlerL ri rw r r r r r r r s
#&-&9 ' ' ' ' ( ( (4 Q Q Q Q@ / / /
r r c e Zd Z erej fdZej Zej Z
ne j fdZe j
Ze j Z
efdZe
fdZd Zd dZd ZdS )
Connectionc & || j d S r r[ rE rL s r rL zConnection._closes F4< r c & || j d S r r[ r s r rL zConnection._closex r r c t t | } || j | }||z }|dk rd S ||d }))NTr )r| rB )rE rj r remainingrn s r _sendzConnection._send} sN HH dlC((A NIA~~abb'C r c t j }| j }|}|dk r] ||| }t | }|dk r ||k rt t d | | ||z }|dk ]|S )Nr z got end of file during message)r r rB r| r rQ r )rE rl readrj rF r chunkrn s r _recvzConnection._recv s jll !mmD++EE
AAvv $$"N!"BCCC IIe NI !mm
r c t | }|dk rkt j dd }t j d| }| | | | | | d S t j d| }|dk r,| | | | d S | ||z d S )Ni!i!Qi @ )r| structpackr )rE rj rn
pre_headerheaders r ri zConnection._send_bytes s HH z>> T2..J[q))F JJz " " " JJv JJsOOOOO [q))F5yy
6"""
3
6C<(((((r Nc D | d }t j d| \ }|dk r>| d }t j d| \ }|||k rd S | | S )N r r r )r r unpackrx )rE r rj rl s r rw zConnection._recv_bytes s jjmm
dCLLNN33 2::**Q--CM$ 77ED 4'>>4zz$ r c B t | g| }t | S r )r r )rE r rs r r zConnection._poll s $ ! !Awwr r )r r r r _multiprocessing closesocketrL ru _writer _readr( rX r r r r ri rw r r r r r r l s
0 < ! ! ! !!& % " ! ! ! ! % % ) ) ). r r c \ e Zd Z d
dZd Zd Zed Zed Zd Z d Z
dS ) r Nr c 8 |p|rt | pt }|pt | }t | |dk rt || | _ nt
||| | _ |$t |t st d || _
d S Nr z authkey should be a byte string) r= default_familyr/ r5 PipeListener _listenerSocketListener
isinstancebytes TypeError_authkey)rE r< r. backlogauthkeys r rI zListener.__init__ s #G = W(=(= #" 6 .v 6 6 Y )'7 ; ;DNN +GVW E EDN z'5'A'A =>> >
r c | j t d | j }| j *t || j t || j |S )Nzlistener is closed)r rQ acceptr deliver_challengeanswer_challenge)rE cs r r zListener.accept sd
> !.// / N ! ! # # = $ a / / / Q
. . .r c T | j }| d | _ | d S d S r )r rX )rE listeners r rX zListener.close s; > !DN NN r c | j j S r )r _addressrM s r r< zListener.address s
~&&r c | j j S r )r _last_acceptedrM s r
last_acceptedzListener.last_accepted s
~,,r c | S r r rM s r r zListener.__enter__ r r c . | d S r r r s r r zListener.__exit__ r r )NNr N) r r r rI r rX r r< r r r r r r r r s
' ' X' - - X- r r c " |pt | }t | |dk rt | }nt | }|$t |t
st
d | t || t || |S r ) r= r5
PipeClient SocketClientr r r r r )r< r. r r s r r r s
,|G,,FV
w ! !:gu#=#=9:::G$$$!W%%% Hr Tc | rt j \ }}| d | d t | }t | }n8t j \ }}t |d }t |d }||fS )NTFrH rG )r4
socketpair setblockingr detachr( pipe)duplexs1s2c1c2fd1fd2s r r r s 1&((FB NN4 NN4 BIIKK((BBIIKK((BBwyyHCC%000BC%000B2v
r c
t d }| r4t j }t j t j z }t
t
}}n!t j }t j }dt
}}t j ||t j z t j z t j
t j z t j z d||t j
t j }t j ||dt j t j t j t j }t j |t j d d t j |d }| d \ } }
t) || } t) || } | | fS )Nr r r Tr r
r )r/ r PIPE_ACCESS_DUPLEX GENERIC_READ
GENERIC_WRITEBUFSIZEPIPE_ACCESS_INBOUNDCreateNamedPipeFILE_FLAG_OVERLAPPED FILE_FLAG_FIRST_PIPE_INSTANCEPIPE_TYPE_MESSAGEPIPE_READMODE_MESSAGE PIPE_WAITNMPWAIT_WAIT_FOREVERNULL
CreateFile
OPEN_EXISTINGSetNamedPipeHandleStateConnectNamedPiper r )
r r< openmodeaccessobsizeibsizeh1h2r _r r r s
r r r ( s\ $I.. ( 1H )G,AAF $gFFF 2H *F FF
$ X << 12 %(E E
vvw ; L
VQ g.C (', ' -tT -bTBBB
//553 B
0
0
0
B
0
0
02v
r c $ e Zd Z ddZd Zd ZdS )r r c t j t t | | _ t j dk r0| j t j t j d | j d | j | | j
| | j | _ n(# t $ r | j w xY w|| _ d | _ |dk r>t# j | s*t# j | t j |fd | _ d S d | _ d S )Nposixr Tr r args exitpriority)r4 getattr_socketr( name
setsockopt
SOL_SOCKET SO_REUSEADDRr
bindlisten getsocknamer rQ rX _familyr r r; Finalizeunlink_unlink)rE r< r. r s r rI zSocketListener.__init__X sF }WVV%<%<== w'!! ''(9(.(;Q@ @ @ L $ $T * * * L g & & & L ( ( ( L 4 4 6 6DMM L " Y t'H'Q'Q =biwjq DLLL DLLLs B,C %D c | j \ }| _ | d t | S NT)r7 r r r
r r rE ss r r zSocketListener.acceptq sE !% !4!4!6!6 4
d!((**%%%r c | j | j }|d | _ | d S d S # | j }|d | _ | w w xY wr )r7 rX rB )rE rA s r rX zSocketListener.closev sr L \F! # "! \F! # "s 9 AN)r )r r r rI r rX r r r r r T sK 2& & &
r r c : t | }t j t t | 5 }| d | | t | cd d d S # 1 swxY w Y d S rD )r= r4 r6 r
connectr r )r< r. rF s r r r s '
"
"F // 1 1 &Q
d '!((**%%& & & & & & & & & & & & & & & & & &s A BBBc < e Zd Z ddZddZd Zed ZdS ) r Nc || _ | d g| _ d | _ t j d| j t j | t j | j | j fd | _ d S )NT)firstz listener created with address=%rr r3 )
r _new_handle
_handle_queuer r sub_debugr@ r _finalize_pipe_listenerrX )rE r< r s r rI zPipeListener.__init__ su #DM"&"2"2"2">">!?D "&D N=t} M M M l:($-8q DJJJr Fc
. t j t j z }|r|t j z }t j | j |t j t j z t j z t j t t t j t j S r )
r r r r r r r r! r" PIPE_UNLIMITED_INSTANCESr r# r$ )rE rL flagss r rM zPipeListener._new_handle sp .1MME
?>>*
u)G,II!"0'7,gl
r c D | j | | j d } t j |d } t j |j gdt }n.# | t j
| xY w | d \ }}nJ# | d \ }}w xY w# t $ r }|j
t j k r Y d }~nd }~ww xY wt | S )Nr Tr F)rN appendrM popr r( r r r r r r rQ r
ERROR_NO_DATAr )rE rF r resr/ r r s r r zPipeListener.accept s8 % %d&6&6&8&8 9 9 9'++A..F
$ -fFFF $!8
E85 5CCIIKKK'/// 3 3D 9 9FAssR 3 3D 9 9FAs#OOO
:!666 76666
"&)) )s6 C& !B C +B,,C C#&
D0D Dc b t j d| | D ]}t j | d S )Nz closing listener with address=%r)r rO r r )queuer< rF s r rP z$PipeListener._finalize_pipe_listener sB N=w G G G
,
,#F++++
,
,r r )F)r r r rI rM r staticmethodrP r r r r r sk
* * *.
, ,
, , ,r r c t } t j | d t j | t j t j z dt j t j t j t j }nG# t $ r9}|j
t j t j fvst | r Y d }~nd }~ww xY wt j |t j d d t! | S )Nr r )r r
WaitNamedPiper% r r r$ r& r rQ r ERROR_SEM_TIMEOUTERROR_PIPE_BUSYr r' r! r )r< r hr s r r r s
OO
%gt444&W 1G4I Iw|W%:0',
:g&?&-&=&? ? ?BPQRBSBS?? ? ? ? ?
" '
w,dD a s A.B
C /B??C s #CHALLENGE#s #WELCOME#s #FAILURE#c dd l }t |t s/t d t | t
j t }| t |z | ||d }|
d }||k r | t d S | t t! d )Nr Authkey must be bytes, not {0!s}md5 zdigest received was wrong)hmacr r r, formatr7 r( urandomMESSAGE_LENGTHro CHALLENGEnewdigestrz WELCOMEFAILUREr
connectionr rg messagerm responses r r r s KKK gu % % F . 5 5d7mm D DF F Fj ((G)g-...
XXgw
.
.
5
5
7
7F$$S))H6 g&&&&& g&&&!"=>>>r c dd l }t |t s/t d t | | d }|t t d }| ||d
}| | | d }|t k rt d d S )Nr rd rf re zdigest sent was rejected)rg r r r, rh r7 rz r| rk rl rm ro rn r rp s r r r s KKK gu % % F . 5 5d7mm D DF F F##C((Gc)nnoo&G
XXgw
.
.
5
5
7
7F&!!!$$S))H7!"<=== r c e Zd Zd Zd Zd ZdS )ConnectionWrapperc | || _ || _ || _ dD ]#}t || }t | || $d S )N)ra rX r rz ro )_conn_dumps_loadsr6 setattr)rE connrr r attrrt s r rI zConnectionWrapper.__init__ sT
K % %D$%%C D$ $ $ $ $ % %r c d | | }| j | d S r )ry rx ro )rE rt rF s r ru zConnectionWrapper.send s/ KK
a r c ^ | j }| | S r )rx rz rz rE s r r zConnectionWrapper.recv s% J ! ! # #{{1~~ r N)r r r rI ru r r r r rv rv sA % % %! ! ! r rv c f t | fd d d d d S )Nr utf-8) xmlrpclibrr encode)rt s r
_xml_dumpsr s, ??C64tQ 7 7 > >w G GGr c j t | d \ \ }}|S )Nr )r r decode)rF rt methods r
_xml_loadsr s* __QXXg%6%677NFSF Jr c e Zd Zd ZdS ) XmlListenerc x dd l ma t | }t |t t S Nr )
xmlrpc.clientclientr r r rv r r rs s r r zXmlListener.accept% s7 ))))))ood## j*===r N)r r r r r r r r r $ s# > > > > >r r c X dd l ma t t | i |t
t S r )r r r rv r r r )r4 kwdss r XmlClientr + s3 %%%%%% VT 2T 2 2J
K KKr c t | }g }|rt j |d| }|t k rnt |cxk rt t | z k rn n |t z }nDt |cxk rt t | z k rn n |t z }nt d | || ||dz d }d}||S )NFzShould not get herer r ) listr r r r r| r
r rU )handlesr LreadyrX s r _exhaustive_waitr 6 s
MM 0E7CCCl"" #>>>>
A(>>>>>>}$!SDDDD+;c!ff+DDDDDD''"#8999 LL3 #a%&& AG r c
|t }n |dk rd}nt |dz dz }t | } i g }t
t } | D ]B} t |d } t j | dd \ }}n*# t $ r }d |j }}|t vr Y d }~nd }~ww xY w|t
j
k r | | | |j < |rpt j d d dk rQ | d \ } }n # t $ r}|j }Y d }~nd }~ww xY w|st! |d rd|_
| d} # t& $ r | | < Y @w xY wt+ | }|D ]}| |D ]} | d \ } }n(# t $ r}|j }|t vr Y d }~nd }~ww xY w|t
j k r? |j }
| |dk rt! |d rd|_ n# |D ]}| |D ]} | d \ } }n(# t $ r}|j }|t vr Y d }~nd }~ww xY w|t
j k r? |j }
| |dk rt! |d rd|_ w xY w
fd
|D
fd | D S ) Nr r] g ?ra T ) r Fr c 3 ( K | ] }| V
d S r r ).0ra waithandle_to_objs r zwait.. s) I Ia .q 1 I I I I I Ir c g | ]}|v | S r r )r o
ready_objectss r
zwait.. s# ===a!}*<*<*<*<*-C-C-E-Ew O OM
8
8 3 3D 9 9FAss *C-// 0//// '999)"(3A!%%a(((axx #1&:;; 837A 0
8
8
8 3 3D 9 9FAss *C-// 0//// '999)"(3A!%%a(((axx #1&:;; 837A 0
8 I I I I= I I IIII====;====s I4 "E:3!BI4
B< B72I4 7B<. s CCCMS&CKCCCr r )
_WaitSelectorregister selectors
EVENT_READr r select)r r selectorrt deadliner s r r r s9
__ )"
=
=!!#y';<<<<" >++g5
) 00 )CCUCCC ) ) ) ) ) ) ) ) *"*T^-=-="="Q;;#( ) ) ) ) ) ) ) )
) ) ) ) ) ) ) ) ) ) )s A!B+> B+*B++B/2B/c | }t j |t j t j 5 }ddlm} | | }t || j | j
ffcd d d S # 1 swxY w Y d S )Nr )resource_sharer) ra r4 fromfdr SOCK_STREAMr$ r DupSocketrebuild_connectionrG rH )r| rF rF r dss r reduce_connectionr s
]66>63E
F
F J! ) ) ) ) ) ) **1--B%DM4='II J J J J J J J J J J J J J J J J J Js 1A==BBc p | }t | || S r r r )r rG rH socks r r r s) yy{{$++--8<<r s 3
2
2
1 1 1 1 1 1 1 1 *NNNOOOOOOOOOOOOO
|w
GGG !!
;
769 N H<7 N H - & & & & 0 0 0
F
F
F
F
F
F&T T T T T T T Tn _] ] ] ] ] ] ] ]@M M M M M M M Mh; ; ; ; ;v ; ; ;|
* <7 && & & &X) ) ) ) )V ) ) )X& & & <76, 6, 6, 6, 6,v 6, 6, 6,p! ! !>
?
?
? > > >$
H H H > > > > >( > > >L L L <7 ( .0MNML> L> L> L> L>`
wy.)) 1!.
!0
) ) ) )6 <7J J J = = = Iz#4555K K K
: : : I~'=>>>>>F F F2 2 2 Iz#455555s A A0/A0