­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­ ­  wWS`c@sddddgZddlZddlZddlZddlZddlZddlZddlmZddl m Z m Z m Z m Z mZmZddlmZdd lmZmZmZmZdd lmZmZydd lmZWn!ek rdd lmZnXd Zejejegd ddfD]Z e!e"ie ^qDZ#de$fdYZ%fidZ&dZ'de(fdYZ)dZ*dZ+de$fdYZ,de$fdYZ-iej.ej/fd6ej0ej1fd6Z2de$fdYZ3de4fdYZ5de$fd YZ6d!Z7id"Z8e9e9e9e:d#Z;d$e$fd%YZ<d&e$fd'YZ=e:d(Z>d)e6fd*YZ?d+e6fd,YZ@d-e@fd.YZAd/e6fd0YZBd1e6fd2YZCd3e6fd4YZDe8d5d6d7d8d9d:d;d<d=d>d?d@dAdBdCdDdEdFdGdHdIdJdKfZEdLeEfdMYZFe8dNd7d8d:dOd<d@dPdQdRdSd ddGdTdUdVdfZGidWdO6eG_He8dXd<d:d@d;dAfZIe8dYdZd[d\d]d^d_d`dadbf ZJidcd[6dcda6dWd]6dWd^6eJ_Hde3fddYZKeKjdeejeKjdfejeKjdgejLeBeKjdhejMe@eKjdiejNe@eKjdjejOe@eKjdkejPe@eKjdlejQeAeKjdme eJeKjdneReFeKjdoeSeGeKjd&e=eDeKjdpe>eIeKjd$e<eCeKjdWdqe?dreTeKjdcdreTdS(st BaseManagert SyncManagert BaseProxytTokeniN(t format_exc(tProcesstcurrent_processtactive_childrentPooltutilt connection(tAuthenticationString(texittPopentassert_spawningtForkingPickler(tFinalizetinfo(t PicklingErrorcCstj|j|jffS(N(tarrayttypecodettostring(ta((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt reduce_array@stitemstkeystvaluescBs8eZdZdZdZdZdZdZRS( s4 Type to uniquely indentify a shared object ttypeidtaddresstidcCs!||||_|_|_dS(N(RRR(tselfRRR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt__init__PscCs|j|j|jfS(N(RRR(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt __getstate__SscCs|\|_|_|_dS(N(RRR(Rtstate((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt __setstate__VscCsd|j|j|jfS(Ns#Token(typeid=%r, address=%r, id=%r)(RRR(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt__repr__Ys(RRR(t__name__t __module__t__doc__t __slots__RR R"R#(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRJs    cCsN|j||||f|j\}}|dkr;|St||dS(sL Send a message to manager using connection `c` and return response s#RETURNN(tsendtrecvtconvert_to_error(tcRt methodnametargstkwdstkindtresult((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pytdispatchas  cCs~|dkr|S|dkr>t|tks4tt|S|dkrpt|tksbttd|StdSdS(Ns#ERRORs #TRACEBACKs#UNSERIALIZABLEsUnserializable message: %s sUnrecognized message type(ttypetstrtAssertionErrort RemoteErrort ValueError(R/R0((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR*ks    R5cBseZdZRS(cCs)ddddt|jdddS(Ns t-iKi(R3R-(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt__str__xs(R$R%R8(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR5wscCsOg}xBt|D]4}t||}t|dr|j|qqW|S(s4 Return a list of names of methods of `obj` t__call__(tdirtgetattrthasattrtappend(tobjttemptnametfunc((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt all_methodss cCs-gt|D]}|ddkr |^q S(sP Return a list of names of methods of `obj` which do not start with '_' it_(RB(R>R@((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pytpublic_methodsstServerc BseZdZddddddddd g Zd Zd Zd Zd ZdZdZ dZ ie d6e d6ed6Z dZ dZ dZdZdZdZdZdZdZRS(sM Server class which runs in a process controlled by a manager object tshutdowntcreatetaccept_connectiont get_methodst debug_infotnumber_of_objectstdummytincreftdecrefcCst|tst||_t||_t|\}}|d|dd|_|jj|_iddfd6|_ i|_ t j |_d|_dS(NRtbacklogit0i((t isinstancetbytesR4tregistryR tauthkeytlistener_clienttlistenerRtNonet id_to_objtid_to_refcountt threadingtRLocktmutextstop(RRSRRTt serializertListenertClient((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs  cCs|t_zylxey|jj}Wnttfk rDqnXtjd|jd|f}t |_ |j qWWnt t fk rnXWdd|_|jjXdS(s( Run the server forever ttargetR-Ni(Rt_manager_serverRVtaccepttOSErrortIOErrorRZtThreadthandle_requesttTruetdaemontstarttKeyboardInterruptt SystemExitR]tclose(RR+tt((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt serve_forevers   c Csd}}}yvtj||jtj||j|j}|\}}}}||jksttd|t||}Wn t k rdt f} nFXy||||}Wn t k rdt f} n Xd|f} y|j | Wnqt k rp} y|j dt fWnt k r<nXt j d| t j d|t j d| nX|jdS(s) Handle a new connection s%r unrecognizeds #TRACEBACKs#RETURNsFailure to send message: %rs ... request was %rs ... exception was %rN(RWR tdeliver_challengeRTtanswer_challengeR)tpublicR4R;t ExceptionRR(R RRm( RR+tfuncnameR0trequesttignoreR-R.RAtmsgte((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRgs4     cCstjdtjj|j}|j}|j}x|jsyd}}|}|\}}} } ||\}} } || krt d|t || fnt ||} y| | | }Wnt k r}d|f}npX| o| j|d}|rP|j|||\}}t||j|}d||ff}n d|f}Wnt k r|dkrdtf}q?y8|j|}|||||| | }d|f}Wq?t k rdtf}q?XnVtk rtjdtjjtjdn t k r>dtf}nXy;y||Wn&t k rx}|d tfnXWq7t k r}tjd tjjtjd |tjd ||jtjd q7Xq7WdS(sQ Handle requests from the proxies in a particular process/thread s$starting server thread to service %rs+method %r of %r object is not in exposed=%rs#ERRORs#PROXYs#RETURNs #TRACEBACKs$got EOF -- exiting thread serving %ris#UNSERIALIZABLEsexception in thread serving %rs ... message was %rs ... exception was %riN(R tdebugRZtcurrent_threadR@R)R(RXR]RWtAttributeErrorR2R;RstgetRGRRRtfallback_mappingtEOFErrortsysR RRm(RtconnR)R(RXR,R>RutidentR-R.texposedt gettypeidtfunctiontresRxRwRtridenttrexposedttokent fallback_funcR0((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt serve_clientsl                 cCs|S(N((RRRR>((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pytfallback_getvalue+scCs t|S(N(R3(RRRR>((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt fallback_str.scCs t|S(N(trepr(RRRR>((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt fallback_repr1sR8R#s #GETVALUEcCsdS(N((RR+((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRL:scCs|jjzg}|jj}|jxS|D]K}|dkr6|jd||j|t|j|dd fq6q6Wdj|SWd|jj XdS(sO Return some info --- useful to spot problems with refcounting RPs %s: refcount=%s %siiKs N( R\tacquireRXRtsortR=RYR3tjointrelease(RR+R0RR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRJ=s      'cCst|jdS(s* Number of shared objects i(tlenRX(RR+((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRKOscCszytjd|jd tjtjkrZtjdtjt_tjt_ntj dx(t D]}tjd|j qqWx(t D]}tjd|j qWtj tj dWnddl}|jnXWdtdXdS( s' Shutdown this process s!manager received shutdown messages#RETURNsresetting stdout, stderris&terminating a child process of managersmanager exiting with exitcode 0iN(s#RETURNN(R RyR(RWRtstdoutt __stdout__t __stderr__tstderrt_run_finalizersRt terminateRRt tracebackt print_excR (RR+tpR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRFUs*         c Os\|jjz:|j|\}}}}|dkrat|dkrN| sTt|d} n|||} |dkrt| }n|dk rt|tkstt |t |}ndt | } t j d|| | t ||f|j| <| |jkr&d|j| Create a new shared object and return its id iis%xs&%r callable returned object with id %rN(R\RRSRWRR4RDR2tdicttlistRR RytsetRXRYRMttupleR( RR+RR-R.tcallableRtmethod_to_typeidt proxytypeR>R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRGus(     cCst|j|jdS(sL Return the methods of the shared object indicated by token i(RRXR(RR+R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRIscCs-|tj_|jd|j|dS(s= Spawn a new thread to serve this connection s#RETURNN(s#RETURNN(RZRzR@R(RWR(RR+R@((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRHs cCs9|jjz|j|cd7 Connect manager object to the server process RTRLN( RURRRR1RWRRRR(RR_R`R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pytconnectsc Csg|jjtjkst|d k rFt|d rFtdntj dt \}}t dt |j d|j|j|j|j|||f|_djd|jjD}t |jd||j_|jj|j|j|_|jtj|j_tj|t |jd|j|j|j|j|jfd d |_d S( s@ Spawn a server process for this manager object R9sinitializer must be a callabletduplexRaR-t:css|]}t|VqdS(N(R3(t.0ti((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pys sR7t exitpriorityiN( RRRRR4RWR<t TypeErrorR tPipetFalseRR2t _run_serverRRRRt_processRt _identityR$R@RjRmR)RR Rt_finalize_managerRRF(Rt initializertinitargstreadertwriterR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRjs(   c Csl|dk r||n|j||||}|j|j|jtjd|j|jdS(s@ Create a server, report its address and run it smanager serving at %rN(RWt_ServerR(RRmR RRo( tclsRSRRTR^RRRtserver((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs   cOs|jjtjks!td|j|jd|j}z)t|dd|f||\}}Wd|j Xt ||j||fS(sP Create a new shared object; return the token and exposed tuple sserver not yet startedRTRGN( RRRRR4RRRR1RWRmR(RRR-R.RRR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt_create0s !) cCs|jj|dS(sC Join the manager process (if it has been spawned) N(RR(Rttimeout((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR<scCsA|j|jd|j}zt|ddSWd|jXdS(sS Return some info about the servers shared objects and connections RTRJN(RRRR1RWRm(RR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt _debug_infoBscCsA|j|jd|j}zt|ddSWd|jXdS(s5 Return the number of shared objects RTRKN(RRRR1RWRm(RR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt_number_of_objectsLscCs|S(N((R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt __enter__VscCs|jdS(N(RF(Rtexc_typetexc_valtexc_tb((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt__exit__YscCs|jrtjdy8||d|}zt|ddWd|jXWntk rdnX|jdd|jrtjdt|drtjd |j |jdd |jrtjd qqqnt j |_ yt j|=Wntk rnXdS( sQ Shutdown the manager process; will be registered as a finalizer s#sending shutdown message to managerRTRFNRg?smanager still aliveRs'trying to `terminate()` manager processg?s#manager still alive after terminate(tis_aliveR RR1RWRmRsRR<RRRRRt_address_to_localtKeyError(tprocessRRTR!RR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR\s.          cCs|jS(N(R(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt|tc s$d|jkr$|jj|_ndkr9tn|pNtdd}|pftdd}|rxa|jD]P\}}t|tkst d|t|tks|t d|q|Wn|||f|j<|r fd} | _ t || ndS(s9 Register a typeid with the manager type Rt _exposed_t_method_to_typeid_s%r is not a stringc stjd|j||\}}||jd|d|jd|}|j|jd|j}t|dd|j f|S(Ns)requesting creation of a shared %r objecttmanagerRTRRN( R RyRRRRRR1RWR(RR-R.RtexptproxyR(RR(s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR?sN( t__dict__RtcopyRWt AutoProxyR;RR2R3R4R$tsetattr( RRRRRRt create_methodtkeyRR?((RRs=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pytregister~s   ") N(((R$R%R&RRERRWRRRRRjt classmethodRRRRRRRt staticmethodRtpropertyRRhR(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs*   $     tProcessLocalSetcBseZdZdZRS(cCstj|ddS(NcSs |jS(N(tclear(R>((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRR(R tregister_after_fork(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRscCst|dfS(N((R2(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs(R$R%RR(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs cBseZdZiZejZd d d edZ dZ d idZ dZ dZ edZdZdZd Zd Zd ZRS(s. A base for proxies of shared objects cCs;tjjzPtjj|jd}|dkr\tjt f}|tj|js0x%x(R2R$RRR(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR#OscCs8y|jdSWn tk r3t|d dSXdS(sV Return representation of the referent (or a fall-back if that fails) R#is; '__str__()' failed>N(RRsR(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR8Ss N((R$R%R&RR tForkAwareThreadLockRRWRhRRRRRRRRRRR#R8(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs %      cCsttdd}|r?|j|jkr?|j|jdS|jdtodttdt }|||d||SdS(s Function used for unpickling proxy objects. If possible the shared object is returned, or otherwise a proxy for it. RbiRMt _inheritingN( R;RRWRRXRtpopRhR(RARR^R.RRM((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR`s cBse|}y|||fSWnek r1nXi}x |D]}d||f|Uq?We|ef|}||_||||f<|S(sB Return a proxy type whose methods are given by `exposed` sLdef %s(self, *args, **kwds): return self._callmethod(%r, args, kwds)(RRR2RR(R@Rt_cachetdictmetht ProxyType((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt MakeProxyTypeus    c Cst|d}|dkr\||jd|}zt|dd|f}Wd|jXn|dkr|dk r|j}n|dkrtj}ntd|j |}|||d|d|d|} t | _ | S(s* Return an auto-proxy for `token` iRTRINs AutoProxy[%s]RRM( RURWRR1RmRRRTR RRhR( RR^RRTRRMRRR R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs     t NamespacecBseZdZdZRS(cKs|jj|dS(N(Rtupdate(RR.((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRscCss|jj}g}x=|D]5\}}|jds|jd||fqqW|jdtjd|S(NRCs%s=%rs Namespace(%s)s, (RRt startswithR=RR3R(RRR?R@R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR#s (R$R%RR#(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s tValuecBs>eZedZdZdZdZeeeZRS(cCs||_||_dS(N(t _typecodet_value(RRRtlock((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs cCs|jS(N(R(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR|scCs ||_dS(N(R(RR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRscCs dt|j|j|jfS(Ns %s(%r, %r)(R2R$RR(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR#s( R$R%RhRR|RR#RR(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs     cCstj||S(N(R(RtsequenceR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pytArrayst IteratorProxycBsDeZd ZdZdZdZdZd Zd ZRS( t__next__tnextR(tthrowRmcCs|S(N((R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt__iter__scGs|jd|S(NR(R(RR-((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRscGs|jd|S(NR(R(RR-((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRscGs|jd|S(NR((R(RR-((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR(scGs|jd|S(NR(R(RR-((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRscGs|jd|S(NRm(R(RR-((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRms(RRR(RRm( R$R%RRRRR(RRm(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs     t AcquirerProxycBs5eZdZedZdZdZdZRS(RRcCs|jd|fS(NR(R(Rtblocking((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRscCs |jdS(NR(R(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRscCs |jdS(NR(R(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRscCs |jdS(NR(R(RRRR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs(RR(R$R%RRhRRRR(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs    tConditionProxycBs,eZdZd dZdZdZRS( RRtwaittnotifyt notify_allcCs|jd|fS(NR(R(RR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRscCs |jdS(NR(R(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRscCs |jdS(NR(R(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs(RRRRRN(R$R%RRWRRR(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs  t EventProxycBs5eZdZdZdZdZd dZRS( tis_setRRRcCs |jdS(NR!(R(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR!scCs |jdS(NR(R(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRscCs |jdS(NR(R(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRscCs|jd|fS(NR(R(RR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs(R!RRRN(R$R%RR!RRRWR(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR s    tNamespaceProxycBs)eZdZdZdZdZRS(t__getattribute__t __setattr__t __delattr__cCsB|ddkr tj||Stj|d}|d|fS(NiRCRR#(tobjectR#(RRt callmethod((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt __getattr__scCsH|ddkr#tj|||Stj|d}|d||fS(NiRCRR$(R&R$R#(RRRR'((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR$scCsB|ddkr tj||Stj|d}|d|fS(NiRCRR%(R&R%R#(RRR'((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR%s(R#R$R%(R$R%RR(R$R%(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR"s  t ValueProxycBs/eZdZdZdZeeeZRS(R|RcCs |jdS(NR|(R(R((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR|scCs|jd|fS(NR(R(RR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRs(R|R(R$R%RR|RRR(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR) s  t BaseListProxyt__add__t __contains__t __delitem__t __delslice__t __getitem__t __getslice__t__len__t__mul__t __reversed__t__rmul__t __setitem__t __setslice__R=tcounttextendtindextinsertRtremovetreverseRt__imul__t ListProxycBseZdZdZRS(cCs|jd|f|S(NR8(R(RR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt__iadd__scCs|jd|f|S(NR=(R(RR((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR= s(R$R%R?R=(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyR>s t DictProxyRRRR|thas_keytpopitemt setdefaultR tIteratort ArrayProxyt PoolProxytapplyt apply_asyncRmtimaptimap_unorderedRtmapt map_asyncRt AsyncResultcBseZdZRS(s( Subclass of `BaseManager` which supports a number of shared object types. The types registered are those intended for the synchronization of threads, plus `dict`, `list` and `Namespace`. The `multiprocessing.Manager()` function creates started instances of this class. (R$R%R&(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyRCs tQueuet JoinableQueuetEventtLockR[t SemaphoretBoundedSemaphoret ConditionRRRRRR(Ut__all__tosRtweakrefRZRRNRRtmultiprocessingRRRRR R tmultiprocessing.processR tmultiprocessing.forkingR R RRtmultiprocessing.utilRRtcPickleRt ImportErrorRRRR@R2R;t view_typesR&RR1R*RsR5RBRDRERR_R`t XmlListenert XmlClientRURRRRRR RWRhRR RRRRRR R"R)R*R>R@RRERFRRPRQR[RRRSRTRRR(((s=/opt/alt/python27/lib64/python2.7/multiprocessing/managers.pyt$s      ."  4  ,