ÿØÿà JFIF    ÿÛ C    !"$"$ÿÛ C  ÿ p " ÿÄ     ÿÄ   ÿÚ   ÕÔË® (% aA*‚XYD¡(J„¡E¢RE,P€XYae )(E¤²€B¤R¥ BQ¤¢ X«)X…€¤  @ .............................................................................................................................................................................. ............................................................................. ÿØÿà JFIF    ÿÛ C    !"$"$ÿÛ C  ÿ p " ÿÄ     ÿÄ   ÿÚ   ÕÔË® (% aA*‚XYD¡(J„¡E¢RE,P€XYae )(E¤²€B¤R¥ BQ¤¢ X«)X…€¤  @ .............................................................................................................................................................................. .............................................................................  ;;Wgc@sydddgZddlZddlZddlZddlZddlZddlZddlZddlZddl m Z m Z ddl m Z mZmZmZddlmZmZdZd ZejZd Zd gZeed r d Zed g7Znejd kr.d Zed g7ZnedZdZdZdZde fdYZ!dddZ#ejd kre$dZ%nddlm&Z&e$dZ%de fdYZ'dZ(ejd krde fdYZ)dZ*ndZ+dZ,dZ-d Z.d!Z/d"Z0d#e fd$YZ1d%Z2d&Z3d'e!fd(YZ4d)Z5dS(*tClienttListenertPipeiN(tcurrent_processtAuthenticationError(t get_temp_dirtFinalizet sub_debugtdebug(t duplicatetclosei g4@tAF_INETtAF_UNIXtwin32tAF_PIPEcCstj|S(N(ttime(ttimeout((s0/usr/lib/python2.7/multiprocessing/connection.pyt _init_timeoutIscCstj|kS(N(R(tt((s0/usr/lib/python2.7/multiprocessing/connection.pyt_check_timeoutLscCs}|dkrd S|dkr5tjdddtS|dkrmtjdd tjtjfdd Std d S(s? Return an arbitrary free address for the given family R t localhostiR tprefixs listener-tdirRs\\.\pipe\pyc-%d-%d-tsunrecognized familyN(Ri(ttempfiletmktempRtostgetpidt _mmap_countertnextt ValueError(tfamily((s0/usr/lib/python2.7/multiprocessing/connection.pytarbitrary_addressSs     cCset|tkrdSt|tkr;|jdr;dSt|tkrQdStd|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((s0/usr/lib/python2.7/multiprocessing/connection.pyt address_typebs!cBsSeZdZdddddZdZdZedZedZ 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|rt|pt}|p-t|}|dkrQt|||_nt||||_|dk rt|t rt dn||_ dS(NRsauthkey should be a byte string( R&tdefault_familyR t PipeListenert _listenertSocketListenertNonet isinstancetbytest TypeErrort_authkey(tselfR%Rtbacklogtauthkey((s0/usr/lib/python2.7/multiprocessing/connection.pyt__init__|s  cCs?|jj}|jr;t||jt||jn|S(sz Accept a connection on the bound socket or named pipe of `self`. Returns a `Connection` object. (R)tacceptR/tdeliver_challengetanswer_challenge(R0tc((s0/usr/lib/python2.7/multiprocessing/connection.pyR4s  cCs |jjS(sA Close the bound socket or named pipe of `self`. (R)R (R0((s0/usr/lib/python2.7/multiprocessing/connection.pyR scCs |jjS(N(R)t_address(R0((s0/usr/lib/python2.7/multiprocessing/connection.pytRcCs |jjS(N(R)t_last_accepted(R0((s0/usr/lib/python2.7/multiprocessing/connection.pyR9RN( t__name__t __module__t__doc__R+R3R4R tpropertyR%t last_accepted(((s0/usr/lib/python2.7/multiprocessing/connection.pyRus  cCs|pt|}|dkr-t|}n t|}|dk rat|t ratdn|dk rt||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.R6R5(R%RR2R7((s0/usr/lib/python2.7/multiprocessing/connection.pyRs     cCs|rtj\}}|jt|jttjtj|j}tjtj|j}|j |j n<tj \}}tj|dt }tj|dt }||fS(sL Returns pair of connection objects at either end of a pipe twritabletreadable( tsockett socketpairt setblockingtTruet_multiprocessingt ConnectionRtduptfilenoR tpipetFalse(tduplexts1ts2tc1tc2tfd1tfd2((s0/usr/lib/python2.7/multiprocessing/connection.pyRs    (R c CsUtd}|r;tj}tjtjB}tt}}ntj}tj}dt}}tj||tjtj Btj Bd||tj tj }tj ||dtj tjdtj }tj|tj ddytj|tj Wn/tk r }|jdtjkr!q!nXtj|d|} tj|d|} | | fS(sL Returns pair of connection objects at either end of a pipe RiiRBRCN(R R tPIPE_ACCESS_DUPLEXt GENERIC_READt GENERIC_WRITEtBUFSIZEtPIPE_ACCESS_INBOUNDtCreateNamedPipetPIPE_TYPE_MESSAGEtPIPE_READMODE_MESSAGEt PIPE_WAITtNMPWAIT_WAIT_FOREVERtNULLt CreateFilet OPEN_EXISTINGtSetNamedPipeHandleStateR+tConnectNamedPipet WindowsErrortargstERROR_PIPE_CONNECTEDRHtPipeConnection( RNR%topenmodetaccesstobsizetibsizeth1th2teRQRR((s0/usr/lib/python2.7/multiprocessing/connection.pyRs2      $ R*cBs,eZdZddZdZdZRS(sO Representation of a socket which is bound to an address and listening icCstjtt||_yb|jjtjtjd|jjt|jj||jj ||jj |_ Wn$tj k r|jj nX||_d|_|dkrt|tjd|fdd|_n d|_dS(NiR Ret exitpriorityi(RDtgetattrt_sockett setsockoptt SOL_SOCKETt SO_REUSEADDRRFRGtbindtlistent getsocknameR8terrorR t_familyR+R:RRtunlinkt_unlink(R0R%RR1((s0/usr/lib/python2.7/multiprocessing/connection.pyR3s     $cCsx\tr^y|jj\}|_Wn2tjk rY}|jdtjkr[q[qXPqW|j tt |j }t j |}|j|S(Ni(RGRqR4R:RDRxReterrnotEINTRRFR RKRHRIR (R0tsRntfdtconn((s0/usr/lib/python2.7/multiprocessing/connection.pyR4s    cCsAz|jjWd|j}|dk r<d|_|nXdS(N(RqR R{R+(R0Rz((s0/usr/lib/python2.7/multiprocessing/connection.pyR s    (R;R<R=R3R4R (((s0/usr/lib/python2.7/multiprocessing/connection.pyR*s  cCsttt|}t}xtj|}|jty|j|Wnbtjk r}|j|j dt j kst |rt d|ntjdq!XPq!Wt|j}tj|}|j|S(sO Return a connection object connected to the socket given by `address` isfailed to connect to address %sg{Gz?(RpRDR&RRFRGtconnectRxR ReR|t ECONNREFUSEDRRRtsleepR RKRHRI(R%RRR~RnRR((s0/usr/lib/python2.7/multiprocessing/connection.pyRA)s&   "  R(cBs2eZdZddZdZedZRS(s0 Representation of a named pipe c Cs||_tj|tjtjtjBtjBtjtttj tj }|g|_ d|_ td|jt|tjd|j |jfdd|_dS(Ns listener created with address=%rReRoi(R8R RZRUR[R\R]tPIPE_UNLIMITED_INSTANCESRXR^R_t _handle_queueR+R:RRR(t_finalize_pipe_listenerR (R0R%R1thandle((s0/usr/lib/python2.7/multiprocessing/connection.pyR3Os       c Cstj|jtjtjtjBtjBtjtttj tj }|j j ||j j d}ytj|tj Wn8tk r}|jdtjtjfkrqnXtj|S(Ni(R RZR8RUR[R\R]RRXR^R_RtappendtpopRcRdReRft ERROR_NO_DATARHRg(R0t newhandleRRn((s0/usr/lib/python2.7/multiprocessing/connection.pyR4bs    cCs,td|x|D]}t|qWdS(Ns closing listener with address=%r(RR (tqueueR%R((s0/usr/lib/python2.7/multiprocessing/connection.pyRvs  N(R;R<R=R+R3R4t staticmethodR(((s0/usr/lib/python2.7/multiprocessing/connection.pyR(Ks  cCst}xyHtj|dtj|tjtjBdtjtjdtj}WnDtk r}|j dtj tj fkst |rqq XPq Wtj |tjddtj|S(sU Return a connection object connected to the pipe given by `address` iiN(RR t WaitNamedPipeR`RVRWR_RaRdRetERROR_SEM_TIMEOUTtERROR_PIPE_BUSYRRbR\R+RHRg(R%RthRn((s0/usr/lib/python2.7/multiprocessing/connection.pyR@|s  " is #CHALLENGE#s #WELCOME#s #FAILURE#cCsddl}t|ts!ttjt}|jt||j ||j }|j d}||kr|jt n|jt tddS(Niisdigest received was wrong(thmacR,R-tAssertionErrorRturandomtMESSAGE_LENGTHt send_bytest CHALLENGEtnewtdigestt recv_bytestWELCOMEtFAILURER(t connectionR2RtmessageRtresponse((s0/usr/lib/python2.7/multiprocessing/connection.pyR5s   cCsddl}t|ts!t|jd}|tt tksVtd||tt}|j||j}|j ||jd}|t krt dndS(Niis message = %rsdigest sent was rejected( RR,R-RRtlenRRRRRR(RR2RRRR((s0/usr/lib/python2.7/multiprocessing/connection.pyR6s &  tConnectionWrappercBs#eZdZdZdZRS(cCsO||_||_||_x-dD]%}t||}t|||q"WdS(NRKR tpollRR(RKR RRR(t_connt_dumpst_loadsRptsetattr(R0Rtdumpstloadstattrtobj((s0/usr/lib/python2.7/multiprocessing/connection.pyR3s     cCs#|j|}|jj|dS(N(RRR(R0RR~((s0/usr/lib/python2.7/multiprocessing/connection.pytsendscCs|jj}|j|S(N(RRR(R0R~((s0/usr/lib/python2.7/multiprocessing/connection.pytrecvs(R;R<R3RR(((s0/usr/lib/python2.7/multiprocessing/connection.pyRs  cCstj|fddddS(Ni(t xmlrpclibRR+(R((s0/usr/lib/python2.7/multiprocessing/connection.pyt _xml_dumpsscCstj|\\}}|S(N(RR(R~Rtmethod((s0/usr/lib/python2.7/multiprocessing/connection.pyt _xml_loadsst XmlListenercBseZdZRS(cCs+ddlatj|}t|ttS(Ni(RRR4RRR(R0R((s0/usr/lib/python2.7/multiprocessing/connection.pyR4s (R;R<R4(((s0/usr/lib/python2.7/multiprocessing/connection.pyRscOs%ddlatt||ttS(Ni(RRRRR(Retkwds((s0/usr/lib/python2.7/multiprocessing/connection.pyt XmlClients (6t__all__RtsysRDR|RRt itertoolsRHtmultiprocessingRRtmultiprocessing.utilRRRRtmultiprocessing.forkingR R RXtCONNECTION_TIMEOUTtcountRR'tfamiliesthasattrtplatformRRR R&tobjectRR+RRGRR R*RAR(R@RRRRR5R6RRRRR(((s0/usr/lib/python2.7/multiprocessing/connection.pyt#s`        "      , *2 1