python (3.11.7)
e~~ 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<dZ+ej dk rd=d Z,nd=d Z, G d d e) Z-d! Z.ej dk r G d" d#e) Z/d$ Z0d%Z1d&Z2d'Z3d(Z4d) Z5d* Z6 G d+ d,e) Z7d- Z8d. Z9 G d/ d0e* Z:d1 Z;ej dk rd2 Z<ej= ej> 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 N/BuggyBox/python/3.11.7/bootstrap/lib/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 )
z?
Return an arbitrary free address for the given family
r ) 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 dS dS dS )zD
Checks if the family is valid for the current environment.
r r z Family %s is not recognized.r N)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 )z]
Return the types of the address
This can be 'AF_INET', 'AF_UNIX', or 'AF_PIPE'
r 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 du S )z True if the connection is closedNrB rM s r closedz_ConnectionBase.closed s |t##r c | j S )z"True if the connection is readable)rC rM s r rG z_ConnectionBase.readable ~ r c | j S )z"True if the connection is writable)rD rM s r rH z_ConnectionBase.writable r^ r c 8 | | j S )z+File descriptor or handle of the connection)rR rB rM s r filenoz_ConnectionBase.fileno s |r c h | j * | d| _ dS # d| _ w xY wdS )zClose the connectionNrK rM s r rX z_ConnectionBase.close sB < #
$
# t #### $ #s & /r c | | t | }|j dk r| d }|j }|dk rt
d ||k rt
d |||z
}n-|dk rt
d ||z |k rt
d | ||||z dS ) z,Send the bytes data from a bytes-like objectr Br zoffset is negativezbuffer length < offsetNzsize 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 | dS )zSend a (picklable) objectN)rR rV ri _ForkingPicklerdumpsrE objs r sendz_ConnectionBase.send sN ..s3344444r c | | ||dk rt d | | }|| | S )z7
Receive bytes data as a bytes object.
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 H | | t | 5 }|j }|t | z }|dk rt d ||k rt d | }| }|||z k r!t | |
d | |||z ||z |z |cddd S # 1 swxY w Y dS )zq
Receive bytes data into a writeable bytes-like object.
Return the number of bytes read.
r znegative offsetzoffset too largeN) rR rT re rf lenr, rw tellr
rx seekreadinto)rE rj rk rm rf bytesizeresultrl s r recv_bytes_intoz _ConnectionBase.recv_bytes_into sj
__ zH #a&&(Hzz !2333("" !3444%%''F;;==D&4-''$V__%6%6777 KKNNN OOAf 0 %} 9 : ;
<
<
<! s CDD Dc | | | }t | S )z Receive a (picklable) object)rR rT rw rq loads getbuffer)rE rj s r recvz_ConnectionBase.recv sS $$S]]__555r c | | | | | S )z/Whether there is any input available to be read)rR rT _pollrE r s r pollz_ConnectionBase.poll s8 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 H e Zd ZdZdZdZej fdZd Z d dZ
d Z d Z dS )
PipeConnectionz
Connection class based on a Windows named pipe.
Overlapped I/O is used, so the handles must have been created
with FILE_FLAG_OVERLAPPED.
FNc ` | 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<t j }|
| |S |t j k r| || S n# | d \ }}|dk r@t j }|
| |c cY S |t j k r| || c cY S w xY wn/# t" $ r"}|j t j k rt( d }~ww xY wt+ d )NF Tr r z.shouldn't get here; expected KeyboardInterrupt)_got_empty_messageioBytesIOminr ReadFilerB r r r r r r writer ERROR_MORE_DATA_get_more_datarQ winerrorERROR_BROKEN_PIPEEOFError RuntimeError) rE maxsizebsizer r r nreadfes r rw zPipeConnection._recv_bytes6 s &
*/'z||# &C4E4E % .t|U;? A A AGBD '":::&-&D!#
E8'= '=G %'%;%;D%A%A
s !88 "
A GGBLLNN 3 3 3#$H G$; ; ;#'#6#6r7#C#C C < &(%;%;D%A%A
s !88 "
A GGBLLNN 3 3 3#$HHHHH G$; ; ;#'#6#6r7#C#C C C C C C C C C C < zW%>>> &
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 __doc__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 ZdZerej fdZej Z ej
Z ne j
fdZe j Z e j Z e fdZe fdZd Zd
dZd ZdS )
Connectionzo
Connection class based on an arbitrary file descriptor (Unix only), or
a socket handle (Windows).
c & || 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 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 ZdZd dZd Zd Zed Zed Z d Z
d
Z dS ) r z
Returns a listener object.
This is a wrapper for a bound socket which is 'listening' for
connections, or for a Windows named pipe.
Nr c 8 |p|rt | pt }|pt | }t | |dk rt || | _ nt
||| | _ |$t |t st d || _
d S )Nr 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 r*t || j t || j |S )zz
Accept a connection on the bound socket or named pipe of `self`.
Returns a `Connection` object.
Nzlistener is closed)r rQ acceptr deliver_challengeanswer_challenge)rE cs r r zListener.accept sa > !.// / N ! ! # # = / a / / / Q
. . .r c R | j }| d| _ | dS dS )zA
Close the bound socket or named pipe of `self`.
N)r rX )rE listeners r rX zListener.close s6 > !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 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 )z=
Returns a connection to the address of a `Listener`
r Nr ) 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 )L
Returns pair of connection objects at either end of a pipe
TFrH 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 dd t j |d }| d \ } }
t) || } t) || } | | fS ) r r r r NTr 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 ' sW $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 ZdZddZd Zd ZdS )r zO
Representation of a socket which is bound to an address and listening
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__W 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)r9 r r r r r rE ss r r zSocketListener.acceptp sE !% !4!4!6!6 4
d!((**%%%r c | j | j }|d | _ | d S d S # | j }|d | _ | w w xY wr )r9 rX rD )rE rC s r rX zSocketListener.closeu sr L \F! # "! \F! # "s 9 AN)r )r r r r rI r rX r r r r r S sP 2& & &
r r c 8 t | }t j t t | 5 }| d | | t | cddd S # 1 swxY w Y dS )zO
Return a connection object connected to the socket given by `address`
TN)r= r4 r8 r connectr r )r< r. rG s r r r s '
"
"F // 1 1 &Q
d '!((**%%& & & & & & & & & & & & & & & & & &s A BBBc > e Zd ZdZddZd dZd Zed ZdS )
r z0
Representation of a named pipe
Nc || _ | d g| _ d | _ t j d| j t j | t j | j | j fd | _ d S )NT)firstz listener created with address=%rr r5 )
r _new_handle
_handle_queuer r sub_debugrB 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 rM flagss r rN 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)rO appendrN popr r* r r r r r r rQ r
ERROR_NO_DATAr )rE rF r resr1 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 rP r r )queuer< rF s r rQ z$PipeListener._finalize_pipe_listener sB N=w G G G
,
,#F++++
,
,r r )F) r r r r rI rN r staticmethodrQ r r r r r sp
* * *.
, ,
, , ,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 dd t! | S )zU
Return a connection object connected to the pipe given by `address`
r r N)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 rh messagern 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 re rg rf zdigest sent was rejected)rh r r r, ri r7 rz r| rl rm rn ro ro r rq 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_loadsr8 setattr)rE connrr r attrrt s r rI zConnectionWrapper.__init__ sT
K % %D$%%C D$ $ $ $ $ % %r c d | | }| j | d S r )rz ry ro )rE rt rG s r ru zConnectionWrapper.send s/ KK
a r c ^ | j }| | S r )ry rz r{ rF s r r zConnectionWrapper.recv s% J ! ! # #{{1~~ r N)r r r rI ru r r r r rw rw
sA % % %! ! ! r rw 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)rG 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 rw 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 rw r r r )r6 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 rV )handlesr LreadyrY s r _exhaustive_waitr 5 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 dd 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 )
Wait till an object in object_list is ready/readable.
Returns list of those objects in object_list which are ready/readable.
Nr r^ g ?ra T ) r Fr c 3 ( K | ] }| V
d S r r ).0rb waithandle_to_objs r <genexpr>zwait.<locals>.<genexpr> s) I Ia .q 1 I I I I I Ir c g | ]}|v | S r r )r o
ready_objectss r
<listcomp>zwait.<locals>.<listcomp> s# ===a!}*<*<*<*<*<r )r intr setr8 r r rQ r
_ready_errorsr rV r r1 getwindowsversionr r3 r addAttributeErrorrA r keysr r update) object_listr ov_list
ready_handlesr ra r r r r1 r r s @@r r r K sX ? GG
q[[GG'D.3.//G;''
6 8
$
$ $ $Q 1 1F
"")"26688Q"E"ECC" " " ""&
C m33 ! 43333" g 666 r***67)"(33
<#"7"9"9"1""="G"G 1)+)?)?)F)F33#* 1 1 1&'j 1#& <716J+K+K <7; 4%))!,,,"#7 & 9 9 978%akkmm4449: -->-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 I3 !E92!BI3
B; B61I3 6B;;AI3 D)(I3 )
E3D?:I3 ?E5I3 9!F I3 F %I3 !G::
H HH 3 L$J+*L$+
K 5K L$ K AL$ PollSelectorc n t 5 }| D ]"}| |t j #|t j |z } | | }|rd |D cddd S |*|t j z
}|dk r|cddd S \# 1 swxY w Y dS )r NTc " g | ] \ }}|j
S r )fileobj)r keyeventss r r zwait.<locals>.<listcomp> s CCCMS&CKCCCr r )
_WaitSelectorregister selectors
EVENT_READr r select)r r selectorrt deadliner s r r r s4 __ )"
=
=!!#y';<<<<" >++g5
) 00 )CCUCCC ) ) ) ) ) ) ) ) *"*T^-=-="="Q;;#( ) ) ) ) ) ) ) )
) ) ) ) ) ) ) ) ) ) )s A!B*= B*)B**B.1B.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 rG 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 c | j r t j nd| j r t j ndz }t j | | }t || j | j ffS r ) rG r FILE_GENERIC_READrH FILE_GENERIC_WRITEr DupHandlera rebuild_pipe_connection)r} r, dhs r reduce_pipe_connectionr s^ 04
D7,,115 E7--AG
7
7&T]DM(JJJr c L | }t ||| S r )r r )r rG rH rF s r r r s! fh999r c z t j | }t || j | j ffS r )r DupFdra r rG rH )r} dfs r r r s/
_T[[]]
+
+!B
t}#EEEr c L | }t ||| S r r )r rG rH fds r r r s!
YY[["h111r )NN)Tr )J__all__r r r( r1 r4 r r r% itertoolsr r$ r r r
contextr ForkingPicklerrq r r r
r r ImportErrorr2 r CONNECTION_TIMEOUTcountr+ r familiesr3 r r r/ r5 r= r? r r objectr r r r r r r rk rl ro rp r r rw r r r r r r ERROR_NETNAME_DELETEDr r r r r SelectSelectorr r r r r r r r <module>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 : : :z
* <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
Browse
Usage
Versions