Ñò ˜à"Ic@sfdddgZddkZddkZddkZddkZddkZddkZddkZddkZddk l Z l Z ddk l Z lZlZlZddklZlZdZeiƒZd Zd gZeed ƒod Zed g7Zneid jod Zed g7Znd „Zd„Zdefd„ƒYZddd„Z eid joe!d„Z"nddkl#Z#e!d„Z"defd„ƒYZ$d„Z%eid jo#defd„ƒYZ&d„Z'ndZ(dZ)dZ*dZ+d„Z,d „Z-d!efd"„ƒYZ.d#„Z/d$„Z0d%efd&„ƒYZ1d'„Z2dS((tClienttListenertPipeiÿÿÿÿN(tcurrent_processtAuthenticationError(t get_temp_dirtFinalizet sub_debugtdebug(t duplicatetclosei tAF_INETtAF_UNIXtwin32tAF_PIPEcCs}|djod S|djotidddtƒƒS|djo'tidd tiƒtiƒfƒStd ƒ‚d S( s? Return an arbitrary free address for the given family R t localhostiR tprefixs listener-tdirRs\\.\pipe\pyc-%d-%d-sunrecognized familyN(Ri(ttempfiletmktempRtostgetpidt _mmap_countertnextt ValueError(tfamily((s7/mit/python/lib/python2.6/multiprocessing/connection.pytarbitrary_address0s    cCslt|ƒtjodSt|ƒtjo|idƒodSt|ƒtjodStd|ƒ‚dS(s] Return the types of the address This can be 'AF_INET', 'AF_UNIX', or 'AF_PIPE' R s\\RR saddress type of %r unrecognizedN(ttypettupletstrt startswithR(taddress((s7/mit/python/lib/python2.6/multiprocessing/connection.pyt address_type?s#cBsSeZdZddddd„Zd„Zd„Zed„ƒZed„ƒZ RS(s• Returns a listener object. This is a wrapper for a bound socket which is 'listening' for connections, or for a Windows named pipe. icCs¤|p|o t|ƒpt}|p t|ƒ}|djot||ƒ|_nt|||ƒ|_|dj ot|tƒ o t d‚n||_ dS(NRsauthkey should be a byte string( R tdefault_familyRt PipeListenert _listenertSocketListenertNonet isinstancetbytest TypeErrort_authkey(tselfRRtbacklogtauthkey((s7/mit/python/lib/python2.6/multiprocessing/connection.pyt__init__Ys  cCsA|iiƒ}|io$t||iƒt||iƒn|S(sz Accept a connection on the bound socket or named pipe of `self`. Returns a `Connection` object. (R#tacceptR)tdeliver_challengetanswer_challenge(R*tc((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR.hs  cCs |iiƒS(sA Close the bound socket or named pipe of `self`. (R#R (R*((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR tscCs |iiS((R#t_address(R*((s7/mit/python/lib/python2.6/multiprocessing/connection.pytzscCs |iiS((R#t_last_accepted(R*((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR3{sN( t__name__t __module__t__doc__R%R-R.R tpropertyRt last_accepted(((s7/mit/python/lib/python2.6/multiprocessing/connection.pyRRs  cCs–|p t|ƒ}|djot|ƒ}n t|ƒ}|dj ot|tƒ o td‚n|dj ot||ƒt||ƒn|S(s= Returns a connection to the address of a `Listener` Rsauthkey should be a byte stringN( R t PipeClientt SocketClientR%R&R'R(R0R/(RRR,R1((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR~s     cCs³|oftiƒ\}}titi|iƒƒƒ}titi|iƒƒƒ}|iƒ|iƒn=tiƒ\}}ti|dt ƒ}ti|dt ƒ}||fS(sL Returns pair of connection objects at either end of a pipe twritabletreadable( tsockett socketpairt_multiprocessingt ConnectionRtduptfilenoR tpipetFalse(tduplexts1ts2tc1tc2tfd1tfd2((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR”s i(R c Cs[tdƒ}|o*ti}titiB}tt}}n ti}ti}dt}}ti||titi Bti Bd||ti ti ƒ}ti ||dti tidti ƒ}ti|ti ddƒyti|ti ƒWn3tj o'}|idtijo‚q'nXti|d|ƒ} ti|d|ƒ} | | fS(sL Returns pair of connection objects at either end of a pipe RiiR<R=N(RR tPIPE_ACCESS_DUPLEXt GENERIC_READt GENERIC_WRITEtBUFSIZEtPIPE_ACCESS_INBOUNDtCreateNamedPipetPIPE_TYPE_MESSAGEtPIPE_READMODE_MESSAGEt PIPE_WAITtNMPWAIT_WAIT_FOREVERtNULLt CreateFilet OPEN_EXISTINGtSetNamedPipeHandleStateR%tConnectNamedPipet WindowsErrortargstERROR_PIPE_CONNECTEDR@tPipeConnection( RFRtopenmodetaccesstobsizetibsizeth1th2teRIRJ((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR©s2      $ R$cBs,eZdZdd„Zd„Zd„ZRS(sO Representation of a socket which is bound to an address and listening icCs¡titt|ƒƒ|_|ii|ƒ|ii|ƒ|iiƒ|_||_d|_ |djo(t |t i d|fddƒ|_ n d|_ dS(NR R]t exitpriorityi(R>tgetattrt_sockettbindtlistent getsocknameR2t_familyR%R4RRtunlinkt_unlink(R*RRR+((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR-×s   %cCsG|iiƒ\}|_t|iƒƒ}ti|ƒ}|iƒ|S(N(RiR.R4R RCR@RAR (R*tstfdtconn((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR.æs  cCs/|iiƒ|idj o|iƒndS(N(RiR RoR%(R*((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR ís (R5R6R7R-R.R (((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR$Ós  cCsÁt|ƒ}titt|ƒƒ}xky|i|ƒWnPtij oA}|idtijotd|ƒ‚nt i dƒq'XPq'‚t |i ƒƒ}t i|ƒ}|iƒ|S(sO Return a connection object connected to the socket given by `address` isfailed to connect to address %sg{®Gáz„?(R R>RhtconnectterrorR]terrnot ECONNREFUSEDRttimetsleepR RCR@RAR (RRRpRfRqRr((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR;ós    R"cBs2eZdZdd„Zd„Zed„ƒZRS(s0 Representation of a named pipe c Cs ||_ti|tititiBtiBtittti ti ƒ}|g|_ d|_ td|iƒt|tid|i |ifddƒ|_dS(Ns listener created with address=%rR]Rgi(R2R RRRMRSRTRUtPIPE_UNLIMITED_INSTANCESRPRVRWt _handle_queueR%R4RRR"t_finalize_pipe_listenerR (R*RR+thandle((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR-s       c CsÀti|itititiBtiBtittti ti ƒ}|i i |ƒ|i i dƒ}yti|ti ƒWn3tj o'}|idtijo‚q³nXti|ƒS(Ni(R RRR2RMRSRTRURyRPRVRWRztappendtpopR[R\R]R^R@R_(R*t newhandleR|Rf((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR.)s    cCs,td|ƒx|D]}t|ƒqWdS(Ns closing listener with address=%r(RR (tqueueRR|((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR{:s N(R5R6R7R%R-R.t staticmethodR{(((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR"s  c Cs·xŽyHti|dƒti|titiBdtitidtiƒ}Wn<tj o0}|idti ti fjo‚q‹qXPq‚ti |ti ddƒti|ƒS(sU Return a connection object connected to the pipe given by `address` ièiN(R t WaitNamedPipeRXRNRORWRYR\R]tERROR_SEM_TIMEOUTtERROR_PIPE_BUSYRZRTR%R@R_(RthRf((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR:@s" is #CHALLENGE#s #WELCOME#s #FAILURE#cCsŽddk}titƒ}|it|ƒ|i||ƒiƒ}|idƒ}||jo|it ƒn|it ƒt dƒ‚dS(Niÿÿÿÿisdigest received was wrong( thmacRturandomtMESSAGE_LENGTHt send_bytest CHALLENGEtnewtdigestt recv_bytestWELCOMEtFAILURER(t connectionR,R†tmessageRŒtresponse((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR/cs   cCs€ddk}|idƒ}|ttƒ}|i||ƒiƒ}|i|ƒ|idƒ}|tjotdƒ‚ndS(Niÿÿÿÿisdigest sent was rejected( R†RtlenRŠR‹RŒR‰RŽR(RR,R†R‘RŒR’((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR0ps   tConnectionWrappercBs#eZd„Zd„Zd„ZRS(cCsO||_||_||_x-dD]%}t||ƒ}t|||ƒq"WdS(NRCR tpollRR‰(sfilenoscloseR•s recv_bytess send_bytes(t_connt_dumpst_loadsRhtsetattr(R*Rrtdumpstloadstattrtobj((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR-s   cCs#|i|ƒ}|ii|ƒdS(N(R—R–R‰(R*RRp((s7/mit/python/lib/python2.6/multiprocessing/connection.pytsendˆscCs|iiƒ}|i|ƒS(N(R–RR˜(R*Rp((s7/mit/python/lib/python2.6/multiprocessing/connection.pytrecv‹s(R5R6R-RžRŸ(((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR”€s  cCs%ti|fddddƒidƒS(Nitutf8(t xmlrpclibRšR%tencode(R((s7/mit/python/lib/python2.6/multiprocessing/connection.pyt _xml_dumpsscCs%ti|idƒƒ\\}}|S(NR (R¡R›tdecode(RpRtmethod((s7/mit/python/lib/python2.6/multiprocessing/connection.pyt _xml_loads’s!t XmlListenercBseZd„ZRS(cCs+ddkati|ƒ}t|ttƒS(Niÿÿÿÿ(R¡RR.R”R£R¦(R*R((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR.—s (R5R6R.(((s7/mit/python/lib/python2.6/multiprocessing/connection.pyR§–scOs%ddkatt||ŽttƒS(Niÿÿÿÿ(R¡R”RR£R¦(R]tkwds((s7/mit/python/lib/python2.6/multiprocessing/connection.pyt XmlClients (3t__all__RtsysR>RuRwRt itertoolsR@tmultiprocessingRRtmultiprocessing.utilRRRRtmultiprocessing.forkingR R RPtcountRR!tfamiliesthasattrtplatformRR tobjectRR%RtTrueRR R$R;R"R:RˆRŠRŽRR/R0R”R£R¦R§R©(((s7/mit/python/lib/python2.6/multiprocessing/connection.pyt sZ        "    , * .