ž §ÿfðŒc@sÚddddgZddlZddlZddlZddlZddlmZddlmZm Z m Z m Z m Z m Z ddlmZdd lmZmZdd lmZd d „Zejejeƒd d„dddfDƒZedek rMdd„Zx:eD]2ZejeeƒddlZejeeƒqWnGdd„deƒZfidd„Zdd„Z Gdd„de!ƒZ"dd„Z#dd„Z$Gdd „d eƒZ%Gd!d"„d"eƒZ&ie j'e j(fd#6e j)e j*fd$6Z+Gd%d„deƒZ,Gd&d'„d'e-ƒZ.Gd(d„deƒZ/d)d*„Z0id+d,„Z1e2e2e2e3d-d.„Z4Gd/d0„d0eƒZ5Gd1d2„d2eƒZ6e3d3d4„Z7Gd5d6„d6e/ƒZ8Gd7d8„d8e/ƒZ9Gd9d:„d:e9ƒZ:Gd;d<„d<e/ƒZ;Gd=d>„d>e/ƒZ<Gd?d@„d@e/ƒZ=GdAdB„dBe/ƒZ>e1dCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVfƒZ?GdWdX„dXe?ƒZ@e1dYdEdFdGdHdLdZd[d\d]dddRd^d_d`dfƒZAe1dadHdGdLfƒZBe1dbdcdddedfdgdhdidjdkdldmf ƒZCidndd6dndj6dndl6dodf6dodg6eC_DGdpd„de,ƒZEeEjdqejFƒeEjdrejFƒeEjdsejGe;ƒeEjdtejHe9ƒeEjduejIe9ƒeEjdvejJe9ƒeEjdwejKe9ƒeEjdxejLe:ƒeEjdyejMe<ƒeEjdze eCƒeEjd{ee@ƒeEjd|eNeAƒeEjd2e6e>ƒeEjd4e7eBƒeEjd0e5e=ƒeEjdod}e8d~eOƒeEjdnd~eOƒdS(u BaseManageru SyncManageru BaseProxyuTokeniN(u format_exc(uProcessucurrent_processuactive_childrenuPooluutilu connection(uAuthenticationString(uPopenuForkingPickler(utimecCstj|j|jƒffS(N(uarrayutypecodeutobytes(ua((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu reduce_array su reduce_arraycCs(g|]}tti|ƒƒƒ‘qS((utypeugetattr(u.0uname((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu $s u uitemsukeysuvaluescCstt|ƒffS(N(ulist(uobj((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyurebuild_as_list&surebuild_as_listcBsP|EeZdZdZdZdd„Zdd„Zd d „Zd d „Zd S(uTokenu4 Type to uniquely indentify a shared object utypeiduaddressuidcCs!||||_|_|_dS(N(utypeiduaddressuid(uselfutypeiduaddressuid((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__init__7suToken.__init__cCs|j|j|jfS(N(utypeiduaddressuid(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __getstate__:suToken.__getstate__cCs|\|_|_|_dS(N(utypeiduaddressuid(uselfustate((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __setstate__=suToken.__setstate__cCsd|j|j|jfS(Nu#Token(typeid=%r, address=%r, id=%r)(utypeiduaddressuid(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__repr__@suToken.__repr__N(utypeiduaddressuid( u__name__u __module__u __qualname__u__doc__u __slots__u__init__u __getstate__u __setstate__u__repr__(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuToken1s    cCsN|j||||fƒ|jƒ\}}|dkr;|St||ƒ‚dS(uL Send a message to manager using connection `c` and return response u#RETURNN(usendurecvuconvert_to_error(ucuidu methodnameuargsukwdsukinduresult((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyudispatchHs  udispatchcCs~|dkr|S|dkr>t|ƒtks4t‚t|ƒS|dkrpt|ƒtksbt‚td|ƒStdƒSdS(Nu#ERRORu #TRACEBACKu#UNSERIALIZABLEuUnserializable message: %s uUnrecognized message type(utypeustruAssertionErroru RemoteErroru ValueError(ukinduresult((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuconvert_to_errorRs    uconvert_to_errorcBs |EeZdZdd„ZdS(u RemoteErrorcCs)ddddt|jdƒddS(Nu u-iKi(ustruargs(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__str___suRemoteError.__str__N(u__name__u __module__u __qualname__u__str__(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu RemoteError^su RemoteErrorcCsLg}x?t|ƒD]1}t||ƒ}t|ƒr|j|ƒqqW|S(u4 Return a list of names of methods of `obj` (udirugetattrucallableuappend(uobjutempunameufunc((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu all_methodsfs  u all_methodscCsdd„t|ƒDƒS(uP Return a list of names of methods of `obj` which do not start with '_' cSs&g|]}|ddkr|‘qS(iu_((u.0uname((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu us u"public_methods..(u all_methods(uobj((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyupublic_methodsqsupublic_methodsc Bs"|EeZdZdZdddddddd d g Zd d „Zd d„Zdd„Zdd„Zdd„Z dd„Z dd„Z dd„Z ie d6e d6e d6Z dd„Zd d!„Zd"d#„Zd$d%„Zd&d'„Zd(d)„Zd*d+„Zd,d-„Zd.d/„Zd0S(1uServeruM Server class which runs in a process controlled by a manager object ushutdownucreateuaccept_connectionu get_methodsu debug_infounumber_of_objectsudummyuincrefudecrefcCs–t|tƒst‚||_t|ƒ|_t|\}}|d|ddƒ|_|jj|_idffd6|_ i|_ t j ƒ|_dS(Nuaddressubacklogiu0(u isinstanceubytesuAssertionErroruregistryuAuthenticationStringuauthkeyulistener_clientulisteneruaddressuNoneu id_to_objuid_to_refcountu threadinguRLockumutex(uselfuregistryuaddressuauthkeyu serializeruListeneruClient((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__init__‚s  uServer.__init__cCsÛtjƒ|_|tƒ_zqtjd|jƒ}d|_|j ƒy*x#|jj ƒsn|jj dƒqLWWnt t fk rŠYnXWdtjtjkrÉtjdƒtjt_tjt_ntjdƒXdS(u( Run the server forever utargetiNuresetting stdout, stderriT(u threadinguEventu stop_eventucurrent_processu_manager_serveruThreaduaccepteruTrueudaemonustartuis_setuwaituKeyboardInterruptu SystemExitusysustdoutu __stdout__uutiludebugu __stderr__ustderruexit(uselfuaccepter((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu serve_forevers       uServer.serve_foreverc Cslxey|jjƒ}Wnttfk r3wYnXtjd|jd|fƒ}d|_|j ƒqdS(NutargetuargsT( ulisteneruacceptuOSErroruIOErroru threadinguThreaduhandle_requestuTrueudaemonustart(uselfucut((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuaccepter¦s uServer.accepterc 'Cs”d}}}yvtj||jƒtj||jƒ|jƒ}|\}}}}||jksttd|ƒ‚t||ƒ}Wn!t k r§dt ƒf} YnGXy||||Ž}Wn!t k rádt ƒf} Yn Xd|f} y|j | ƒWn„t k r…} zdy|j dt ƒfƒWnt k rBYnXt j d| ƒt j d|ƒt j d| ƒWYdd} ~ XnX|jƒdS(u) Handle a new connection u%r unrecognizedu #TRACEBACKu#RETURNuFailure to send message: %ru ... request was %ru ... exception was %rN(uNoneu connectionudeliver_challengeuauthkeyuanswer_challengeurecvupublicuAssertionErrorugetattru Exceptionu format_excusenduutiluinfouclose( uselfucufuncnameuresulturequestuignoreuargsukwdsufuncumsgue((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuhandle_request°s4     #uServer.handle_requestc*Cs+tjdtjƒjƒ|j}|j}|j}xð|jj ƒs&y/d}}|ƒ}|\}}} } ||\}} } || kr¯t d|t |ƒ| fƒ‚nt ||ƒ} y| | | Ž}Wn1tk r}zd|f}WYdd}~XnpX| o| j|dƒ}|rh|j|||ƒ\}}t||j|ƒ}d||ff}n d|f}Wnãt k r|dkr£dtƒf}n\y8|j|}|||||| | Ž}d|f}Wn!tk rþdtƒf}YnXYnXtk r:tjdtjƒjƒtjd ƒYn!tk rZdtƒf}YnXyPy||ƒWn;tk r©}z|d t|ƒfƒWYdd}~XnXWq7tk r"}zUtjd tjƒjƒtjd |ƒtjd |ƒ|jƒtjdƒWYdd}~Xq7Xq7WdS(uQ Handle requests from the proxies in a particular process/thread u$starting server thread to service %ru+method %r of %r object is not in exposed=%ru#ERRORNu#PROXYu#RETURNu #TRACEBACKu$got EOF -- exiting thread serving %riu#UNSERIALIZABLEuexception in thread serving %ru ... message was %ru ... exception was %ri(uutiludebugu threadingucurrent_threadunameurecvusendu id_to_obju stop_eventuis_setuNoneuAttributeErrorutypeugetattru ExceptionugetucreateuTokenuaddressu format_excufallback_mappinguEOFErrorusysuexiturepruinfouclose(uselfuconnurecvusendu id_to_obju methodnameuobjurequestuidentuargsukwdsuexposedu gettypeidufunctionuresueumsgutypeiduridenturexposedutokenu fallback_funcuresult((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu serve_clientÒsl              -  uServer.serve_clientcCs|S(N((uselfuconnuidentuobj((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyufallback_getvaluesuServer.fallback_getvaluecCs t|ƒS(N(ustr(uselfuconnuidentuobj((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu fallback_strsuServer.fallback_strcCs t|ƒS(N(urepr(uselfuconnuidentuobj((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu fallback_repr"suServer.fallback_repru__str__u__repr__u #GETVALUEcCsdS(N((uselfuc((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyudummy+su Server.dummycCs´|jjƒz’g}t|jjƒƒ}|jƒxY|D]Q}|dkr<|jd||j|t|j|dƒdd…fƒq<q<Wdj |ƒSWd|jj ƒXdS(uO Return some info --- useful to spot problems with refcounting u0u %s: refcount=%s %siNiKu ( umutexuacquireulistu id_to_objukeysusortuappenduid_to_refcountustrujoinurelease(uselfucuresultukeysuident((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu debug_info.s      -uServer.debug_infocCst|jƒdS(u* Number of shared objects i(ulenu id_to_obj(uselfuc((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyunumber_of_objects@suServer.number_of_objectscCsXzCytjdƒ|jdƒWnddl}|jƒYnXWd|jjƒXdS(u' Shutdown this process u!manager received shutdown messageu#RETURNiN(u#RETURNN(uutiludebugusenduNoneu tracebacku print_excu stop_eventuset(uselfucu traceback((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyushutdownFs  uServer.shutdownc Os\|jjƒz:|j|\}}}}|dkrat|ƒdkrN| sTt‚|d} n|||Ž} |dkr‹t| ƒ}n|dk rÈt|ƒtks¯t‚t |ƒt |ƒ}ndt | ƒ} t j d|| ƒ| t |ƒ|f|j| <| |jkr&d|j| Create a new shared object and return its id iiu%xu&%r callable returned object with id %rN(umutexuacquireuregistryuNoneulenuAssertionErrorupublic_methodsutypeudictulistuiduutiludebugusetu id_to_objuid_to_refcountuincrefutupleurelease( uselfucutypeiduargsukwdsucallableuexposedumethod_to_typeidu proxytypeuobjuident((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyucreateSs(     u Server.createcCst|j|jdƒS(uL Return the methods of the shared object indicated by token i(utupleu id_to_objuid(uselfucutoken((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu get_methodsysuServer.get_methodscCs-|tjƒ_|jdƒ|j|ƒdS(u= Spawn a new thread to serve this connection u#RETURNN(u#RETURNN(u threadingucurrent_threadunameusenduNoneu serve_client(uselfucuname((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuaccept_connections uServer.accept_connectionc Cs7|jjƒz|j|d7 Connect manager object to the server process uauthkeyudummyN( ulistener_clientu _serializeru_addressu_authkeyudispatchuNoneuStateuSTARTEDu_stateuvalue(uselfuListeneruClientuconn((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuconnectÉsuBaseManager.connectc Csg|jjtjkst‚|d k rCt|ƒ rCtdƒ‚ntj dd ƒ\}}t dt |ƒj d|j|j|j|j|||fƒ|_djdd„|jjDƒƒ}t |ƒjd||j_|jjƒ|jƒ|jƒ|_|jƒtj|j_tj|t |ƒjd|j|j|j|j|jfd d ƒ|_d S( u@ Spawn a server process for this manager object uinitializer must be a callableuduplexutargetuargsu:css|]}t|ƒVqdS(N(ustr(u.0ui((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu äsu$BaseManager.start..u-u exitpriorityiNF( u_stateuvalueuStateuINITIALuAssertionErroruNoneucallableu TypeErroru connectionuPipeuFalseuProcessutypeu _run_serveru _registryu_addressu_authkeyu _serializeru_processujoinu _identityu__name__unameustartucloseurecvuSTARTEDuutiluFinalizeu_finalize_manageru_Clientushutdown(uselfu initializeruinitargsureaderuwriteruident((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyustartÒs("   uBaseManager.startc Csl|dk r||Œn|j||||ƒ}|j|jƒ|jƒtjd|jƒ|jƒdS(u@ Create a server, report its address and run it umanager serving at %rN(uNoneu_Serverusenduaddressucloseuutiluinfou serve_forever( uclsuregistryuaddressuauthkeyu serializeruwriteru initializeruinitargsuserver((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu _run_serverös   uBaseManager._run_serverc OsŒ|jjtjks!tdƒ‚|j|jd|jƒ}z)t|dd|f||ƒ\}}Wd|j ƒXt ||j|ƒ|fS(uP Create a new shared object; return the token and exposed tuple userver not yet starteduauthkeyucreateN( u_stateuvalueuStateuSTARTEDuAssertionErroru_Clientu_addressu_authkeyudispatchuNoneucloseuToken(uselfutypeiduargsukwdsuconnuiduexposed((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu_create s !) uBaseManager._createcCsA|jdk r=|jj|ƒ|jjƒs=d|_q=ndS(uC Join the manager process (if it has been spawned) N(u_processuNoneujoinuis_alive(uselfutimeout((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyujoinsuBaseManager.joinc CsA|j|jd|jƒ}zt|ddƒSWd|jƒXdS(uS Return some info about the servers shared objects and connections uauthkeyu debug_infoN(u_Clientu_addressu_authkeyudispatchuNoneuclose(uselfuconn((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu _debug_infosuBaseManager._debug_infoc CsA|j|jd|jƒ}zt|ddƒSWd|jƒXdS(u5 Return the number of shared objects uauthkeyunumber_of_objectsN(u_Clientu_addressu_authkeyudispatchuNoneuclose(uselfuconn((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu_number_of_objects)suBaseManager._number_of_objectscCsA|jjtjkr"|jƒn|jjtjks=t‚|S(N(u_stateuvalueuStateuINITIALustartuSTARTEDuAssertionError(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __enter__3s uBaseManager.__enter__cCs|jƒdS(N(ushutdown(uselfuexc_typeuexc_valuexc_tb((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__exit__9suBaseManager.__exit__cCs|jƒrêtjdƒy8||d|ƒ}zt|ddƒWd|jƒXWntk reYnX|jddƒ|jƒrêtjdƒt|dƒrçtjd ƒ|j ƒ|jdd ƒ|jƒrätjd ƒqäqçqênt j |_ yt j|=Wntk rYnXdS( uQ Shutdown the manager process; will be registered as a finalizer u#sending shutdown message to manageruauthkeyushutdownNutimeoutgð?umanager still aliveu terminateu'trying to `terminate()` manager processgš™™™™™¹?u#manager still alive after terminate(uis_aliveuutiluinfoudispatchuNoneucloseu Exceptionujoinuhasattru terminateuStateuSHUTDOWNuvalueu BaseProxyu_address_to_localuKeyError(uprocessuaddressuauthkeyustateu_Clientuconn((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu_finalize_manager<s.          uBaseManager._finalize_managercCs|jS(N(u_address(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu\suBaseManager.c s-d|jkr$|jjƒ|_nˆdkr9t‰n|pNtˆddƒ}|pftˆddƒ}|rÙxgt|jƒƒD]P\}}t|ƒt ks°t d|ƒ‚t|ƒt ks‚t d|ƒ‚q‚Wn|||ˆf|jˆ<|r)‡‡fdd†} ˆ| _ t |ˆ| ƒndS(u9 Register a typeid with the manager type u _registryu _exposed_u_method_to_typeid_u%r is not a stringc sŠtjdˆƒ|jˆ||Ž\}}ˆ||jd|d|jd|ƒ}|j|jd|jƒ}t|dd|j fƒ|S(Nu)requesting creation of a shared %r objectumanageruauthkeyuexposedudecref( uutiludebugu_createu _serializeru_authkeyu_ClientuaddressudispatchuNoneuid(uselfuargsukwdsutokenuexpuproxyuconn(u proxytypeutypeid(u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyutempysu"BaseManager.register..tempN( u__dict__u _registryucopyuNoneu AutoProxyugetattrulistuitemsutypeustruAssertionErroru__name__usetattr( uclsutypeiducallableu proxytypeuexposedumethod_to_typeidu create_methodukeyuvalueutemp((u proxytypeutypeidu=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuregister^s   ") uBaseManager.registerNT(u__name__u __module__u __qualname__u__doc__u _registryuServeru_ServeruNoneu__init__u get_serveruconnectustartu classmethodu _run_serveru_createujoinu _debug_infou_number_of_objectsu __enter__u__exit__u staticmethodu_finalize_managerupropertyuaddressuTrueuregister(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu BaseManager°s(  $     cBs,|EeZdZdd„Zdd„ZdS(uProcessLocalSetcCstj|dd„ƒdS(NcSs |jƒS(N(uclear(uobj((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuŒsu*ProcessLocalSet.__init__..(uutiluregister_after_fork(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__init__‹suProcessLocalSet.__init__cCst|ƒffS(N(utype(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __reduce__suProcessLocalSet.__reduce__N(u__name__u __module__u __qualname__u__init__u __reduce__(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuProcessLocalSetŠs uProcessLocalSetcBsÈ|EeZdZdZiZejƒZdddddd„Z dd„Z fidd„Z dd „Z d d „Zed d „ƒZdd„Zdd„Zdd„Zdd„Zdd„ZdS(u BaseProxyu. A base for proxies of shared objects c Cs;tjjƒzPtjj|jdƒ}|dkr\tjƒt ƒf}|tj|ju0x%x(utypeu__name__u_tokenutypeiduid(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__repr__/suBaseProxy.__repr__c CsBy|jdƒSWn*tk r=t|ƒdd…dSYnXdS(uV Return representation of the referent (or a fall-back if that fails) u__repr__Niu; '__str__()' failed>iÿÿÿÿ(u _callmethodu Exceptionurepr(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__str__3s uBaseProxy.__str__NT(u__name__u __module__u __qualname__u__doc__u_address_to_localuutiluForkAwareThreadLocku_mutexuNoneuTrueu__init__u_connectu _callmethodu _getvalueu_increfu staticmethodu_decrefu _after_forku __reduce__u __deepcopy__u__repr__u__str__(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu BaseProxy”s %      cCsttƒddƒ}|r?|j|jkr?|j|jdS|jddƒodttƒddƒ }|||d||SdS(u‚ Function used for unpickling proxy objects. If possible the shared object is returned, or otherwise a proxy for it. u_manager_serveriuincrefu _inheritingNTF( ugetattrucurrent_processuNoneuaddressu id_to_objuidupopuTrueuFalse(ufuncutokenu serializerukwdsuserveruincref((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu RebuildProxy@s u RebuildProxyc Cs“t|ƒ}y|||fSWntk r2YnXi}x%|D]}td||f|ƒq@Wt|tf|ƒ}||_||||f<|S(uC Return an proxy type whose methods are given by `exposed` uLdef %s(self, *args, **kwds): return self._callmethod(%r, args, kwds)(utupleuKeyErroruexecutypeu BaseProxyu _exposed_(unameuexposedu_cacheudicumethu ProxyType((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu MakeProxyTypeUs    u MakeProxyTypec Csßt|d}|dkr\||jd|ƒ}zt|dd|fƒ}Wd|jƒXn|dkr€|dk r€|j}n|dkr›tƒj}ntd|j |ƒ}|||d|d|d|ƒ} d| _ | S( u* Return an auto-proxy for `token` iuauthkeyu get_methodsNu AutoProxy[%s]umanageruincrefT( ulistener_clientuNoneuaddressudispatchucloseu_authkeyucurrent_processuauthkeyu MakeProxyTypeutypeiduTrueu_isauto( utokenu serializerumanageruauthkeyuexposeduincrefu_Clientuconnu ProxyTypeuproxy((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu AutoProxyks     u AutoProxycBs,|EeZdZdd„Zdd„ZdS(u NamespacecKs|jj|ƒdS(N(u__dict__uupdate(uselfukwds((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__init__‰suNamespace.__init__cCsyt|jjƒƒ}g}x=|D]5\}}|jdƒs"|jd||fƒq"q"W|jƒdtjd|ƒS(Nu_u%s=%ru Namespace(%s)u, (ulistu__dict__uitemsu startswithuappendusortustrujoin(uselfuitemsutempunameuvalue((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__repr__‹s uNamespace.__repr__N(u__name__u __module__u __qualname__u__init__u__repr__(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu Namespaceˆs u NamespacecBsV|EeZdZd dd„Zdd„Zdd„Zdd„ZeeeƒZ d S( uValuecCs||_||_dS(N(u _typecodeu_value(uselfutypecodeuvalueulock((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__init__•s uValue.__init__cCs|jS(N(u_value(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuget˜su Value.getcCs ||_dS(N(u_value(uselfuvalue((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyusetšsu Value.setcCs dt|ƒj|j|jfS(Nu %s(%r, %r)(utypeu__name__u _typecodeu_value(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__repr__œsuValue.__repr__NT( u__name__u __module__u __qualname__uTrueu__init__ugetusetu__repr__upropertyuvalue(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuValue”s    uValuecCstj||ƒS(N(uarray(utypecodeusequenceulock((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuArray suArraycBsV|EeZdZdZdd„Zdd„Zd d „Zd d „Zd d„ZdS(u IteratorProxyu__next__usenduthrowuclosecCs|S(N((uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__iter__©suIteratorProxy.__iter__cGs|jd|ƒS(Nu__next__(u _callmethod(uselfuargs((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__next__«suIteratorProxy.__next__cGs|jd|ƒS(Nusend(u _callmethod(uselfuargs((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyusend­suIteratorProxy.sendcGs|jd|ƒS(Nuthrow(u _callmethod(uselfuargs((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuthrow¯suIteratorProxy.throwcGs|jd|ƒS(Nuclose(u _callmethod(uselfuargs((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuclose±suIteratorProxy.closeN(u__next__usenduthrowuclose( u__name__u __module__u __qualname__u _exposed_u__iter__u__next__usenduthrowuclose(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu IteratorProxy§s     u IteratorProxycBsP|EeZdZd Zd d dd„Zdd„Zdd„Zd d „Z d S(u AcquirerProxyuacquireureleasecCs1|dkr|fn ||f}|jd|ƒS(Nuacquire(uNoneu _callmethod(uselfublockingutimeoutuargs((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuacquire·s!uAcquirerProxy.acquirecCs |jdƒS(Nurelease(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyureleaseºsuAcquirerProxy.releasecCs |jdƒS(Nuacquire(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __enter__¼suAcquirerProxy.__enter__cCs |jdƒS(Nurelease(u _callmethod(uselfuexc_typeuexc_valuexc_tb((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__exit__¾suAcquirerProxy.__exit__N(uacquireureleaseT( u__name__u __module__u __qualname__u _exposed_uTrueuNoneuacquireureleaseu __enter__u__exit__(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu AcquirerProxyµs   u AcquirerProxycBsP|EeZdZdZddd„Zdd „Zd d „Zdd d „ZdS(uConditionProxyuacquireureleaseuwaitunotifyu notify_allcCs|jd|fƒS(Nuwait(u _callmethod(uselfutimeout((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuwaitÄsuConditionProxy.waitcCs |jdƒS(Nunotify(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyunotifyÆsuConditionProxy.notifycCs |jdƒS(Nu notify_all(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu notify_allÈsuConditionProxy.notify_allcCsŽ|ƒ}|r|S|dk r/tƒ|}n d}d}xL|s‰|dk rp|tƒ}|dkrpPqpn|j|ƒ|ƒ}q>W|S(Ni(uNoneu_timeuwait(uselfu predicateutimeouturesultuendtimeuwaittime((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuwait_forÊs        uConditionProxy.wait_forN(uacquireureleaseuwaitunotifyu notify_all( u__name__u __module__u __qualname__u _exposed_uNoneuwaitunotifyu notify_alluwait_for(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuConditionProxyÂs   uConditionProxycBsM|EeZdZdZdd„Zdd„Zd d „Zd d d „Zd S(u EventProxyuis_setusetuclearuwaitcCs |jdƒS(Nuis_set(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuis_setßsuEventProxy.is_setcCs |jdƒS(Nuset(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyusetásuEventProxy.setcCs |jdƒS(Nuclear(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuclearãsuEventProxy.clearcCs|jd|fƒS(Nuwait(u _callmethod(uselfutimeout((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuwaitåsuEventProxy.waitN(uis_setusetuclearuwait( u__name__u __module__u __qualname__u _exposed_uis_setusetuclearuNoneuwait(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu EventProxyÝs    u EventProxycBsw|EeZdZdZddd„Zdd„Zd d „Zed d „ƒZ ed d„ƒZ edd„ƒZ dS(u BarrierProxyu__getattribute__uwaituaborturesetcCs|jd|fƒS(Nuwait(u _callmethod(uselfutimeout((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuwaitësuBarrierProxy.waitcCs |jdƒS(Nuabort(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuabortísuBarrierProxy.abortcCs |jdƒS(Nureset(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuresetïsuBarrierProxy.resetcCs|jddƒS(Nu__getattribute__uparties(uparties(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyupartiesñsuBarrierProxy.partiescCs|jddƒS(Nu__getattribute__u n_waiting(u n_waiting(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu n_waitingôsuBarrierProxy.n_waitingcCs|jddƒS(Nu__getattribute__ubroken(ubroken(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyubroken÷suBarrierProxy.brokenN(u__getattribute__uwaituabortureset( u__name__u __module__u __qualname__u _exposed_uNoneuwaituaborturesetupropertyupartiesu n_waitingubroken(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu BarrierProxyés  u BarrierProxycBs>|EeZdZd Zdd„Zdd„Zdd „Zd S( uNamespaceProxyu__getattribute__u __setattr__u __delattr__cCsB|ddkr tj||ƒStj|dƒ}|d|fƒS(Niu_u _callmethodu__getattribute__(uobjectu__getattribute__(uselfukeyu callmethod((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __getattr__þsuNamespaceProxy.__getattr__cCsH|ddkr#tj|||ƒStj|dƒ}|d||fƒS(Niu_u _callmethodu __setattr__(uobjectu __setattr__u__getattribute__(uselfukeyuvalueu callmethod((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __setattr__suNamespaceProxy.__setattr__cCsB|ddkr tj||ƒStj|dƒ}|d|fƒS(Niu_u _callmethodu __delattr__(uobjectu __delattr__u__getattribute__(uselfukeyu callmethod((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __delattr__suNamespaceProxy.__delattr__N(u__getattribute__u __setattr__u __delattr__(u__name__u __module__u __qualname__u _exposed_u __getattr__u __setattr__u __delattr__(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuNamespaceProxyüs  uNamespaceProxycBsA|EeZdZdZdd„Zdd„ZeeeƒZdS( u ValueProxyugetusetcCs |jdƒS(Nuget(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyugetsuValueProxy.getcCs|jd|fƒS(Nuset(u _callmethod(uselfuvalue((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyusetsuValueProxy.setN(ugetuset(u__name__u __module__u __qualname__u _exposed_ugetusetupropertyuvalue(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu ValueProxys  u ValueProxyu BaseListProxyu__add__u __contains__u __delitem__u __getitem__u__len__u__mul__u __reversed__u__rmul__u __setitem__uappenducountuextenduindexuinsertupopuremoveureverseusortu__imul__cBs,|EeZdZdd„Zdd„ZdS(u ListProxycCs|jd|fƒ|S(Nuextend(u _callmethod(uselfuvalue((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__iadd__suListProxy.__iadd__cCs|jd|fƒ|S(Nu__imul__(u _callmethod(uselfuvalue((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__imul__"suListProxy.__imul__N(u__name__u __module__u __qualname__u__iadd__u__imul__(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu ListProxys u ListProxyu DictProxyuclearucopyugetuhas_keyupopitemu setdefaultuupdateu ArrayProxyu PoolProxyuapplyu apply_asyncucloseuimapuimap_unorderedujoinumapu map_asyncustarmapu starmap_asyncu terminateu AsyncResultuIteratorcBs|EeZdZdZdS(u SyncManageru( 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. N(u__name__u __module__u __qualname__u__doc__(u __locals__((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu SyncManagerCs uQueueu JoinableQueueuEventuLockuRLocku SemaphoreuBoundedSemaphoreu ConditionuBarrieruPoolulistudictu proxytypeu create_method(Pu__all__usysu threadinguarrayuqueueu tracebacku format_excumultiprocessinguProcessucurrent_processuactive_childrenuPooluutilu connectionumultiprocessing.processuAuthenticationStringumultiprocessing.forkinguPopenuForkingPicklerutimeu_timeu reduce_arrayuregisteru view_typesulisturebuild_as_listu view_typeucopyregupickleuobjectuTokenudispatchuconvert_to_erroru Exceptionu RemoteErroru all_methodsupublic_methodsuServeruStateuListeneruClientu XmlListeneru XmlClientulistener_clientu BaseManagerusetuProcessLocalSetu BaseProxyu RebuildProxyu MakeProxyTypeuNoneuTrueu AutoProxyu NamespaceuValueuArrayu IteratorProxyu AcquirerProxyuConditionProxyu EventProxyu BarrierProxyuNamespaceProxyu ValueProxyu BaseListProxyu ListProxyu DictProxyu ArrayProxyu PoolProxyu_method_to_typeid_u SyncManageruQueueuEventuLockuRLocku SemaphoreuBoundedSemaphoreu ConditionuBarrierudictuFalse(((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu s®    .      ÿ# Ú ¬