⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
usr
/
lib
/
python3.12
/
multiprocessing
/
__pycache__
/
View File Name :
connection.cpython-312.pyc
CRh g d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z ddl m Z mZ ddlmZ ej" Z ddlZddlmZmZmZmZ d Zd Z e j8 Z d Z d gZ e ed rd Z e d gz Z ej2 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+ej2 dk7 rdFd Z,ndFd Z, G d d e) Z-d Z.ej2 dk( r G d! d"e) Z/d# Z0d$Z1d%Z2d&Z3d'Z4 e5h d( Z6 e7d) e6D Z8d*Z9d+Z:e9e:fZ;d,e<d-e=e<ffd.Z>d/ Z?d0 Z@dGd1e<fd2ZAd1e<fd3ZB G d4 d5e) ZCd6 ZDd7 ZE G d8 d9e* ZFd: ZGej2 dk( r d; ZHej ej hZKdHd<ZLn*ddlMZM e eMd= r eMj ZOn eMj ZOdHd>ZLej2 dk( r3d? ZQd@ ZR ej e(eQ dA ZTdB ZU ej e'eT ydC ZQdD ZR ej e(eQ y# e$ r ej2 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 1/usr/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/ F 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 T 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__v 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 )Nhandle 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 rQ rM s r _check_readablez _ConnectionBase._check_readable s ~~45 5 r c 2 | j s t d y )Nzconnection is read-only)rD rQ 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 closerQ 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)rR 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 rX 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)rR rV 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)rR rV ri _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)rR rT r, _recv_bytesrY getvalue)rE maxlengthrj 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) rR rT re rf lenr, rw tellr rx seekreadinto)rE rj rk rm rf bytesizeresultrl 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)rR rT rw rq loads getbuffer)rE rj s r recvz_ConnectionBase.recv s? $$S]]_55r c d | j | j | j | S )z/Whether there is any input available to be read)rR rT _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 rX rE exc_type exc_valueexc_tbs r __exit__z_ConnectionBase.__exit__ r )TT)r Nr )r )g )__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 s G ".65, $ $ $2(5 26# r r? c P e Zd ZdZdZdZej fdZd Z d 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. FNc d | j }||j || j y r )_send_ovcancelrB )rE _CloseHandleovs r rL zPipeConnection._close s% B~ &r c > | j t d t j | j |d \ }}|| _ |t j k( r1t j |j gdt }|t k( sJ d | _ |j d \ }}|t j k( rt t j d |dk( sJ |t! | k( sJ y # |j xY w# d | _ |j d \ }}w xY w)Nz/concurrent send_bytes() calls are not supportedT overlappedFrP r )r r, _winapi WriteFilerB ERROR_IO_PENDINGWaitForMultipleObjectseventr r r GetOverlappedResultERROR_OPERATION_ABORTEDrQ errnoEPIPEr| )rE rj r errwaitresnwrittens r ri zPipeConnection._send_bytes s }}( "5 6 6 '' cdKGB DM ='222 % < < E8 5G"m333 !% " 6 6t < #g555 ekk+=>>!8O8s3x' '' $ " 6 6t < #s AC) )C<<C? ? D c | 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_datarQ winerrorERROR_BROKEN_PIPEEOFError RuntimeError) rE maxsizebsizer r r nreadfes r rw zPipeConnection._recv_bytes6 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._pollV 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| rY r r )rE r r rj r leftr rbytess r r z PipeConnection._get_more_data\ s ,,.C A GGCL(( 6q9D!8O8"s3x$'@((* &&t||TdKGB 006KFC!8O8T> !> GGBLLN #Hr r ) r r r __doc__r r r CloseHandlerL ri rw r r r r r r r s8 #&-&9&9 ' (4 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 r[ rE rL s r rL zConnection._closes 4<< r c ( || j y r r[ r s r rL zConnection._closex r r c b t | } || j | }||z }|dk( ry ||d }$Nr )r| rB )rE rj r remainingrn s r _sendzConnection._send} 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 rQ r )rE rl readrj rF r chunkrn s r _recvzConnection._recv 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 rj rn pre_headerheaders r ri 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 unpackrx )rE r rj rl s r rw 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 ru _writer _readr( rX r r r r ri rw r r r r r r l 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 ,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 rQ acceptr deliver_challengeanswer_challenge)rE cs r r zListener.accept sW >> !./ / NN ! ! # == $ a / Q .r c P | j }|d| _ |j yy)zA Close the bound socket or named pipe of `self`. N)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 $ | j y 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 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 ( si $I. 11H ))G,A,AAF $gFF 22H **F FF $ $ X < << 1 12 % %(E(E E vvw ; ; LL VQ g.C.C ( (',, '' --tT --bTB //53axx 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 rQ rX _familyr r r; Finalizeunlink_unlink)rE r< r. r s r rI zSocketListener.__init__X 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)r9 r r r r r rE ss r r zSocketListener.acceptq s9 !% !4!4!6 4 d!((*%%r c | j j | j }|d | _ | y y # | j }|d | _ | w w xY wr )r9 rX rD )rE rC s r rX zSocketListener.closev s[ LL \\F! # " \\F! # "s : AN)r )r r r r rI r rX r r r r r T 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 r8 r connectr r )r< r. rG s r r r sU ' "F / 1Q d '!((*% 2 1 1s ;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 r5 ) r _new_handle _handle_queuer r sub_debugrB r _finalize_pipe_listenerrX )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 rM flagss r rN 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)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 s % %d&6&6&8 9''++A.F $ --fF $!88 E85C 3 3D 9FAs !8O8!&) )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 rP r r )queuer< rF s r rQ z$PipeListener._finalize_pipe_listener s) NN=w G ##F+ r r )F) r r r r rI rN r staticmethodrQ 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 rQ 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| ).0r1 s r <genexpr>rk F s 7&6c!f&6s 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 )rn curlydigestpayloads r _get_digest_name_and_payloadr} Q 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}%srt )hmacr} newr{ r, encode)r rn r digest_nameresponses r _create_responser k 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 Nr zresponse_digest=z unsupportedz expected z of length z got zdigest received was wrong)r r} r r{ r, r r| compare_digest)r rn r r response_digest response_macexpecteds r _verify_challenger 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 rt )r r r, formatr7 MESSAGE_LENGTH_MD5ONLY_MESSAGE_LENGTHr( urandomr ro _CHALLENGErz r _WELCOMEr _FAILURE) connectionr r rn r s r r r s gu % . 5 5d7m DF F 3 3J5JJ 3jj (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 rz r: r r r| r r ro r )r r rn r{ 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)ra rX r rz ro )_conn_dumps_loadsr8 setattr)rE connrr r attrrt s r rI zConnectionWrapper.__init__ s: KD$%C D$ $ Lr c \ | j | }| j j | y r )r r ro )rE rt rG s r ru zConnectionWrapper.send s" KK a r c X | j j }| j | S r )r rz r rF s r r zConnectionWrapper.recv s" JJ ! ! #{{1~ r N)r r r rI ru r r r r r r s %! r r c T t j | fd d d d j d S )Nr utf-8) xmlrpclibrr r )rt s r _xml_dumpsr s& ??C64tQ 7 > >w GGr c X t j | j d \ \ }}|S )Nr )r r ry )rG rt 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 rs 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 )r6 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 rV )handlesr LreadyrY 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 r^ g ?ra Trs ) rs Fr c 3 ( K | ] }| y wr r )rj rb waithandle_to_objs r rk zwait.<locals>.<genexpr>S s I=a .q 1=s )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_objects ready_handlesora r r r r1 r s @r r r s- ? 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 3 3D 9FAs '999)"((3A!%%a(ax #1&:;37A 0 I= II&=;a!}*<;==_ # ""& C m3 ! 4" $+ 1&'jj 1- & 978%akkm49N **C-/ 0 3 3D 9FAs **C-/ 0 '999)"((3A!%%a(ax #1&:;37A 0 " >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 selectorrt deadliner keyeventss r r r b s _"!!#y';';< # " >>+g5 0=BCUMS&CKKUC _ *"*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) ra r4 fromfdr SOCK_STREAMr$ r DupSocketrebuild_connectionrG rH )r rF rG r dss r reduce_connectionr ~ s` ]]66>>63E3E F! ) **1-B%DMM4=='II G F Fs 6BB c X | j }t |j || S r r r )r rG rH socks 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 DupHandlera rebuild_pipe_connection)r r, dhs r reduce_pipe_connectionr 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 DupFdra 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 )V__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 r r r r frozensetrx maxrw r _MD5_DIGEST_LENru r r9 r} 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 Mh;v ;| * <<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#45s# ||w Gs H? ?II