£Á°è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ã !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! fc@sddddgZddlZddlZddlZddlZddlmZddlmZm Z m Z m Z m Z m Z ddlmZdd lmZmZdd lmZd d Zejejed ddddfDZedek rMddZx:eD]2ZejeeddlZejeeqWnGdddeZfiddZddZ Gddde!Z"ddZ#ddZ$Gdd d eZ%Gd!d"d"eZ&ie j'e j(fd#6e j)e j*fd$6Z+Gd%ddeZ,Gd&d'd'e-Z.Gd(ddeZ/d)d*Z0id+d,Z1e2e2e2e3d-d.Z4Gd/d0d0eZ5Gd1d2d2eZ6e3d3d4Z7Gd5d6d6e/Z8Gd7d8d8e/Z9Gd9d:d:e9Z:Gd;d<d<e/Z;Gd=d>d>e/Z<Gd?d@d@e/Z=GdAdBdBe/Z>e1dCdDdEdFdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVfZ?GdWdXdXe?Z@e1dYdEdFdGdHdLdZd[d\d]dddRd^d_d`dfZAe1dadHdGdLfZBe1dbdcdddedfdgdhdidjdkdldmf ZCidndd6dndj6dndl6dodf6dodg6eC_DGdpdde,ZEeEjdqejFeEjdrejFeEjdsejGe;eEjdtejHe9eEjduejIe9eEjdvejJe9eEjdwejKe9eEjdxejLe:eEjdyejMe<eEjdze eCeEjd{ee@eEjd|eNeAeEjd2e6e>eEjd4e7eBeEjd0e5e=eEjdod}e8d~eOeEjdnd~eOdS(u BaseManageru SyncManageru BaseProxyuTokeniN(u format_exc(uProcessucurrent_processuactive_childrenuPooluutilu connection(uAuthenticationString(uPopenuForkingPickler(utimecCstj|j|jffS(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|EeZdZdZdZddZddZd 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  udispatchcCsN|dkr|S|dkr&t|S|dkr@td|StdSdS(Nu#ERRORu #TRACEBACKu#UNSERIALIZABLEuUnserializable message: %s uUnrecognized message type(u RemoteErroru ValueError(ukinduresult((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuconvert_to_errorRs    uconvert_to_errorcBs |EeZdZddZdS(u RemoteErrorcCs)ddddt|jdddS(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_methodscCsddt|DS(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 dZddZddZddZ ddZ ddZ ddZ ie d6e d6e d6Z ddZd 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|\}}|d|dd|_|jj|_idffd6|_i|_t j |_ dS(Nuaddressubacklogiu0( uregistryuAuthenticationStringuauthkeyulistener_clientulisteneruaddressuNoneu id_to_objuid_to_refcountu threadinguRLockumutex(uselfuregistryuaddressuauthkeyu serializeruListeneruClient((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__init__s  uServer.__init__cCstj|_|t_zqtjd|j}d|_|j y*x#|jj sn|jj dqLWWnt t fk rYnXWdtjtjkrtjdtjt_tjt_ntjdXdS(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.pyuaccepters uServer.accepterc 'Csud}}}yWtj||jtj||j|j}|\}}}}t||}Wn!tk rdtf} YnGXy||||}Wn!tk rdtf} Yn Xd|f} y|j | Wntk rf} zdy|j dtfWntk r#YnXt j d| t j d|t j d| WYdd} ~ XnX|j dS(u) Handle a new connection u #TRACEBACKu#RETURNuFailure to send message: %ru ... request was %ru ... exception was %rN( uNoneu connectionudeliver_challengeuauthkeyuanswer_challengeurecvugetattru Exceptionu format_excusenduutiluinfouclose( uselfucufuncnameuresulturequestuignoreuargsukwdsufuncumsgue((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuhandle_requests2     #uServer.handle_requestc*Cs+tjdtjj|j}|j}|j}x|jj s&y/d}}|}|\}}} } ||\}} } || krt d|t || fnt ||} y| | | }Wn1tk r}zd|f}WYdd}~XnpX| o| j|d}|rh|j|||\}}t||j|}d||ff}n d|f}Wnt k r|dkrdtf}n\y8|j|}|||||| | }d|f}Wn!tk rdtf}YnXYnXtk r:tjdtjjtjd Yn!tk rZdtf}YnXyPy||Wn;tk r}z|d t|fWYdd}~XnXWq7tk r"}zUtjd tjjtjd |tjd ||jtjdWYdd}~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_clientsl              -  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|jjzg}t|jj}|jxY|D]Q}|dkr<|jd||j|t|j|dddfq<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|jdS(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|jdWnddl}|jYnXWd|jjXdS(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%|jjz|j|\}}}}|dkrB|d} n|||} |dkrlt| }n|dk rt|t|}ndt| } tjd|| | t ||f|j | <| |j krd|j | Create a new shared object and return its id iu%xu&%r callable returned object with id %rN(umutexuacquireuregistryuNoneupublic_methodsulistuiduutiludebugusetu id_to_objuid_to_refcountuincrefutupleurelease( uselfucutypeiduargsukwdsucallableuexposedumethod_to_typeidu proxytypeuobjuident((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyucreateSs$     u Server.createcCst|j|jdS(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|jjz|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.pyuconnectsuBaseManager.connectc CsL|d k r(t| r(tdntjdd \}}tdt|jd|j |j |j |j |||f|_ djdd|j jD}t|jd||j _|j j|j|j|_ |jtj|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(uNoneucallableu TypeErroru connectionuPipeuFalseuProcessutypeu _run_serveru _registryu_addressu_authkeyu _serializeru_processujoinu _identityu__name__unameustartucloseurecvuStateuSTARTEDu_stateuvalueuutiluFinalizeu_finalize_manageru_Clientushutdown(uselfu initializeruinitargsureaderuwriteruident((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyustarts&"   uBaseManager.startc Csl|dk r||n|j||||}|j|j|jtjd|j|jdS(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_servers   uBaseManager._run_serverc Osk|j|jd|j}z)t|dd|f||\}}Wd|jXt||j||fS(uP Create a new shared object; return the token and exposed tuple uauthkeyucreateN(u_Clientu_addressu_authkeyudispatchuNoneucloseuToken(uselfutypeiduargsukwdsuconnuiduexposed((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu_create s ) uBaseManager._createcCsA|jdk r=|jj||jjs=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|ddSWd|jXdS(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|ddSWd|jXdS(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_objectscCs&|jjtjkr"|jn|S(N(u_stateuvalueuStateuINITIALustart(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __enter__3s uBaseManager.__enter__cCs|jdS(N(ushutdown(uselfuexc_typeuexc_valuexc_tb((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__exit__9suBaseManager.__exit__cCs|jrtjdy8||d|}zt|ddWd|jXWntk reYnX|jdd|jrtjdt|drtjd |j |jdd |jrtjd qqqnt 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 sd|jkr$|jj|_ndkr9tn|pNtdd}|pftdd}|rx#t|jD] \}}qWn|||f|j<|rfdd} | _t || ndS(u9 Register a typeid with the manager type u _registryu _exposed_u_method_to_typeid_c stjd|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 AutoProxyugetattrulistuitemsu__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 BaseManagers(  $     cBs,|EeZdZddZddZdS(uProcessLocalSetcCstj|dddS(NcSs |jS(N(uclear(uobj((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyusu*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.pyuProcessLocalSets uProcessLocalSetcBs|EeZdZdZiZejZddddddZ ddZ fiddZ dd Z d d Zed d ZddZddZddZddZddZdS(u BaseProxyu. A base for proxies of shared objects c Cs;tjjzPtjj|jd}|dkr\tjt f}|tj|ju0x%x(utypeu__name__u_tokenutypeiduid(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu__repr__/suBaseProxy.__repr__c CsBy|jdSWn*tk r=t|dddSYnXdS(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 BaseProxys %      cCsttdd}|r?|j|jkr?|j|jdS|jddodttdd }|||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 Cst|}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 Cst|d}|dkr\||jd|}zt|dd|f}Wd|jXn|dkr|dk r|j}n|dkrtj}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,|EeZdZddZddZdS(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\}}|jds"|jd||fq"q"W|jdtjd|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 Namespaces u NamespacecBsV|EeZdZd ddZddZddZddZeeeZ 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.pyugetsu Value.getcCs ||_dS(N(u_value(uselfuvalue((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyusetsu 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.pyuValues    uValuecCstj||S(N(uarray(utypecodeusequenceulock((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuArraysuArraycBsV|EeZdZdZddZddZd d Zd d Zd dZdS(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.pyusendsuIteratorProxy.sendcGs|jd|S(Nuthrow(u _callmethod(uselfuargs((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuthrowsuIteratorProxy.throwcGs|jd|S(Nuclose(u _callmethod(uselfuargs((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuclosesuIteratorProxy.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 IteratorProxys     u IteratorProxycBsP|EeZdZd Zd d ddZddZddZd d Z d S(u AcquirerProxyuacquireureleasecCs1|dkr|fn ||f}|jd|S(Nuacquire(uNoneu _callmethod(uselfublockingutimeoutuargs((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuacquires!uAcquirerProxy.acquirecCs |jdS(Nurelease(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyureleasesuAcquirerProxy.releasecCs |jdS(Nuacquire(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __enter__suAcquirerProxy.__enter__cCs |jdS(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 AcquirerProxys   u AcquirerProxycBsP|EeZdZdZdddZdd Zd d Zdd d ZdS(uConditionProxyuacquireureleaseuwaitunotifyu notify_allcCs|jd|fS(Nuwait(u _callmethod(uselfutimeout((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuwaitsuConditionProxy.waitcCs |jdS(Nunotify(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyunotifysuConditionProxy.notifycCs |jdS(Nu notify_all(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu notify_allsuConditionProxy.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_fors        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.pyuConditionProxys   uConditionProxycBsM|EeZdZdZddZddZd d Zd d d Zd S(u EventProxyuis_setusetuclearuwaitcCs |jdS(Nuis_set(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuis_setsuEventProxy.is_setcCs |jdS(Nuset(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyusetsuEventProxy.setcCs |jdS(Nuclear(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuclearsuEventProxy.clearcCs|jd|fS(Nuwait(u _callmethod(uselfutimeout((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuwaitsuEventProxy.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 EventProxys    u EventProxycBsw|EeZdZdZdddZddZd d Zed d Z ed dZ eddZ dS(u BarrierProxyu__getattribute__uwaituaborturesetcCs|jd|fS(Nuwait(u _callmethod(uselfutimeout((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuwaitsuBarrierProxy.waitcCs |jdS(Nuabort(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuabortsuBarrierProxy.abortcCs |jdS(Nureset(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyuresetsuBarrierProxy.resetcCs|jddS(Nu__getattribute__uparties(uparties(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyupartiessuBarrierProxy.partiescCs|jddS(Nu__getattribute__u n_waiting(u n_waiting(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu n_waitingsuBarrierProxy.n_waitingcCs|jddS(Nu__getattribute__ubroken(ubroken(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyubrokensuBarrierProxy.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 BarrierProxys  u BarrierProxycBs>|EeZdZd ZddZddZdd Zd S( uNamespaceProxyu__getattribute__u __setattr__u __delattr__cCsB|ddkr tj||Stj|d}|d|fS(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||fS(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|fS(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.pyuNamespaceProxys  uNamespaceProxycBsA|EeZdZdZddZddZeeeZdS( u ValueProxyugetusetcCs |jdS(Nuget(u _callmethod(uself((u=/opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyugetsuValueProxy.getcCs|jd|fS(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,|EeZdZddZddZdS(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    .      #