£Á°èZ¨Ä…–K§‚«“ô4“ÒÙ´dîfUÙÃÅ WKbyʦ•êŽ…È®FÒ¿ÊÎóCozá¬S@6{Í:›œêZÌ:Š•_%:¢¾¾~;‘Ã~芩ÊǍí`ÔÑ©ú뙵'5I¿fš×WO%ø9¾«¾DK|€ùÍD”Ýs]nHÕ¶êםӼ㞪éUWŸÈË%DÒÕ¬ï‘]/Åcx ‰ï2ß]ä6G[]S£Ôϯrs{úëóµmÒï#UQxo·õÞCe]"±/aÙ&Eã4ú9Jé_ÞåëdãöKë)AÞ ¯¹ægƒÛowЍø^d™ý½ßB7áyMä9ÜÖUã !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! fyuc@sddddgZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl mZmZmZddlmZmZmZmZddlmZy,ddlZdd lmZmZmZWn-ek rKejd krAndZYnXd Zd Z e j!Z"d Z#d gZ$e%edrdZ#e$dg7Z$nejd krdZ#e$dg7Z$ne ddZ&ddZ'ddZ(ddZ)ddZ*GdddZ+er.Gddde+Z,nGddde+Z-Gd dde.Z/ddd!dZ0ejd krdHd"dZ2ndHd#dZ2Gd$d%d%e.Z3d&d'Z4ejd krGd(d)d)e.Z5d*d+Z6nd,Z7d-Z8d.Z9d/Z:d0d1Z;d2d3Z<Gd4d5d5e.Z=d6d7Z>d8d9Z?Gd:d;d;e/Z@d<d=ZAejd krd>d?ZBejCejDhZEdd@dZFn9e%edArdBdCZGn dDdCZGddEdZFejd krHdFdGlHmIZIejJejeIjKejJe-eIjLejJe,eIjMnRydFdGlHmIZIWnek rpYn*XejJejeIjKejJe-eIjLdS(IuClientuListeneruPipeuwaitiN(ucurrent_processuAuthenticationErroruBufferTooShort(u get_temp_diruFinalizeu sub_debugudebug(uForkingPickler(u WAIT_OBJECT_0u WAIT_TIMEOUTuINFINITEuwin32i g4@uAF_INETuAF_UNIXuAF_PIPEcCstj|S(N(utime(utimeout((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu _init_timeout:su _init_timeoutcCstj|kS(N(utime(ut((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_check_timeout=su_check_timeoutcCsw|dkrd S|dkr5tjdddtS|dkrgtjdd tjttfStd d S( u? Return an arbitrary free address for the given family uAF_INETu localhostiuAF_UNIXuprefixu listener-udiruAF_PIPEu\\.\pipe\pyc-%d-%d-uunrecognized familyN(u localhosti(utempfileumktempu get_temp_diruosugetpidunextu _mmap_counteru ValueError(ufamily((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuarbitrary_addressDs    uarbitrary_addresscCsrtjdkr.|dkr.td|ntjdkrn|dkrntt|sntd|qnndS(uD Checks if the family is valid for the current environment. uwin32uAF_PIPEuFamily %s is not recognized.uAF_UNIXN(usysuplatformu ValueErroruhasattrusocket(ufamily((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_validate_familyRs u_validate_familycCset|tkrdSt|tkr;|jdr;dSt|tkrQdStd|dS(u] Return the types of the address This can be 'AF_INET', 'AF_UNIX', or 'AF_PIPE' uAF_INETu\\uAF_PIPEuAF_UNIXuaddress type of %r unrecognizedN(utypeutupleustru startswithu ValueError(uaddress((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu address_type^s!u address_typecBs%|EeZdZd)Zd*d*ddZddZddZddZ d d Z d d Z e d dZ e ddZe ddZddZddZdd)ddZddZd)ddZdddZd d!Zd"d#d$Zd%d&Zd'd(Zd)S(+u_ConnectionBasecCsc|j}|dkr'tdn| rD| rDtdn||_||_||_dS(Niuinvalid handleu6at least one of `readable` and `writable` must be True(u __index__u ValueErroru_handleu _readableu _writable(uselfuhandleureadableuwritable((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu__init__ts     u_ConnectionBase.__init__cCs |jdk r|jndS(N(u_handleuNoneu_close(uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu__del__su_ConnectionBase.__del__cCs"|jdkrtdndS(Nuhandle is closed(u_handleuNoneuIOError(uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu _check_closedsu_ConnectionBase._check_closedcCs|jstdndS(Nuconnection is write-only(u _readableuIOError(uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_check_readables u_ConnectionBase._check_readablecCs|jstdndS(Nuconnection is read-only(u _writableuIOError(uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_check_writables u_ConnectionBase._check_writablecCs/|jrd|_n |jtddS(Nubad message lengthF(u _writableuFalseu _readableucloseuIOError(uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_bad_message_lengths   u#_ConnectionBase._bad_message_lengthcCs |jdkS(u True if the connection is closedN(u_handleuNone(uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuclosedsu_ConnectionBase.closedcCs|jS(u"True if the connection is readable(u _readable(uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyureadablesu_ConnectionBase.readablecCs|jS(u"True if the connection is writable(u _writable(uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuwritablesu_ConnectionBase.writablecCs|j|jS(u+File descriptor or handle of the connection(u _check_closedu_handle(uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyufilenos u_ConnectionBase.filenoc Cs1|jdk r-z|jWdd|_XndS(uClose the connectionN(u_handleuNoneu_close(uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuclosesu_ConnectionBase.closeicCs|j|jt|}|jdkrDtt|}nt|}|dkrktdn||krtdn|dkr||}n:|dkrtdn|||krtdn|j||||dS(u,Send the bytes data from a bytes-like objectiiuoffset is negativeubuffer length < offsetusize is negativeubuffer length < offset + sizeN( u _check_closedu_check_writableu memoryviewuitemsizeubytesulenu ValueErroruNoneu _send_bytes(uselfubufuoffsetusizeumun((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu send_bytess"         u_ConnectionBase.send_bytescCsP|j|jtj}t|tjj||j|j dS(uSend a (picklable) objectN( u _check_closedu_check_writableuiouBytesIOuForkingPicklerupickleuHIGHEST_PROTOCOLudumpu _send_bytesu getbuffer(uselfuobjubuf((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyusends    u_ConnectionBase.sendcCsm|j|j|dk r;|dkr;tdn|j|}|dkrc|jn|jS(u7 Receive bytes data as a bytes object. iunegative maxlengthN(u _check_closedu_check_readableuNoneu ValueErroru _recv_bytesu_bad_message_lengthugetvalue(uselfu maxlengthubuf((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu recv_bytess    u_ConnectionBase.recv_bytesc Cs|j|jt|}|j}|t|}|dkrWtdn||krrtdn|j}|j}|||krt|j n|j d|j |||||||SWdQXdS(ur Receive bytes data into a writeable buffer-like object. Return the number of bytes read. iunegative offsetuoffset too largeN( u _check_closedu_check_readableu memoryviewuitemsizeulenu ValueErroru _recv_bytesutelluBufferTooShortugetvalueuseekureadinto(uselfubufuoffsetumuitemsizeubytesizeuresultusize((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyurecv_bytes_intos"        u_ConnectionBase.recv_bytes_intocCs3|j|j|j}tj|jS(uReceive a (picklable) object(u _check_closedu_check_readableu _recv_bytesupickleuloadsu getbuffer(uselfubuf((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyurecvs   u_ConnectionBase.recvgcCs!|j|j|j|S(u/Whether there is any input available to be read(u _check_closedu_check_readableu_poll(uselfutimeout((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyupolls  u_ConnectionBase.pollcCs|S(N((uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu __enter__su_ConnectionBase.__enter__cCs|jdS(N(uclose(uselfuexc_typeu exc_valueuexc_tb((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu__exit__su_ConnectionBase.__exit__NT(u__name__u __module__u __qualname__uNoneu_handleuTrueu__init__u__del__u _check_closedu_check_readableu_check_writableu_bad_message_lengthupropertyuclosedureadableuwritableufilenoucloseu send_bytesusendu recv_bytesurecv_bytes_intourecvupollu __enter__u__exit__(u __locals__((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_ConnectionBaseqs(           u_ConnectionBasecBse|EeZdZdZd ZejddZddZ d ddZ dd Z d d Z d S(uPipeConnectionu Connection class based on a Windows named pipe. Overlapped I/O is used, so the handles must have been created with FILE_FLAG_OVERLAPPED. cCs||jdS(N(u_handle(uselfu _CloseHandle((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_closesuPipeConnection._closecCstj|j|dd\}}z_yC|tjkrftj|jgdt}|t ksft nWn|j YnXWd|j d\}}X|dkst |t |kst dS(Nu overlappediTF(u_winapiu WriteFileu_handleuTrueuERROR_IO_PENDINGuWaitForMultipleObjectsueventuFalseuINFINITEu WAIT_OBJECT_0uAssertionErrorucanceluGetOverlappedResultulen(uselfubufuovuerruwaitresunwritten((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu _send_bytess!  uPipeConnection._send_bytesc Cs~|jrd|_tjS|dkr.dn t|d}ytj|j|dd\}}z_yC|tj krtj |j gdt }|tkstnWn|jYnXWd|jd\}}|dkrtj}|j|j|S|tjkr&|j||SXWnCtk rm}z#|jtjkrXtnWYdd}~XnXtddS(Niu overlappediu.shouldn't get here; expected KeyboardInterruptFT(u_got_empty_messageuFalseuiouBytesIOuNoneuminu_winapiuReadFileu_handleuTrueuERROR_IO_PENDINGuWaitForMultipleObjectsueventuINFINITEu WAIT_OBJECT_0uAssertionErrorucanceluGetOverlappedResultuwriteu getbufferuERROR_MORE_DATAu_get_more_datauIOErroruwinerroruERROR_BROKEN_PIPEuEOFErroru RuntimeError( uselfumaxsizeubsizeuovuerruwaitresunreadufue((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu _recv_bytes's6   !     uPipeConnection._recv_bytescCs?|js%tj|jddkr)dStt|g|S(NiT(u_got_empty_messageu_winapiu PeekNamedPipeu_handleuTrueubooluwait(uselfutimeout((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_pollGs uPipeConnection._pollcCs|j}tj}|j|tj|jd}|dksMt|dk r|t |||kr||j ntj |j|dd\}}|j d\}}|dkst||kst|j|j|S(Niiu overlappedT(u getbufferuiouBytesIOuwriteu_winapiu PeekNamedPipeu_handleuAssertionErroruNoneulenu_bad_message_lengthuReadFileuTrueuGetOverlappedResult(uselfuovumaxsizeubufufuleftuerrurbytes((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_get_more_dataMs   " !uPipeConnection._get_more_dataNF(u__name__u __module__u __qualname__u__doc__uFalseu_got_empty_messageu_winapiu CloseHandleu_closeu _send_bytesuNoneu _recv_bytesu_pollu_get_more_data(u __locals__((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuPipeConnection s  uPipeConnectioncBs|EeZdZdZerCejddZejZ ej Z n$e j ddZe jZ e jZ e ddZe ddZd d Zdd d Zd dZdS(u Connectionuo Connection class based on an arbitrary file descriptor (Unix only), or a socket handle (Windows). cCs||jdS(N(u_handle(uselfu_close((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_closedsuConnection._closecCs||jdS(N(u_handle(uselfu_close((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_closeisc Csnt|}x[y||j|}Wntk r<wYnX||8}|dkrWPn||d}qdS(Ni(ulenu_handleuInterruptedError(uselfubufuwriteu remainingun((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_sendns    uConnection._sendc Cstj}|j}|}x|dkry|||}Wntk rTwYnXt|}|dkr||krtqtdn|j|||8}qW|S(Niugot end of file during message(uiouBytesIOu_handleuInterruptedErrorulenuEOFErroruIOErroruwrite(uselfusizeureadubufuhandleu remaininguchunkun((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_recvzs         uConnection._recvcCst|}tjd|}|dkr9||g}n%|dkrU||g}n |g}x|D]}|j|qeWdS(Nu!ii@i(ulenustructupacku_send(uselfubufunuheaderuchunksuchunk((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu _send_bytess     uConnection._send_bytescCsS|jd}tjd|j\}|dk rF||krFdS|j|S(Niu!i(u_recvustructuunpackugetvalueuNone(uselfumaxsizeubufusize((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu _recv_bytess uConnection._recv_bytescCst|g|}t|S(N(uwaitubool(uselfutimeoutur((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_pollsuConnection._pollN(u__name__u __module__u __qualname__u__doc__u_winapiu_multiprocessingu closesocketu_closeusendu_writeurecvu_readuosucloseuwriteureadu_sendu_recvu _send_bytesuNoneu _recv_bytesu_poll(u __locals__((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu Connection]s      u ConnectioncBs|EeZdZdZddddddZddZddZed d Z ed d Z d d Z ddZ dS(uListeneru 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|}t||dkr[t|||_nt||||_|dk rt|t  rt dn||_ dS(NuAF_PIPEuauthkey should be a byte string( u address_typeudefault_familyuarbitrary_addressu_validate_familyu PipeListeneru _listeneruSocketListeneruNoneu isinstanceubytesu TypeErroru_authkey(uselfuaddressufamilyubackloguauthkey((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu__init__s  uListener.__init__cCs]|jdkrtdn|jj}|jrYt||jt||jn|S(uz Accept a connection on the bound socket or named pipe of `self`. Returns a `Connection` object. ulistener is closedN(u _listeneruNoneuIOErroruacceptu_authkeyudeliver_challengeuanswer_challenge(uselfuc((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuaccepts uListener.acceptcCs,|jdk r(|jjd|_ndS(uA Close the bound socket or named pipe of `self`. N(u _listeneruNoneuclose(uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyucloses uListener.closecCs |jjS(N(u _listeneru_address(uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyusuListener.cCs |jjS(N(u _listeneru_last_accepted(uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuscCs|S(N((uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu __enter__suListener.__enter__cCs|jdS(N(uclose(uselfuexc_typeu exc_valueuexc_tb((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu__exit__suListener.__exit__N( u__name__u __module__u __qualname__u__doc__uNoneu__init__uacceptucloseupropertyuaddressu last_acceptedu __enter__u__exit__(u __locals__((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuListeners   cCs|pt|}t||dkr7t|}n t|}|dk rnt|t rntdn|dk rt||t ||n|S(u= Returns a connection to the address of a `Listener` uAF_PIPEuauthkey should be a byte stringN( u address_typeu_validate_familyu PipeClientu SocketClientuNoneu isinstanceubytesu TypeErroruanswer_challengeudeliver_challenge(uaddressufamilyuauthkeyuc((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuClients     cCs|rYtj\}}|jd|jdt|j}t|j}n6tj\}}t|dd}t|dd}||fS(uL Returns pair of connection objects at either end of a pipe uwritableureadableTF( usocketu socketpairu setblockinguTrueu ConnectionudetachuosupipeuFalse(uduplexus1us2uc1uc2ufd1ufd2((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuPipes  c CsStd}|r;tj}tjtjB}tt}}ntj}tj}dt}}tj||tjBtj Btj tj Btj Bd||tj tj}tj||dtjtjtjtj}tj|tj ddtj|dd}|jd\} } | dks%tt|d|} t|d|} | | fS( uL Returns pair of connection objects at either end of a pipe uAF_PIPEiiu overlappeduwritableureadableNT(uarbitrary_addressu_winapiuPIPE_ACCESS_DUPLEXu GENERIC_READu GENERIC_WRITEuBUFSIZEuPIPE_ACCESS_INBOUNDuCreateNamedPipeuFILE_FLAG_OVERLAPPEDuFILE_FLAG_FIRST_PIPE_INSTANCEuPIPE_TYPE_MESSAGEuPIPE_READMODE_MESSAGEu PIPE_WAITuNMPWAIT_WAIT_FOREVERuNULLu CreateFileu OPEN_EXISTINGuSetNamedPipeHandleStateuNoneuConnectNamedPipeuTrueuGetOverlappedResultuAssertionErroruPipeConnection( uduplexuaddressuopenmodeuaccessuobsizeuibsizeuh1uh2u overlappedu_uerruc1uc2((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuPipes2       cBsA|EeZdZdZdddZddZddZd S( uSocketListeneruO Representation of a socket which is bound to an address and listening icCstjtt||_yttjdkrL|jjtjtjdn|jjd|jj ||jj ||jj |_ Wn"tk r|jjYnX||_d|_|dkrt|tjd|fdd|_n d|_dS(NuposixiuAF_UNIXuargsu exitpriorityiT(usocketugetattru_socketuosunameu setsockoptu SOL_SOCKETu SO_REUSEADDRu setblockinguTrueubindulistenu getsocknameu_addressuOSErrorucloseu_familyuNoneu_last_accepteduFinalizeuunlinku_unlink(uselfuaddressufamilyubacklog((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu__init__?s$     $uSocketListener.__init__c CsUx5y|jj\}|_Wntk r3YqXPq|jdt|jS(NT(u_socketuacceptu_last_accepteduInterruptedErroru setblockinguTrueu Connectionudetach(uselfus((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuacceptWs  uSocketListener.acceptcCs-|jj|jdk r)|jndS(N(u_socketucloseu_unlinkuNone(uself((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuclosebs uSocketListener.closeN(u__name__u __module__u __qualname__u__doc__u__init__uacceptuclose(u __locals__((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuSocketListener;s uSocketListenerc Cs[t|}tjtt|1}|jd|j|t|jSWdQXdS(uO Return a connection object connected to the socket given by `address` NT(u address_typeusocketugetattru setblockinguTrueuconnectu Connectionudetach(uaddressufamilyus((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu SocketClienths    u SocketClientcBsV|EeZdZdZd ddZd ddZddZe dd Z d S( u PipeListeneru0 Representation of a named pipe cCsk||_|jddg|_d|_td|jt|tj d|j|jfdd|_ dS(Nufirstu listener created with address=%ruargsu exitpriorityiT( u_addressu _new_handleuTrueu _handle_queueuNoneu_last_acceptedu sub_debuguFinalizeu PipeListeneru_finalize_pipe_listeneruclose(uselfuaddressubacklog((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu__init__|s   uPipeListener.__init__c CsetjtjB}|r&|tjO}ntj|j|tjtjBtjBtj t t tj tj S(N( u_winapiuPIPE_ACCESS_DUPLEXuFILE_FLAG_OVERLAPPEDuFILE_FLAG_FIRST_PIPE_INSTANCEuCreateNamedPipeu_addressuPIPE_TYPE_MESSAGEuPIPE_READMODE_MESSAGEu PIPE_WAITuPIPE_UNLIMITED_INSTANCESuBUFSIZEuNMPWAIT_WAIT_FOREVERuNULL(uselfufirstuflags((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu _new_handles   uPipeListener._new_handlecCs|jj|j|jjd}ytj|dd}Wn=tk r}z|jtj krnnWYdd}~XntXzHytj |j gdt }Wn"|jtj|YnXWd|jd\}}|dkstXt|S(Niu overlappedTF(u _handle_queueuappendu _new_handleupopu_winapiuConnectNamedPipeuTrueuOSErroruwinerroru ERROR_NO_DATAuWaitForMultipleObjectsueventuFalseuINFINITEucancelu CloseHandleuGetOverlappedResultuAssertionErroruPipeConnection(uselfuhandleuovueuresu_uerr((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuaccepts"   uPipeListener.acceptcCs/td|x|D]}tj|qWdS(Nu closing listener with address=%r(u sub_debugu_winapiu CloseHandle(uqueueuaddressuhandle((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_finalize_pipe_listeners  u$PipeListener._finalize_pipe_listenerNF( u__name__u __module__u __qualname__u__doc__uNoneu__init__uFalseu _new_handleuacceptu staticmethodu_finalize_pipe_listener(u __locals__((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu PipeListenerxs   u PipeListenercCst}xyKtj|dtj|tjtjBdtjtjtjtj}WnRt k r}z2|j tj tj fkst |rnWYdd}~Xq XPq tj|tjddt|S(uU Return a connection object connected to the pipe given by `address` iiN(u _init_timeoutu_winapiu WaitNamedPipeu CreateFileu GENERIC_READu GENERIC_WRITEuNULLu OPEN_EXISTINGuFILE_FLAG_OVERLAPPEDu WindowsErroruwinerroruERROR_SEM_TIMEOUTuERROR_PIPE_BUSYu_check_timeoutuSetNamedPipeHandleStateuPIPE_READMODE_MESSAGEuNoneuPipeConnection(uaddressutuhue((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu PipeClients"  u PipeClientis #CHALLENGE#s #WELCOME#s #FAILURE#cCsddl}t|ts!ttjt}|jt||j ||j }|j d}||kr|jt n|jt tddS(Niiudigest received was wrong(uhmacu isinstanceubytesuAssertionErroruosuurandomuMESSAGE_LENGTHu send_bytesu CHALLENGEunewudigestu recv_bytesuWELCOMEuFAILUREuAuthenticationError(u connectionuauthkeyuhmacumessageudigesturesponse((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyudeliver_challenges   udeliver_challengecCsddl}t|ts!t|jd}|dtttks\td||ttd}|j||j}|j ||jd}|t krt dndS(Niiu message = %rudigest sent was rejected( uhmacu isinstanceubytesuAssertionErroru recv_bytesulenu CHALLENGEunewudigestu send_bytesuWELCOMEuAuthenticationError(u connectionuauthkeyuhmacumessageudigesturesponse((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuanswer_challenges ,  uanswer_challengecBs8|EeZdZddZddZddZdS(uConnectionWrappercCsO||_||_||_x-dD]%}t||}t|||q"WdS(Nufilenoucloseupollu recv_bytesu send_bytes(ufilenoucloseupollu recv_bytesu send_bytes(u_connu_dumpsu_loadsugetattrusetattr(uselfuconnudumpsuloadsuattruobj((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu__init__s     uConnectionWrapper.__init__cCs#|j|}|jj|dS(N(u_dumpsu_connu send_bytes(uselfuobjus((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyusendsuConnectionWrapper.sendcCs|jj}|j|S(N(u_connu recv_bytesu_loads(uselfus((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyurecvsuConnectionWrapper.recvN(u__name__u __module__u __qualname__u__init__usendurecv(u __locals__((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuConnectionWrappers  uConnectionWrappercCs%tj|fddddjdS(Niuutf-8(u xmlrpclibudumpsuNoneuencode(uobj((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu _xml_dumpssu _xml_dumpscCs%tj|jd\\}}|S(Nuutf-8(u xmlrpclibuloadsudecode(usuobjumethod((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu _xml_loadss!u _xml_loadscBs |EeZdZddZdS(u XmlListenercCs.ddljatj|}t|ttS(Ni(u xmlrpc.clientuclientu xmlrpclibuListeneruacceptuConnectionWrapperu _xml_dumpsu _xml_loads(uselfuobj((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuaccept suXmlListener.acceptN(u__name__u __module__u __qualname__uaccept(u __locals__((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu XmlListenersu XmlListenercOs(ddljatt||ttS(Ni(u xmlrpc.clientuclientu xmlrpclibuConnectionWrapperuClientu _xml_dumpsu _xml_loads(uargsukwds((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu XmlClientsu XmlClientcCst|}g}x|rtj|d|}|tkr@Pnrt|koatt|knrs|t8}n?t|kott|knr|t8}n td|j ||||dd}d}qW|S(NuShould not get hereiiF( ulistu_winapiuWaitForMultipleObjectsuFalseu WAIT_TIMEOUTu WAIT_OBJECT_0ulenuWAIT_ABANDONED_0u RuntimeErroruappend(uhandlesutimeoutuLureadyures((u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu_exhaustive_waits   & &   u_exhaustive_waitc s|dkrt}n)|dkr*d}nt|dd}t|}ig}tt}zx|D]}yt|d}Wn"tk r||jrsuwait..cs"g|]}|kr|qS(((u.0uo(u ready_objects(u?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyu ss uwait..T(uNoneuINFINITEuintulistusetugetattruAttributeErroru __index__u_winapiuReadFileuTrueuOSErroruwinerroru _ready_errorsuERROR_IO_PENDINGuappendueventuaddu_exhaustive_waitukeysucanceluGetOverlappedResultuERROR_OPERATION_ABORTEDuhasattru_got_empty_messageuupdate( u object_listutimeoutuov_listu ready_handlesuoufilenouovuerrueu_((u ready_objectsuwaithandle_to_obju?/opt/alt/python33/lib64/python3.3/multiprocessing/connection.pyuwait0sZ         "             upollcCs|dk rt|d}ni}tj}xM|D]E}|j|tjt|drs|||j s            "         PS7*- 8     G