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 )
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/ E sy 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 yyy)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 S sc ||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 )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}
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 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 : | j | j S )z+File descriptor or handle of the connection)rQ rB rM s r filenoz_ConnectionBase.fileno s ||r c f | j | j d| _ yy# d| _ w xY w)zClose the connectionNrK rM s r rW z_ConnectionBase.close s1 << #
$
# $ $ s ' 0c v | 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) z,Send the bytes data from a bytes-like objectr Br zoffset is negativezbuffer length < offsetNzsize 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)zSend a (picklable) objectN)rQ rU rh _ForkingPicklerdumpsrE objs r sendz_ConnectionBase.send s3 ..s34r c | j | j ||dk r t d | j | }|| j |j S )z7
Receive bytes data as a bytes object.
r znegative maxlength)rQ rS r, _recv_bytesrX getvalue)rE maxlengthri s r
recv_bytesz_ConnectionBase.recv_bytes sa
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 |cddd S # 1 sw Y yxY w)zq
Receive bytes data into a writeable bytes-like object.
Return the number of bytes read.
r znegative offsetzoffset too largeN) 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 )z Receive a (picklable) object)rQ rS rv rp loads getbuffer)rE ri s r recvz_ConnectionBase.recv s? $$S]]_55r c d | j | j | j | S )z/Whether there is any input available to be read)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 L e Zd ZdZdZej fdZd Zd dZ d Z
d Z y)
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.
Fc ( || j y r rZ )rE _CloseHandles r rL zPipeConnection._close s &r c t j | j |d \ }} |t j k( r1t j |j
gdt }|t k( sJ |j d \ }}|dk( sJ |t | k( sJ y # |j xY w# |j d \ }}w xY w)NT
overlappedFr ) _winapi WriteFilerB ERROR_IO_PENDINGWaitForMultipleObjectseventr r cancelGetOverlappedResultr{ )rE ri overrwaitresnwrittens r rh zPipeConnection._send_bytes s '' cdKGB
='222 % < <
E8 5G"m33
!# 6 6t <
#!8Os3x' ''
" 6 6t <
#s AB B**B- -CNc | j rd| _ t j S |dn t |d } t j
| j |d \ }} |t j k( r1t j |j gdt }|t k( sJ |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 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#*m#; ;
&(%;%;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\ %F8 AD" #A
F8 1$F8 "D55D8 8AF5 F8 'F52F8 4F55F8 8 G*$G%%G*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 }|dkD sJ |!t | |z |kD r| j t j | j |d \ }}|j d \ }}|dk( sJ ||k( sJ |j |j |S )Nr r 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!8O"s3x$'@((* &&t||TdKGB 006KFC!8OT> !
GGBLLN #Hr r ) r r r __doc__r r CloseHandlerL rh rv r r r r r r r s3
#&-&9&9 '
( Q@ /
r r c e Zd ZdZer(ej fdZej Z ej Z n'e j fdZe j Z e j Z e fdZe fdZd Zd
dZd Zy)
Connectionzo
Connection class based on an arbitrary file descriptor (Unix only), or
a socket handle (Windows).
c ( || 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 r _multiprocessing closesocketrL rt _writer _readr( rW r r r r rh rv r r r r r r [ so
0 < < !!&& %% " ! % % ). r r c P e Zd ZdZd
dZd Zd Zed Zed Z d Z
d Z y) 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.
Nc |xs |xr t | xs t }|xs t | }t | |dk( rt || | _ nt
||| | _ |t |t s t d || _
y )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 Y )'7 ;DN +GVW EDN z'5'A => >
r c | j t d | j 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.
zlistener is closed)r rP acceptr deliver_challengeanswer_challenge)rE cs r r zListener.accept sT >> !./ / NN ! ! # == a / Q
.r c P | j }|d| _ |j yy)zA
Close the bound socket or named pipe of `self`.
N)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 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 )z=
Returns a connection to the address of a `Listener`
r r ) r= r5
PipeClient SocketClientr r r r r )r< r. r r s r r r sq
,|G,FV
w !:gu#=9::G$!W% Hr c N | rot j \ }}|j d |j d t |j }t |j }||fS t 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 &&(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 dd t j$ |d }|j' d \ } }
|
dk( sJ 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 sg $I. 11H ))G,A,AAF $gFF 22H **F FF
$
$ X < << 1 12 % %(E(E E
vvw ; ; LL
VQ g.C.C ( (',, '' --tT --bTB
//53ax
B
0
B
02v
r c $ e Zd ZdZddZd Zd Zy)r zO
Representation of a socket which is bound to an address and listening
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)r4 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 )r4 rW r? )rE r> s r rW zSocketListener.closed s[ LL \\F! # " \\F! # "s : AN)r )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
cddd S # 1 sw Y yxY w)zO
Return a connection object connected to the socket given by `address`
TN)r= r4 r3 r
connectr r )r< r. rB s r r r n s^ '
"F / 1 &Q
d '!((*%& & &s ;A44A=c 6 e Zd ZdZddZddZd Zed Zy) r z0
Representation of a named pipe
Nc || _ | j d g| _ d | _ t j
d| j t j | t j | j | j fd | _ y )NT)firstz listener created with address=%rr r0 )
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 rH flagss r rI zPipeListener._new_handle s ..1M1MME>>>**
u))G,I,II!!"00'7,,gll
r c h | j j | j | j j d } t j
|d } t j |j gdt } |j d \ }}|dk( sJ t | S # |j t j | xY w# |j d \ }}|dk( sJ w xY w# t $ r2}|j t j k7 r Y d }~t | S d }~ww xY w)Nr Tr F)rJ appendrI 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 !8O!&) )IIK''/ 3 3D 9FAs !8O8
::!6!66 7 "&) )!
s0 C6 &B+ +(CC C36 D1? D,,D1c h t j d| | D ] }t j | y )Nz closing listener with address=%r)r rK r r )queuer< rF s r rL z$PipeListener._finalize_pipe_listener s. NN=w G
,##F+
,r r )F) r r r r rI rI r staticmethodrL r r r r r ~ s*
*.
,
,r r c . t } t j | d t j | t j t j
z dt j t j t j t j } t j |t j dd t! | S # t $ rB}|j t j t j fvs t | r Y d}~nd}~ww xY w )zU
Return a connection object connected to the pipe given by `address`
r N)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 D8D
D( s #CHALLENGE#s #WELCOME#s #FAILURE#> md5 sha256 sha384 sha3_256 sha3_384c # 2 K | ] }t | y wr )r{ ).0r, s r <genexpr>rf 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 | )
a Returns a digest name and the payload for a response hash.
If a legacy protocol is detected based on the message length
or contents the digest name returned will be empty to indicate
legacy mode where MD5 and no digest prefix should be sent.
r$ { }r r NasciizRunsupported message length, missing digest prefix, or unsupported digest: message=)r{ _LEGACY_LENGTHSr: find_MAX_DIGEST_LEN_ALLOWED_DIGESTSdecoder )ri curlydigestpayloads r _get_digest_name_and_payloadrx ? s 7|&
7{4 ,,tQ(9: :a?5! % % eAgh'G==)72 2
/&-Z
1 2 2r c ddl }t | d }|s" |j | |d j S |j | || j }d|j d |fz S # t $ r d}Y Dw xY w)a Create a MAC based on authkey and message
The MAC algorithm defaults to HMAC-MD5, unless MD5 is not available or
the message has a '{digest_name}' prefix. For legacy HMAC-MD5, the response
is the raw MAC, otherwise the response is prefixed with '{digest_name}',
e.g. b'{sha256}abcdefg...'
Note: The MAC protects the entire message including the digest_name prefix.
r Nmd5sha256 {%s}%sro )hmacrx newrv r, encode)r ri r} digest_nameresponses r _create_responser Y s .w7:K #88GWe4;;= = xx+6==?H **73X> >> # #K #s A. . A<;A<c
d ddl }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)
a` Verify MAC challenge
If our message did not include a digest_name prefix, the client is allowed
to select a stronger digest_name from _ALLOWED_DIGESTS.
In case our message is prefixed, a client cannot downgrade to a weaker
algorithm, because the MAC is calculated over the entire message
including the '{digest_name}' prefix.
r Nrz zresponse_digest=z unsupportedz expected z of length z got zdigest received was wrong)r} rx r~ rv r, r r{ compare_digest)r ri 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 B/r c t |t s#t dj t | t
t kD sJ d 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}zprotocol constraintr| ro )r r r, formatr7 MESSAGE_LENGTH_MD5ONLY_MESSAGE_LENGTHr( urandomr rn
_CHALLENGEry r _WELCOMEr _FAILURE)
connectionr r ri r s r r r s gu % . 5 5d7m DF F 3 3J5JJjj (G;--g6@@G *w./$$S)H('7H5
h' h'
s !
C C$c 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{ r r rn r )r r ri rv 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_loadsr3 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 rB s r rt zConnectionWrapper.send s" KK
a r c X | j j }| j | S r )r ry r rA 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 rt )rB 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 )r1 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 rQ )handlesr LreadyrT s r _exhaustive_waitr s
M00E7CCl" #>
A(>>}$!SD+;c!f+DD ##899 ''"#899 LL3 #a%& AG r c V |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 dd 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 )
Wait till an object in object_list is ready/readable.
Returns list of those objects in object_list which are ready/readable.
Nr rY g ?r` Trn ) rn Fr c 3 ( K | ] }| y wr r )re r] waithandle_to_objs r rf zwait.<locals>.<genexpr>A s Ia .q 1 Is )r intr setr3 r r rP r
_ready_errorsr rQ 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 sB ? 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 I4 H% G:AI4 H AI4 I L&
L& G? G:4I4 :G??I4 H" H I4 H""I4 % II4 II4 I1I,,I14 L#J'&L#' K 0K
L#
K L#&%L# L#
L# PollSelectorc t 5 }| D ]" }|j |t j $ |t j
|z } |j
| }|r(|D cg c] \ }}|j c}}cddd S |'t j
z
}|dk r |cddd S ec c}}w # 1 sw Y yxY w)r Nr )
_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$ AB8%B2;B8 B81B88Cc | 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 rB 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)r{ 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 frozensetrs maxrr r _MD5_DIGEST_LENrp r r9 rx 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