h,SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK J r SSK J r SSK J r J r SSKJr SSKJrJr SSKJr SS K Jr SS KJr \R.S :Xa0\R0r\R2r\R4r\R6r/S Qr\"\S 5rSr Sr!\RD"5r#Sr$S/r%\"\S5(aSr$\%S/- r%\R.S :XaSr$\%S/- r%\!4Sjr&Sr'Sr(Sr)Sr*"SS5r+"SS5r,\(a "SS\,5r-"SS\,5r."S S!5r/SES"jr0S#r1\R.S :waSFS$jr2OSFS%jr2"S&S'5r3S(r4\R.S :Xa&"S)S*5r5\Rl\Rn44S+jr8S,r9S-r:S.r;S/r"S2S35r?S4r@S5rA"S6S7\/5rBS8rC\R.S :Xa!S9rD\R\R1rGSGS:jrHO\"\S;5(aS<rIOS=rISGS>jrH\R.S :Xa3S?rJS@rK\ R"\.\J5 SArMSBrN\ R"\-\M5 gSCrJSDrK\ R"\.\J5 g!\a \R.S :XaeSrGNf=f)HN) reduction)util)AuthenticationErrorBufferTooShort) _billiard) setblocking send_offset monotonic)ForkingPickler)_winapiwin32)ClientListenerPipewaitpypy_version_infoi g4@AF_INETAF_UNIXAF_PIPEc[5U-$Nr )timeouts ;D:\TimeStamps\venv\Lib\site-packages\billiard/connection.py _init_timeoutrEs ;  c[5U:$rr )ts r_check_timeoutr Is ;?rcUS:XagUS:Xa([R"S[R"5S9$US:Xa:[R"S[R "5[ [54-SS9$[S 5e) z7 Return an arbitrary free address for the given family r) localhostrrz listener-)prefixdirrz\\.\pipe\pyc-%d-%d-zunrecognized family) tempfilemktempr get_temp_dirosgetpidnext _mmap_counter ValueErrorfamilys rarbitrary_addressr0Qsy 9 kt7H7H7JKK 9 &< " T--@A'BGIK K.//rc[RS:waUS:Xa[SU-5e[RS:Xa+US:Xa$[[U5(d[SU-5eggg)z< Checks if the family is valid for the current environment. rrzFamily %s is not recognized.rN)sysplatformr-hasattrsocketr.s r_validate_familyr6`sf ||w6Y#67&@AA ||w6Y#6vv&&;fDE E'$7rc[U5[:Xag[U5[LaURS5(ag[U5[Lag[ SU-5e)zQ Return the types of the address This can be 'AF_INET', 'AF_UNIX', or 'AF_PIPE' rz\\rrzaddress type of %r unrecognized)typetuplestr startswithr-)addresss r address_typer=msR  G} g# '"4"4V"<"< g# :WDEErc\rSrSrSrSrg)_SocketContainercXlgrsock)selfrCs r__init___SocketContainer.__init__s rrBN)__name__ __module__ __qualname____firstlineno__rE__static_attributes__rrr?r?srr?c\rSrSrSrSSjrSrSrSrSr Sr \ S 5r \ S 5r \ S 5rS rS rSSjrSrSSjrSSjrSrSSjrSrSrSrSrSrg)_ConnectionBaseNc[U[5(a+URUlURR 5nUR 5nUS:a [ S5eU(dU(d [ S5eXlX lX0l g)Nrzinvalid handlez6at least one of `readable` and `writable` must be True) isinstancer?rC_socketfileno __index__r-_handle _readable _writable)rDhandlereadablewritables rrE_ConnectionBase.__init__st f. / /!;;DL[['')F!!# A:-. .HJ J !!rc@URbUR5 ggrrU_closerDs r__del___ConnectionBase.__del__s << # KKM $rc4URc [S5eg)Nzhandle is closed)rUOSErrorr_s r _check_closed_ConnectionBase._check_closeds << ,- - rc<UR(d [S5eg)Nzconnection is write-only)rVrcr_s r_check_readable_ConnectionBase._check_readables~~45 5rc<UR(d [S5eg)Nzconnection is read-only)rWrcr_s r_check_writable_ConnectionBase._check_writables~~34 4rcjUR(aSUlOUR5 [S5e)NFzbad message length)rWrVclosercr_s r_bad_message_length#_ConnectionBase._bad_message_lengths% >>"DN JJL*++rcURSL$)z True if the connection is closedNrUr_s rclosed_ConnectionBase.closeds||t##rcUR$)z"True if the connection is readable)rVr_s rrY_ConnectionBase.readable~~rcUR$)z"True if the connection is writable)rWr_s rrZ_ConnectionBase.writablervrc:UR5 UR$)z+File descriptor or handle of the connection)rdrUr_s rrS_ConnectionBase.filenos ||rchURbUR5 SUlgg!SUlf=f)zClose the connectionNr]r_s rrm_ConnectionBase.closes1 << # $ # $ $ s( 1c|UR5 UR5 [U5nURS:a[[ U55n[ U5nUS:a [ S5eXR:a [ S5eUcXR- nO$US:a [ S5eX#-U:a [ S5eURXBX#-5 g)z,Send the bytes data from a bytes-like objectrrzoffset is negativezbuffer length < offsetNzsize is negativezbuffer length < offset + size)rdrj memoryviewitemsizebyteslenr- _send_bytes)rDbufoffsetsizemns r send_bytes_ConnectionBase.send_bytess   sO ::>58$A F A:12 2 :56 6 <:D AX/0 0 ]Q <= = &-01rcUR5 UR5 UR[R"U55 g)zSend a (picklable) objectN)rdrjrr dumpsrDobjs rsend_ConnectionBase.sends3   --c23rcUR5 UR5 UbUS:a [S5eURU5nUcUR 5 UR 5$)z' Receive bytes data as a bytes object. rznegative maxlength)rdrgr- _recv_bytesrngetvalue)rD maxlengthrs r recv_bytes_ConnectionBase.recv_bytessa    Y]12 2y) ;  $ $ &||~rcUR5 UR5 [U5nURnU[ U5-nUS:a [ S5eX%:a [ S5eUR 5nUR5nXRU-:a[UR55eURS5 URUX$-X'-U-5 UsSSS5 $!,(df  g=f)zY Receive bytes data into a writeable bytes-like object. Return the number of bytes read. rznegative offsetzoffset too largeN) rdrgr~rrr-rtellrrseekreadinto)rDrrrrbytesizeresultrs rrecv_bytes_into_ConnectionBase.recv_bytes_intos   _zzH#a&(Hz !233" !344%%'F;;=D4-'$V__%677 KKN OOA"FMh#> #__s B*C  C.cUR5 UR5 UR5n[R"U5$)zReceive a (picklable) object)rdrgrr loadbuf)rDrs rrecv_ConnectionBase.recvs9   %%c**rcdUR5 UR5 URU5$)z/Whether there is any input available to be read)rdrg_pollrDrs rpoll_ConnectionBase.polls)  zz'""rcU$rrLr_s r __enter___ConnectionBase.__enter__ rc$UR5 grrmrDexc_type exc_valueexc_tbs r__exit___ConnectionBase.__exit__  rc6[UR5X5$r)r rS)rDrrs rr _ConnectionBase.send_offset"s4;;=#66rc8[UR5U5 gr)r rS)rDblockings rr _ConnectionBase.setblocking%sDKKM8,r)rUrVrRrW)TT)rNr)r)g)rGrHrIrJrUrEr`rdrgrjrnpropertyrrrYrZrSrmrrrrrrrrr r rKrLrrrNrNsG " .65,$$ $2*4 4+# 7-rrNcX\rSrSrSrSr\R4SjrSr S Sjr Sr S r S r g) PipeConnectioni+z 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(U"UR5 grrq)rD _CloseHandles rr^PipeConnection._close3s  &rc[R"URUSS9up#U[R:Xa3[R"UR /S[ 5nU[:XdeURS5upSUS:XdeU[U5:Xdeg! UR5 e=f!URS5upSf=f)NT overlappedFr) r WriteFilerUERROR_IO_PENDINGWaitForMultipleObjectseventINFINITE WAIT_OBJECT_0cancelGetOverlappedResultr)rDroverrwaitresnwrittens rrPipeConnection._send_bytes6s'' cdKGB ='222%<< E85G#m333 !# 6 6t < !8O8s3x' ''    " 6 6t < #sABB++B..CNcUR(aSUl[R"5$UcSO [US5n[R "UR USS9up4U[R:Xa3[R"UR/S[5nU[:XdeURS5updUS:Xa6[R"5nURUR55 U$U[R :XaUR#X15$[-S5e! UR5 e=f!URS5updUS:Xa:[R"5nURUR55 Us s$U[R :XaUR#X15s s$f=f![$a*nUR&[R(:Xa[*eeSnAff=f)NFTrrz.shouldn't get here; expected KeyboardInterrupt)_got_empty_messageioBytesIOminrReadFilerUrrrrrrrwrite getbufferERROR_MORE_DATA_get_more_datarcwinerrorERROR_BROKEN_PIPEEOFError RuntimeError) rDmaxsizebsizerrrnreadfes rrPipeConnection._recv_bytesFs&&*/'zz|#&C4E%.. eGBD'":"::&-&D&D!# E8'=G#*m#;;#; &(%;%;D%A !8 " AGGBLLN3#$H G$;$;;#'#6#6r#CC<@B B! %'%;%;D%A !8 " AGGBLLN3#$H G$;$;;#'#6#6r#CC<zzW%>%>>& s]"G#AD**AG9$G*D==EAF>G'F>;G=F>>G G5 %G00G5cUR(d'[R"UR5SS:wag[ [ U/U55$)NrT)rr PeekNamedPiperUboolrrs rrPipeConnection._pollhs>''))$,,7:a?dVW-. .rcUR5n[R"5nURU5 [R "UR 5SnUS:deUb"[U5U-U:aUR5 [R"UR USS9upURS5upvUS:XdeXu:XdeURUR55 U$)NrrTr) rrrrrrrUrrnrr)rDrrrrleftrrbytess rrPipeConnection._get_more_datans,,.C A GGCL((6q9D!8O8"s3x$'@((*&&t||TdKGB006KF!8O8> !> GGBLLN #Hr)rr)rGrHrIrJ__doc__rr CloseHandler^rrrrrKrLrrrr+s3 #&-&9&9 ' ( BD / rrc\rSrSrSr\(a)\R4Sjr\Rr \Rr O(\ R4Sjr\ Rr \ R r \ 4Sjr\ 4Sjr\4SjrS S jrS rS rg) Connectioni~zc Connection class based on an arbitrary file descriptor (Unix only), or a socket handle (Windows). c(U"UR5 grrqrDr^s rr^Connection._close 4<< rc(U"UR5 grrqrs rr^rrrc[U5nU"URU5nX4-nUS:XagXSnM%![[[R 4a*n[ USS5[R:waeSnANFSnAff=f)Nrerrno) rrUrcIOErrorr5errorgetattrrEINTR)rDrr remainingrexcs r_sendConnection._sends~H  $,,,  >"gWfll3 3.%++=> s2A; A66A;c[R"5nURnUnUS:aMU"XE5n[U5nUS:XaXQ:Xa[e[ S5eUR U5 XW-nUS:aMMU$![ [[R4a*n[USS5[R:waeSnANNSnAff=f)Nrzgot end of file during messager) rrrUrrrcrrr5rrrr) rDrreadrrXrchunkrrs r_recvConnection._recvsjjl !m V/ J6 (&%&FGG %  !m Wfll3 3.%++=> sA99C B==Cc[U5n[R"SU5nUS:a#URU5 URU5 g[ X5(aUR 5nURXA-5 g)N!ii@)rstructpackrrQtobytes)rDrr~rheaders rrConnection._send_bytessa HT1% u9 JJv  JJsO #**kkm JJv| $rNcURS5n[R"SUR55unUbX1:agURU5$)Nr)rrunpackr)rDrrrs rrConnection._recv_bytessCjjm dCLLN3  4>zz$rc2[U/U5n[U5$r)rr)rDrrs rrConnection._polls $ !AwrrLr)rGrHrIrJrrr closesocketr^r_writer_readr)rmrrrrr~rrrrKrLrrrr~sp  ) 5 5 ! " !%  %*+5%$ rrc^\rSrSrSrS SjrSrSr\"S5r \"S5r S r S r S r g) riz Returns a listener object. This is a wrapper for a bound socket which is 'listening' for connections, or for a Windows named pipe. Nc8U=(d! U=(a [U5=(d [nU=(d [U5n[U5 US:Xa[ X5UlO[ XU5UlUb [U[5(d [S5eX@l g)Nrauthkey should be a byte string) r=default_familyr0r6 PipeListener _listenerSocketListenerrQr TypeError_authkey)rDr<r/backlogauthkeys rrEListener.__init__sH4|G4H9G 6.v6 Y )';DN+GWEDN  z'5'A'A=> > rcURc [S5eURR5nUR(a*[ XR5 [ XR5 U$)zb Accept a connection on the bound socket or named pipe of `self`. Returns a `Connection` object. zlistener is closed)rrcacceptrdeliver_challengeanswer_challenge)rDcs rr"Listener.acceptsP >> !./ / NN ! ! # == a / Q .rcRURnUbSUlUR5 gg)z1 Close the bound socket or named pipe of `self`. N)rrm)rDlisteners rrmListener.closes)>>  !DN NN  rc.URR$r)r_addressr_s rListener.sDNN$;$;rc.URR$r)r_last_acceptedr_s rr,r-s$..*G*GrcU$rrLr_s rrListener.__enter__rrc$UR5 grrrs rrListener.__exit__rr)rr)NNrN)rGrHrIrJrrEr"rmrr< last_acceptedrrrKrLrrrrs8  ;&&  d&)$$ Wfll3 3.%++=> s!A B) BBcURR5 URnUbSUlU"5 gg!URnUbSUlU"5 ff=fr)rRrmrr)rDrqs rrmSocketListener.closes[  LL   \\F!# "\\F!# "s ; A)r+ror/rRrrN)r) rGrHrIrJrrEr"rmrKrLrrrrqs 0 %rrc[U5n[R"[[U55nURS5 UR U5 [ [ U55$)zG Return a connection object connected to the socket given by `address` T)r=r5rr connectrr9)r<r/rus rr7r7sJ' "F gff-.AMM$IIg fQi  rcB\rSrSrSrS SjrS SjrSr\S5r Sr g) riz Representation of a named pipe Nc XlURSS9/UlSUl[R "SUR5 [R "U[RURUR4SS9Ul g)NT)firstz listener created with address=%rrre) r+ _new_handle _handle_queuer/r sub_debugrpr_finalize_pipe_listenerrm)rDr<rs rrEPipeListener.__init__sj#M"&"2"2"2">!?D "&D  NN=t}} Ml::(($--8qDJrc [R[R-nU(aU[R-n[R"UR U[R [R-[R-[R[[[R[R5$r) rrJrPrQrOr+rRrSrTPIPE_UNLIMITED_INSTANCESrMrUrV)rDr}flagss rr~PipeListener._new_handles..1M1MME>>>** u))G,I,II!!"00'7,,gll  rcZURRUR55 URRS5n[R "USS9n[R "UR/S[5 URS5up4US:Xde[U5$! UR5 [R"U5 e=f!URS5up4US:Xdef=f![a)nUR[R:waeSnANSnAff=f)NrTrF)rappendr~poprrZrrrrrrrcr ERROR_NO_DATAr)rDrXrrarrs rr"PipeListener.accepts    % %d&6&6&8 9''++A.F $--fF $22 E85 33D9FA!8O8!&) )IIK''/33D9FA!8O8 ::!6!667 s0C7'B++)CCC47 D*D%%D*cp[R"SU5 UHn[R"U5 M g)Nz closing listener with address=%r)rrrr)queuer<rXs rr$PipeListener._finalize_pipe_listeners) NN=w G##F+ r)r+rr/rmr)F) rGrHrIrJrrEr~r" staticmethodrrKrLrrrrs*    *.  ,  ,rrc [5n[R"US5 [R"U[R[R -S[R [R[R[R 5n[R"U[RSS5 [U5$![a+nURU;d[U5(aeSnAOSnAff=fM)zE Return a connection object connected to the pipe given by `address` rN)rr WaitNamedPiperWrKrLrVrXrPrcrr rYrSr)r<_ignorerhrs rr6r6s O %%gt4&&W11G4I4IIw||W%:%:00',, '' w,,dD a   ::W,q0A0A1B sB C C?!C::C?s #CHALLENGE#s #WELCOME#s #FAILURE#ctSSKn[U[5(de[R"[ 5nUR [U-5 URXS5R5nURS5nXT:XaUR [5 gUR [5 [S5e)Nrmd5zdigest received was wrong)hmacrQrr)urandomMESSAGE_LENGTHr CHALLENGEnewdigestrWELCOMEFAILUREr connectionrrmessagerresponses rr#r#s gu % %% %jj(G)g-. XXg . 5 5 7F$$S)Hg&g&!"=>>rcvSSKn[U[5(deURS5nUS[ [ 5[ :Xd SU-5eU[ [ 5SnUR XS5R5nURU5 URS5nU[:wa [S5eg)Nrrz message = %rrzdigest sent was rejected) rrQrrrrrrrrrrs rr$r$s gu % %% %##C(G ?C N #y 0J.72JJ 0c)no&G XXg . 5 5 7F&!$$S)H7!"<==rc&\rSrSrSrSrSrSrg)ConnectionWrapperi0chXlX lX0lSHn[X5n[ XU5 M g)N)rSrmrrr)_conn_dumps_loadsrsetattr)rDconnrloadsattrrs rrEConnectionWrapper.__init__2s0   KD$%C D $Lrc\URU5nURRU5 gr)rrr)rDrrus rrConnectionWrapper.send:s" KK  a rcXURR5nURU5$r)rrr)rDrus rrConnectionWrapper.recv>s" JJ ! ! #{{1~r)rrrN)rGrHrIrJrErrrKrLrrrr0s%!rrcX[RU4SSSS5nURS5$)Nrutf-8) xmlrpclibrencode)ros r _xml_dumpsrCs)tT15A 88G rcV[RURS55uupU$)Nr)rrdecode)rurmethods r _xml_loadsrHs"__QXXg%67NFS Jrc\rSrSrSrSrg) XmlListeneriMcbSSKJq [R U5n[ U[ [5$Nr) xmlrpc.clientclientrrr"rrrrs rr"XmlListener.acceptOs")ood# j*==rrLN)rGrHrIrJr"rKrLrrrrMs>rrcJSSKJq [[ U0UD6[ [ 5$r)rrrrrrr)rfkwdss r XmlClientrVs% VT2T2J KKrc[U5n/nU(a[R"USU5nU[:XaU$[Us=::a[[ U5-:a O O U[-nO9[ Us=::a[ [ U5-:a O O U[ -nO [S5eURX$5 X$S-SnSnU(aMU$)NFzShould not get hererr) listrr WAIT_TIMEOUTrrWAIT_ABANDONED_0rr)handlesrLreadyress r_exhaustive_waitras M00E7CCl" #> A(>>}$!SD+;c!f+DD''"#899 LL '( AGa rc^ Uc[nOUS:aSnO[US-S-5n[U5n0m /n[5n[5nUHyn[ US5n[ R "U"5SS5upxU[ R:Xa"URW5 UT UR'MfURU5 SnM{ [!T R#5U5nUHnUR%5 M UHonUR'S5upU[ R(:wdM-T URnURU5 US:XdMU[+US5(dMhSUlMq UR/U 4SjU55 UV s/sH oU;dM U PM sn $![a"n U RnU[;aeSn A GNQSn A ff=f![a UT UR5'GMf=f![a"n U RnU[;aeSn A GN Sn A ff=f!UHnUR%5 M UHnUR'S5upO.![a!n U RnU[;aeSn A OSn A ff=fU[ R(:wdM\T URnURU5 US:XdM[+US5(dMSUlM f=fs sn f)  Wait till an object in object_list is ready/readable. Returns list of those objects in object_list which are ready/readable. Nrrg?rSTrc3.># UH nTUv M g7frrL).0rwaithandle_to_objs r wait..sI=a.q1=s)rintrsetrrrrcr _ready_errorsrrraddAttributeErrorrTrkeysrrERROR_OPERATION_ABORTEDr4rupdate) object_listrov_list ready_objects ready_handlesrrSrrrraprs @rrrws ?G q[G'D.3./G;'   - 8 $$Q1F "")"2"268Q"E g666r*67)"((3 &))!,"#+!.-->-C-C-EwOM 33D9FA '999)"((3A!%%a(ax#1&:;;37A0 I=II&=;a}*<;==M#"jjm3!4" &978%akkm49<**C-/0 33D9FAs**C-/0'999)"((3A!%%a(ax#1&:;;37A0">s H) GF&K(J K(!$K( K( K(rcUb[US-5n0n[R"5nUHLnURU[R5 [ US5(aXBUR 5'MHXBU'MN /nURU5H>upFU[R-(a[SU-5eURX$5 M@ U$)NrrSzinvalid file descriptor %i) rselectrregisterPOLLINr4rSPOLLNVALr-r)fdsrfd_mappollsterfdlsrs rrrs"gn-F{{}H!!"fmm42x((*,299;'!#2J  B%]]73 6??*$%AB%FGG &*%4Irc:[R"U//U5S$r)r)rrs rrrs==b"g6q9 9rcUbUS::a [US5$[5U-n[X5$![[[R 4a)nUR [ R:waeSnAOSnAff=fUb W[5- nMi)rNr)rr rcrr5rrr)rrdeadliners rrrs  !|[!,,$;0 [22Wfll3 77ekk)* ""Y[0s 0A8A33A8c*UR5n[R"U[R[R5nSSKJn URU5n[X@RUR44sSSS5 $!,(df  g=f)Nr)resource_sharer) rSr5fromfdr SOCK_STREAMr%r DupSocketrebuild_connectionrYrZ)rrXrurdss rreduce_connectionrs^ ]]66>>63E3E F! ) **1-B%MM4=='IIG F Fs 5B BcLUR5n[[U5X5$r)r9r)rrYrZrCs rrrsyy{&,;;rcUR(a[ROSUR(a[ROS-n[ R "UR5U5n[X RUR44$r) rYrFILE_GENERIC_READrZFILE_GENERIC_WRITEr DupHandlerSrebuild_pipe_connection)rr\dhs rreduce_pipe_connectionrs\04 7,,1157--AG   7&]]DMM(JJJrc,[[U5X5$r)rr9)rrYrZs rrrsfRj(==rc[R"UR55n[XRUR 44$r)rDupFdrSrrYrZ)rdfs rrrs. __T[[] +!B t}}#EEErc,[[U5X5$r)rr9)rrYrZs rrrs&*h99r)NN)TFFr)Orrr)r2r5rrr& itertoolsr%rrrr_extrcompatr r timer r rr3rrrr ImportError__all__r4is_pypyrMCONNECTION_TIMEOUTcountr,rfamiliesrr r0r6r=r?rNrrrrr9rrr7rERROR_SEM_TIMEOUTERROR_PIPE_BUSYr6rrrrr#r$rrrrrrrERROR_NETNAME_DELETEDrrrrrrrrrLrrrs 1,% $  ||w-- "33++ ## 0 #* + !  ; 69N  H<<7N  H-! 0 F F( _-_-D PPfOOl55p *"<<7.(^//d!<<76,6,p&-%>%>%,%<%<%>!>    ? >"&  >(>L<<7(..0M0MNMC>Nvv $ :10<<7J<z#45K > ~'=>F: z#45W ||w GsI66JJ