python (3.12.0)
̑e g d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl
m Z ddl
m Z m
Z
ddlmZ ej Z ddlZddlmZmZmZmZ d Zd
Z ej6 Z d Z d gZ e ed rd Z e d gz
Z ej0 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)dEdZ*ej0 dk7 rdFd Z+ndFd Z+ G d d e( Z,d Z-ej0 dk( r G d! d"e( Z.d# Z/d$Z0d%Z1d&Z2d'Z3 e4h d( Z5 e6d) e5D Z7d*Z8d+Z9e8e9fZ:d,e;d-e<e;ffd.Z=d/ Z>d0 Z?dGd1e;fd2Z@d1e;fd3ZA G d4 d5e( ZBd6 ZCd7 ZD G d8 d9e) ZEd: ZFej0 dk( r d; ZGej ej hZJdHd<ZKn*ddlLZL e eLd= r
eLj ZNn eLj ZNdHd>ZKej0 dk( r3d? ZPd@ ZQ ej e'eP dA ZSdB ZT ej e&eS ydC ZPdD ZQ ej e'eP y# e$ r ej0 dk( r dZY w xY w)I)ClientListenerPipewait N )util)AuthenticationErrorBufferTooShort) reduction)
WAIT_OBJECT_0WAIT_ABANDONED_0 WAIT_TIMEOUTINFINITEwin32i g 4@AF_INETAF_UNIXAF_PIPEc 0 t j | z S Ntime monotonic)timeouts N/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/multiprocessing/connection.py
_init_timeoutr ; s >> g %% c 0 t j | kD S r r )ts r _check_timeoutr > s >> a r c | dk( ry| 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/ E s~ 9 kt7H7H7JKK 9 &< " T--@ A'BGIK K .//r c t j dk7 r| dk( rt d| z t j dk( r%| dk( r t t | st d| z y y y )Nr r z Family %s is not recognized.r )sysplatformr, hasattrsocketr- s r _validate_familyr5 S sh ||w 6Y#67&@AA
||w 6Y#6vv& ;f DE E ' $7 r c t | t k( ryt | t u r| j d ryt | t u st j
| ryt
d| z )Nr z\\r r z address type of %r unrecognized)typetuplestr
startswithr is_abstract_socket_namespacer, )addresss r address_typer= _ sa
G}
g # '"4"4V"<
g # !B!B7!K:WDEEr c e Zd ZdZddZd Zd Zd Zd Zd Z e
d Z e
d Z e
d
Z
d Zd Zdd
Zd ZddZddZd ZddZd Zd Zy)_ConnectionBaseNc |j }|dk r t d |s
|s t d || _ || _ || _ y )Nr zinvalid handlez6at least one of `readable` and `writable` must be True) __index__r, _handle _readable _writable)selfhandlereadablewritables r __init__z_ConnectionBase.__init__u sO !!# A: -. . HJ
J !!r c > | j | j y y r rB _closerE s r __del__z_ConnectionBase.__del__ s << # KKM $r c 2 | j t d y )Nzhandle is closed)rB OSErrorrM s r
_check_closedz _ConnectionBase._check_closed s << ,- - r c 2 | j s t d y )Nzconnection is write-only)rC rP rM s r _check_readablez _ConnectionBase._check_readable s ~~45 5 r c 2 | j s t d y )Nzconnection is read-only)rD rP rM s r _check_writablez _ConnectionBase._check_writable s ~~34 4 r c t | j rd| _ t d | j t d )NFzbad message length)rD rC closerP rM s r _bad_message_lengthz#_ConnectionBase._bad_message_length s5 >> "DN *++
JJL*++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 | j S r )rQ rB rM s r filenoz_ConnectionBase.fileno s 9 ||r c h | j | j d | _ y y # d | _ w xY wr rK rM s r rW z_ConnectionBase.close s4 " << #
$
# $ $ s ( 1c x | j | j t | }|j dkD r|j d }|j
}|dk r t
d ||k r t
d |||z
}n#|dk r t
d ||z |kD r t
d | j ||||z y )Nr Br zoffset is negativezbuffer length < offsetzsize is negativez buffer length < offset + size)rQ rU
memoryviewitemsizecastnbytesr, _send_bytes)rE bufoffsetsizemns r
send_bytesz_ConnectionBase.send_bytes s : sO ::>s A
HH A: 12 2 v: 56 6 <v:D
AX /0 0
d]Q
<= = 6&4-01r c | j | j | j t j | y r )rQ rU rh _ForkingPicklerdumpsrE objs r sendz_ConnectionBase.send s6 ' ..s34r c | j | j ||dk r t d | j | }|| j |j S )Nr znegative maxlength)rQ rS r, _recv_bytesrX getvalue)rE maxlengthri s r
recv_bytesz_ConnectionBase.recv_bytes sf
Y] 12 2 y) ; $ $ &||~ r c | j | j t | 5 }|j }|t | z }|dk r t d ||kD r t d | j
}|j }|||z k rt |j |j d |j |||z ||z |z |cd d d S # 1 sw Y y xY w)Nr znegative offsetzoffset too large) rQ rS rd re lenr, rv tellr
rw seekreadinto)rE ri rj rl re bytesizeresultrk s r recv_bytes_intoz _ConnectionBase.recv_bytes_into s
_ zzH #a&(Hz !233(" !344%%'F;;=D&4-'$V__%677 KKN OOAf 0 %} 9 ;
<! s B+C""C+c | j | j | j }t j |j S r )rQ rS rv rp loads getbuffer)rE ri s r recvz_ConnectionBase.recv sB * $$S]]_55r c f | j | j | j | S r )rQ rS _pollrE r s r pollz_ConnectionBase.poll s, = zz'""r c | S r rM s r __enter__z_ConnectionBase.__enter__ r c $ | j y r rW rE exc_type exc_valueexc_tbs r __exit__z_ConnectionBase.__exit__
r )TT)r Nr )r )g )__name__
__module__ __qualname__rB rI rN rQ rS rU rX propertyr[ rG rH r` rW rn rt ry r r r r r r r r r? r? r s G ".65, $ $
$2(5 26# r r? c J e Zd Z dZej
fdZd ZddZd Z d Z
y) PipeConnectionFc ( || j y r rZ )rE _CloseHandles r rL zPipeConnection._close s &r c H t j | j |d \ }} |t j k( r&t j |j
gdt }|j d \ }}y # |j xY w# |j d \ }}w xY w)NT
overlappedF) _winapi WriteFilerB ERROR_IO_PENDINGWaitForMultipleObjectseventr cancelGetOverlappedResult)rE ri overrwaitresnwrittens r rh zPipeConnection._send_bytes s '' cdKGB
='222 % < <
E8 5G !# 6 6t <
#
" 6 6t <
#s 9A5 5BB B!Nc | j rd| _ t j S |dn t |d } t j
| j |d \ }} |t j k( r&t j |j gdt }|j d \ }}|dk( r5t j }|j |j |S |t j k( r| j! || S t+ d # |j xY w# |j d \ }}|dk( r9t j }|j |j |c cY S |t j k( r| j! || c cY S w xY w# t" $ r)}|j$ t j& k( rt( d }~ww xY w)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_datarP winerrorERROR_BROKEN_PIPEEOFError RuntimeError) rE maxsizebsizer r r nreadfes r rv zPipeConnection._recv_bytes% s &&*/'zz|# &C4E % . .t||U;? AGBD '":"::&-&D&D!#
E8'=G &(%;%;D%A
s !8 "
A GGBLLN 3#$H G$;$; ;#'#6#6r7#C C < OP P! %'%;%;D%A
s !8 "
A GGBLLN 3#$H G$;$; ;#'#6#6r7#C C < zzW%>%>> & s[ %F- 9D A
F- &$F- D**D- -AF*>F- 'F*'F- )F**F- - G 6$GG c | j s%t j | j d dk7 ryt t | g| S )Nr T)r r
PeekNamedPiperB boolr r s r r zPipeConnection._pollE s> '' --dll;A>!CdVW-. .r c |j }t j }|j | t j
| j d }|!t | |z |kD r| j t j | j |d \ }}|j d \ }}|j |j |S )Nr Tr ) r r r r r r rB r{ rX r r )rE r r ri r leftr rbytess r r z PipeConnection._get_more_dataK s ,,.C
A
GGCL(( 6q9D"s3x$'@((* &&t||TdKGB 006KFC
GGBLLN #Hr r ) r r r r r CloseHandlerL rh rv r r r r r r r s3
#&-&9&9 '
( Q@ /
r r c e Zd Z er(ej
fdZej Zej Z
n'e j fdZe j Ze j Z
efdZe
fdZd Zd dZd Zy)
Connectionc ( || j y r rZ rE rL s r rL zConnection._closeb 4<< r c ( || j y r rZ r s r rL zConnection._closeg r r c b t | } || j | }||z }|dk( ry ||d }$Nr )r{ rB )rE ri r remainingrm s r _sendzConnection._sendl sA H dllC(A NIA~ab'C r c t j }| j }|}|dkD rK ||| }t | }|dk( r||k( rt t d |j
| ||z }|dkD rK|S )Nr z got end of file during message)r r rB r{ r rP r )rE rk readri rF r chunkrm s r _recvzConnection._recvu s| jjl !m+EE
AAv $"N!"BCC IIe NI !m
r c t | }|dkD r`t j dd }t j d| }| j | | j | | j | y t j d| }|dkD r#| j | | j | y | j ||z y )Ni!i!Qi @ )r{ structpackr )rE ri rm
pre_headerheaders r rh zConnection._send_bytes s H z> T2.J[[q)F JJz " JJv JJsO [[q)F5y
6"
3
6C<(r Nc | j d }t j d|j \ }|dk( r7| j d }t j d|j \ }|||kD ry | j | S )N r r r )r r unpackrw )rE r ri rk s r rv zConnection._recv_bytes sq jjm
dCLLN3 2:**Q-CMM$ 7ED 4'>zz$ r c 2 t | g| }t | S r )r r )rE r rs r r zConnection._poll s $ !Awr r )r r r r _multiprocessing closesocketrL rt _writer _readr( rW r r r r rh rv r r r r r r [ so
0 < < !!&& %% " ! % % ). r r c N e Zd Z d dZd Zd Zed Zed Zd Z d Z
y)
r Nc |xs |xr t | xs t }|xs t | }t | |dk( rt || | _ nt
||| | _ |t |t s t d || _
y 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 Y )'7 ;DN +GVW EDN z'5'A => >
r c | j t d | j j }| j r,t || j t || j |S )Nzlistener is closed)r rP acceptr deliver_challengeanswer_challenge)rE cs r r zListener.accept sY
>> !./ / NN ! ! # == a / Q
.r c R | j }|d | _ |j y y r )r rW )rE listeners r rW 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 $ | j y r r r s r r zListener.__exit__ r r )NNr N) r r r rI r rW r r< r r r r r r r r sH ' ' - -r r c |xs t | }t | |dk( r t | }n t | }|t |t
s t
d |t || t || |S r ) r= r5
PipeClient SocketClientr r r r r )r< r. r r s r r r sv
,|G,FV
w !:gu#=9::G$!W% Hr c P | rot j \ }}|j d |j d t |j }t |j }||fS t j \ }}t |d }t |d }||fS )NTFrH rG )r4
socketpair setblockingr detachr( pipe)duplexs1s2c1c2fd1fd2s r r r s &&(FB NN4 NN4 BIIK(BBIIK(B 2v
wwyHCC%0BC%0B2v
r c
t d }| r>t 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 }|j' 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 se $I. 11H ))G,A,AAF $gFF 22H **F FF
$
$ X < << 1 12 % %(E(E E
vvw ; ; LL
VQ g.C.C ( (',, '' --tT --bTB
//53 B
0
B
02v
r c " e Zd Z ddZd Zd Zy)r c t j t t | | _ t j dk( r9| j j t j t j d | j j d | j j | | j j | | j j | _ || _ d | _ |dk( rCt# j$ | s.t# j& | t j( |fd | _ y d | _ y # t $ r | j j w xY w)Nposixr Tr r args exitpriority)r4 getattr_socketr( name
setsockopt
SOL_SOCKET SO_REUSEADDRr bindlisten getsocknamer rP rW _familyr r r; Finalizeunlink_unlink)rE r< r. r s r rI zSocketListener.__init__F s }}WVV%<= ww'! ''(9(9(.(;(;Q@ LL $ $T * LL g & LL ( LL 4 4 6DM " Y t'H'H'Q ==biiwjq DL DL LL s B<E %E)c | j j \ }| _ |j d t |j S NT)r2 r r r r r rE ss r r zSocketListener.accept_ s9 !% !4!4!6 4
d!((*%%r c | j j | j }|d | _ | y y # | j }|d | _ | w w xY wr )r2 rW r= )rE r< s r rW zSocketListener.closed s[ LL \\F! # " \\F! # "s : AN)r )r r r rI r rW r r r r r B s 2&
r r c t | }t j t t | 5 }|j d |j | t |j
cd d d S # 1 sw Y y xY wr? )r= r4 r1 r connectr r )r< r. rA s r r r n sc '
"F / 1 &Q
d '!((*%& & &s ;A55A>c 4 e Zd Z ddZddZd Zed Zy)r Nc || _ | j d g| _ d | _ t j
d| j t j | t j | j | j fd | _ y )NT)firstz listener created with address=%rr r. )
r _new_handle
_handle_queuer r sub_debugr; r _finalize_pipe_listenerrW )rE r< r s r rI zPipeListener.__init__ sl #DM"&"2"2"2">!?D "&D NN=t}} M l::(($--8qDJr c
~ 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 rG flagss r rH zPipeListener._new_handle s ..1M1MME>>>**
u))G,I,II!!"00'7,,gll
r c L | j j | j | j j d } t j
|d } t j |j gdt } |j d \ }}t | S # |j t j | xY w# |j d \ }}w xY w# t $ r2}|j t j k7 r Y d }~t | S d }~ww xY w)Nr Tr F)rI appendrH popr r# r r r r r r rP r
ERROR_NO_DATAr )rE rF r resr* r r s r r zPipeListener.accept s % %d&6&6&8 9''++A.F
$ --fF $!88
E85C 3 3D 9FAs!&) )IIK''/ 3 3D 9FAs
::!6!66 7 "&) )!
s0 C( &B$ $(C C C%( D#1 D D#c h t j d| | D ] }t j | y )Nz closing listener with address=%r)r rJ r r )queuer< rF s r rK z$PipeListener._finalize_pipe_listener s. NN=w G
,##F+
,r r )F)r r r rI rH r staticmethodrK r r r r r ~ s*
*.
,
,r r c 0 t } t j | d t j | t j t j
z dt j t j t j t j } t j |t j d d t! | S # t $ rB}|j t j t j fvs t | r Y d }~nd }~ww xY w )N r )r r
WaitNamedPiper r r r r! r rP r ERROR_SEM_TIMEOUTERROR_PIPE_BUSYr r" r r )r< r hr s r r r s
O
%%gt4&&W 1 1G4I4I Iw||W%:%:00',, ''
w,,dD a
::g&?&?&-&=&=&? ?BPQRBS CT
s BC D8DD( s #CHALLENGE#s #WELCOME#s #FAILURE#> md5 sha256 sha384 sha3_256 sha3_384c # 2 K | ] }t | y wr )r{ ).0r* s r <genexpr>re 4 s 7c!f7s messagereturnc t | t v rd| fS | j d rG| j ddt dz x}dkD r(| d| }|t
v r| |dz d }|j
d |fS t d| ) Nr$ { }r r asciizRunsupported message length, missing digest prefix, or unsupported digest: message=)r{ _LEGACY_LENGTHSr: find_MAX_DIGEST_LEN_ALLOWED_DIGESTSdecoder )rh curlydigestpayloads r _get_digest_name_and_payloadrw ? s 7|&
7{4 ,,tQ(9: :a?5! % % eAgh'G==)72 2
/&-Z
1 2 2r c dd l }t | d }|s" |j | |d j S |j | || j }d|j d |fz S # t $ r d}Y Dw xY w)Nr md5sha256 {%s}%srn )hmacrw newru r, encode)r rh r| digest_nameresponses r _create_responser Y s .w7:K #88GWe4;;= = xx+6==?H **73X> >> # #K #s A/ / A=<A=c
f dd l }t | \ }}|xs d} |j | || j }t
| t
| k7 r&t d|dt
| dt
| |j || s t d y # t $ r t d|d w xY w) Nr ry zresponse_digest=z unsupportedz expected z of length z got zdigest received was wrong)r| rw r} ru r, r r{ compare_digest)r rh r r| response_digest response_macexpecteds r _verify_challenger u s $@$J!O\%.OE88GWo>EEG 8}L))!O.k#h- I<()+, , x 6!"=>> 7
E!%5_$6l"CDDEs !B B0r c t |t s#t dj t | t j t }d|j d |fz }| j t |z | j d } t ||| | j t y # t $ r | j t w xY w)N Authkey must be bytes, not {0!s}r{ rn )r r r, formatr7 r( urandomMESSAGE_LENGTHr~ rn
_CHALLENGEry r _WELCOMEr _FAILURE)
connectionr r rh r s r r r s gu % . 5 5d7m DF F jj (G;--g6@@G *w./$$S)H('7H5
h' h'
s
B0 0 Cc t |t s#t dj t | | j d }|j
t st d| |t t d }t | t k r t d t || }| j | | j d }|t k7 r t d y )Nr r z,Protocol error, expected challenge: message=z)challenge too short: {len(message)} byteszdigest sent was rejected)r r r, r r7 ry r: r r r{ _MD5ONLY_MESSAGE_LENGTHr rn r )r r rh ru r s r r r s gu % . 5 5d7m DF F##C(G j )!?wjAC Cc*o&'G
7|--!"MNN
gw
/F&!$$S)H8!"<== r c e Zd Zd Zd Zd Zy)ConnectionWrapperc n || _ || _ || _ dD ] }t || }t | || y )N)r` rW r ry rn )_conn_dumps_loadsr1 setattr)rE connrq r attrrs s r rI zConnectionWrapper.__init__ s>
K %D$%C D$ $ %r c \ | j | }| j j | y r )r r rn )rE rs rA s r rt zConnectionWrapper.send s" KK
a r c X | j j }| j | S r )r ry r r@ s r r zConnectionWrapper.recv s" JJ ! ! #{{1~ r N)r r r rI rt r r r r r r s %! r r c T t j | fd d d d j d S )Nr utf-8) xmlrpclibrq r~ )rs s r
_xml_dumpsr s& ??C64tQ 7 > >w GGr c X t j | j d \ \ }}|S )Nr )r r rs )rA rs methods r
_xml_loadsr s$ __QXXg%67NFSF Jr c e Zd Zd Zy) XmlListenerc b dd l ma t j | }t |t t S r )
xmlrpc.clientclientr r r r r r rr s r r zXmlListener.accept s" )ood# j*==r N)r r r r r r r r r s >r r c J dd l ma t t | i |t
t S r )r r r r r r r )r/ kwdss r XmlClientr s % VT 2T 2J
KKr c t | }g }|rt j |d| }|t k( r |S t |cxk rt t | z k r
n n
|t z }nAt |cxk rt t | z k rn t d |t z }n t d |j || ||dz d }d}|r|S )NFzShould not get herer r ) listr r r r r{ r
r rP )handlesr LreadyrS s r _exhaustive_waitr s
M00E7CCl" #>
A(>>}$!SD+;c!f+DD ##899 ''"#899 LL3 #a%& AG r c X |t }n|dk rd}nt |dz dz }t | } i g }t }t } | D ] } t |d } t j | dd \ }}|t
j k( r!|j | | |j < d|rDt j d d dk\ r* |j d \ }
}|st! |d rd|_ |j% | d} t+ j- | }|D ] }|j/ |D ]e } |j d \ }
}|t
j0 k7 s, |j }|j% | |dk( sRt! |d s_d|_ g |j3 fd
|D | D cg c] }||v s| c}S # t $ r"} d | j }}|t vr Y d } ~ d } ~ ww xY w# t $ r} | j }Y d } ~ >d } ~ ww xY w# t& $ r | |j) < Y w xY w# t $ r } | j }|t vr Y d } ~ d } ~ ww xY w# |D ] }|j/ |D ] } |j d \ }
}n+# t $ r } | j }|t vr Y d } ~ nd } ~ ww xY w|t
j0 k7 sX |j }|j% | |dk( s~t! |d sd|_ w xY wc c}w ) Nr rX g ?r` Trm ) rm Fr c 3 ( K | ] }| y wr r )rd r\ waithandle_to_objs r re zwait.<locals>.<genexpr>A s Ia .q 1 Is )r intr setr1 r r rP r
_ready_errorsr rP r r1 getwindowsversionr r3 r addAttributeErrorrA r keysr ERROR_OPERATION_ABORTEDupdate) object_listr ov_list
ready_objects
ready_handlesor` r r r r* r s @r r r sG
? G
q[G'D.3./G;'
6 8
$ $ $Q 1F
"")"2"268Q"EC
g 6 66 r*67)"((3
#"7"7"9"1"="G 1)+)?)?)F3 $'716J+K7; 4%))!,"#=
$@ -->-C-C-Ew OM
8 3 3D 9FAs
'999)"((3A!%%a(ax #1&:;37A 0
8 I= II&=a!}*<==_ # ""&
C m3 ! 4" $+ 1&'jj 1- & 978%akkm49N **C-/ 0
8 3 3D 9FAs **C-/ 0 '999)"((3A!%%a(ax #1&:;37A 0
8" >s I5 H& G;AI5 H AI5 I L'L' H G;5I5 ;H I5 H# H I5 H##I5 & II5 II5 I2I--I25 L$J('L$( K 1K L$ K L$'%L$
L$
L$ PollSelectorc t 5 }| D ]" }|j |t j $ |t j
|z } |j
| }|r(|D cg c] \ }}|j c}}cd d d S |'t j
z
}|dk r |cd d d S ec c}}w # 1 sw Y y xY wr )
_WaitSelectorregister selectors
EVENT_READr r selectfileobj)r r selectorrs deadliner keyeventss r r r P s
_ )"
=!!#y';';<
= " >>+g5 0=BCMS&CKKC ) ) *"*T^^-="="Q;#( ) ) D ) )s$ AB9&B3<B9 B92B99Cc | j }t j |t j t j 5 }ddlm} |j | }t || j | j ffcd d d S # 1 sw Y y xY w)Nr )resource_sharer) r` r4 fromfdr SOCK_STREAMr$ r DupSocketrebuild_connectionrG rH )r rF rA r dss r reduce_connectionr l sl
]]66>>63E3E
F J! ) **1-B%DMM4=='II J J Js 6BB
c X | j }t |j || S r r r )r rG rH socks r r r r s" yy{$++-8<<r c | j rt j nd| j rt j ndz }t j | j | }t || j | j ffS r ) rG r FILE_GENERIC_READrH FILE_GENERIC_WRITEr DupHandler` rebuild_pipe_connection)r r% dhs r reduce_pipe_connectionr w s^ 04
7,,115 7--AG
7&T]]DMM(JJJr c < | j }t ||| S r )r r )r rG rH rF s r r r | s fh99r c t j | j }t || j | j
ffS r )r DupFdr` r rG rH )r dfs r r r s0
__T[[]
+!B
t}}#EEEr c < | j }t ||| S r r )r rG rH fds r r r s
YY["h11r )NN)T)rz r )U__all__r r( r1 r4 r r r% itertoolsr r$ r r r
contextr ForkingPicklerrp 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 r r r r frozensetrr maxrq r _MD5_DIGEST_LENro r r9 rw r r r r r 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
1 **OO !
;
69 N H<<7 N H - & 0
F
F&T Tn M M`M Mh:v :z
* <<7&&X)V )X& <<76,v 6,p!>
r @B 7&677 *O<2% 2S%L 24?8?2(5 (*>% >*
H>( >L <<7( ..0M0MNML>`
y.)!..
!00
)6 <<7J = Iz#45K
: I~'=>F2 Iz#45Q#
||w
Gs
H; ;II
Browse
Usage
Versions