ž
§ÿ fðŒ c @ sÚ d d d d g Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m Z m Z m
Z
m Z m Z m
Z
d d l m Z d d l m Z m Z d d
l m Z d d „ Z e j e j e ƒ d
d „ d d d f Dƒ Z e d e k rMd d „ Z x: e D]2 Z e j e e ƒ d d l Z e j e e ƒ qWn Gd d „ d e ƒ Z f i d d „ Z d d „ Z Gd d „ d e! ƒ Z" d d „ Z# d d „ Z$ Gd d „ d e ƒ Z% Gd! d" „ d" e ƒ Z& i e
j' e
j( f d# 6e
j) e
j* f d$ 6Z+ Gd% d „ d e ƒ Z, Gd& d' „ d' e- ƒ Z. Gd( d „ d e ƒ Z/ d) d* „ Z0 i d+ d, „ Z1 e2 e2 e2 e3 d- d. „ Z4 Gd/ d0 „ d0 e ƒ Z5 Gd1 d2 „ d2 e ƒ Z6 e3 d3 d4 „ Z7 Gd5 d6 „ d6 e/ ƒ Z8 Gd7 d8 „ d8 e/ ƒ Z9 Gd9 d: „ d: e9 ƒ Z: Gd; d< „ d< e/ ƒ Z; Gd= d> „ d> e/ ƒ Z< Gd? d@ „ d@ e/ ƒ Z= GdA dB „ dB e/ ƒ Z> e1 dC dD dE dF dG dH dI dJ dK dL dM dN dO dP dQ dR dS dT dU dV f ƒ Z? GdW dX „ dX e? ƒ Z@ e1 dY dE dF dG dH dL dZ d[ d\ d] d d dR d^ d_ d` d f ƒ ZA e1 da dH dG dL f ƒ ZB e1 db dc dd de df dg dh di dj dk dl dm f ƒ ZC i dn dd 6dn dj 6dn dl 6do df 6do dg 6eC _D Gdp d „ d e, ƒ ZE eE j dq e jF ƒ eE j dr e jF ƒ eE j ds e jG e; ƒ eE j dt e jH e9 ƒ eE j du e jI e9 ƒ eE j dv e jJ e9 ƒ eE j dw e jK e9 ƒ eE j dx e jL e: ƒ eE j dy e jM e< ƒ eE j dz e eC ƒ eE j d{ e e@ ƒ eE j d| eN eA ƒ eE j d2 e6 e> ƒ eE j d4 e7 eB ƒ eE j d0 e5 e= ƒ eE j do d} e8 d~ eO ƒeE j dn d~ eO ƒd S( u BaseManageru SyncManageru BaseProxyu Tokeni N( u
format_exc( u Processu current_processu active_childrenu Poolu utilu
connection( u AuthenticationString( u Popenu ForkingPickler( u timec C s t j | j | j ƒ f f S( N( u arrayu typecodeu tobytes( u a( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu reduce_array s u reduce_arrayc C s( g | ] } t t i | ƒ ƒ ƒ ‘ q S( ( u typeu getattr( u .0u name( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu
$ s u
u itemsu keysu valuesc C s t t | ƒ f f S( N( u list( u obj( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu rebuild_as_list& s u rebuild_as_listc B sP | Ee Z d Z d Z d Z d d „ Z d d „ Z d d
„ Z d d „ Z d
S( u Tokenu4
Type to uniquely indentify a shared object
u typeidu addressu idc C s! | | | | _ | _ | _ d S( N( u typeidu addressu id( u selfu typeidu addressu id( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __init__7 s u Token.__init__c C s | j | j | j f S( N( u typeidu addressu id( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __getstate__: s u Token.__getstate__c C s | \ | _ | _ | _ d S( N( u typeidu addressu id( u selfu state( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __setstate__= s u Token.__setstate__c C s d | j | j | j f S( Nu# Token(typeid=%r, address=%r, id=%r)( u typeidu addressu id( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __repr__@ s u Token.__repr__N( u typeidu addressu id( 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.pyu Token1 s c C sN | j | | | | f ƒ | j ƒ \ } } | d k r; | St | | ƒ ‚ d S( uL
Send a message to manager using connection `c` and return response
u #RETURNN( u sendu recvu convert_to_error( u cu idu
methodnameu argsu kwdsu kindu result( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu dispatchH s
u dispatchc C sN | d k r | S| d k r& t | ƒ S| d k r@ t d | ƒ St d ƒ Sd S( Nu #ERRORu
#TRACEBACKu #UNSERIALIZABLEu Unserializable message: %s
u Unrecognized message type( u RemoteErroru
ValueError( u kindu result( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu convert_to_errorR s
u convert_to_errorc B s | Ee Z d Z d d „ Z d S( u RemoteErrorc C s) d d d d t | j d ƒ d d S( Nu
u -iK i ( u stru args( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __str___ s u RemoteError.__str__N( u __name__u
__module__u __qualname__u __str__( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu RemoteError^ s u RemoteErrorc C sL g } x? t | ƒ D]1 } t | | ƒ } t | ƒ r | j | ƒ q q W| S( u4
Return a list of names of methods of `obj`
( u diru getattru callableu append( u obju tempu nameu func( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu all_methodsf s u all_methodsc C s d d „ t | ƒ Dƒ S( uP
Return a list of names of methods of `obj` which do not start with '_'
c S s& g | ] } | d d k r | ‘ q S( i u _( ( u .0u name( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu
u s u" public_methods..( u all_methods( u obj( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu public_methodsq s u public_methodsc B s" | Ee Z d Z d Z d d d d d d d d d
g Z d d „ Z d
d „ Z d d „ Z d d „ Z d d „ Z d d „ Z
d d „ Z d d „ Z i e d 6e d 6e
d 6Z
d d „ Z d d! „ Z d" d# „ Z d$ d% „ Z d& d' „ Z d( d) „ Z d* d+ „ Z d, d- „ Z d. d/ „ Z d0 S(1 u ServeruM
Server class which runs in a process controlled by a manager object
u shutdownu createu accept_connectionu get_methodsu
debug_infou number_of_objectsu dummyu increfu decrefc C s | | _ t | ƒ | _ t | \ } } | d | d d ƒ | _ | j j | _ i d f f d 6| _ i | _ t j
ƒ | _ d S( Nu addressu backlogi u 0( u registryu AuthenticationStringu authkeyu listener_clientu listeneru addressu Noneu id_to_obju id_to_refcountu threadingu RLocku mutex( u selfu registryu addressu authkeyu
serializeru Listeneru Client( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __init__‚ s u Server.__init__c C sÛ t j ƒ | _ | t ƒ _ zq t j d | j ƒ } d | _ | j ƒ y* x# | j j
ƒ sn | j j d ƒ qL WWn t t
f k
rŠ Yn XWd t j t j k rÉ t j d ƒ t j t _ t j t _ n t j d ƒ Xd S( u(
Run the server forever
u targeti Nu resetting stdout, stderri T( u threadingu Eventu
stop_eventu current_processu _manager_serveru Threadu accepteru Trueu daemonu startu is_setu waitu KeyboardInterruptu
SystemExitu sysu stdoutu
__stdout__u utilu debugu
__stderr__u stderru exit( u selfu accepter( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu
serve_forever s
u Server.serve_foreverc
C sl xe y | j j ƒ } Wn t t f k
r3 w Yn Xt j d | j d | f ƒ } d | _ | j ƒ q d S( Nu targetu argsT(
u listeneru acceptu OSErroru IOErroru threadingu Threadu handle_requestu Trueu daemonu start( u selfu cu t( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu accepter¦ s u Server.accepterc ' C su d } } } yW t j | | j ƒ t j | | j ƒ | j ƒ } | \ } } } } t | | ƒ } Wn! t k
rˆ d t ƒ f } YnG Xy | | | | Ž } Wn! t k
r d t ƒ f } Yn
Xd | f } y | j | ƒ Wn„ t k
rf}
zd y | j d t ƒ f ƒ Wn t k
r#Yn Xt
j d | ƒ t
j d | ƒ t
j d |
ƒ WYd d }
~
Xn X| j ƒ d S( u)
Handle a new connection
u
#TRACEBACKu #RETURNu Failure to send message: %ru ... request was %ru ... exception was %rN(
u Noneu
connectionu deliver_challengeu authkeyu answer_challengeu recvu getattru Exceptionu
format_excu sendu utilu infou close( u selfu cu funcnameu resultu requestu ignoreu argsu kwdsu funcu msgu e( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu handle_request° s2
#u Server.handle_requestc * C s+ t j d t j ƒ j ƒ | j } | j } | j } xð| j j ƒ s&y/d } } | ƒ } | \ } } } }
| | \ } } } | | k r¯ t d | t | ƒ | f ƒ ‚ n t
| | ƒ }
y |
| |
Ž } Wn1 t k
r} z d | f } WYd d } ~ Xnp X| o| j | d ƒ } | rh| j | | | ƒ \ } } t | | j | ƒ } d | | f f } n d | f } Wnã t k
r| d k r£d t ƒ f } n\ y8 | j | } | | | | | | |
Ž } d | f } Wn! t k
rþd t ƒ f } Yn XYnX t k
r:t j d t j ƒ j ƒ t j d ƒ Yn! t k
rZd t ƒ f } Yn XyP y | | ƒ Wn; t k
r©} z | d
t | ƒ f ƒ WYd d } ~ Xn XWq7 t k
r"} zU t j d t j ƒ j ƒ t j d | ƒ t j d
| ƒ | j ƒ t j d ƒ WYd d } ~ Xq7 Xq7 Wd S( 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 %ri u #UNSERIALIZABLEu exception in thread serving %ru ... message was %ru ... exception was %ri ( u utilu debugu threadingu current_threadu nameu recvu sendu id_to_obju
stop_eventu is_setu Noneu AttributeErroru typeu getattru Exceptionu getu createu Tokenu addressu
format_excu fallback_mappingu EOFErroru sysu exitu repru infou close( u selfu connu recvu sendu id_to_obju
methodnameu obju requestu identu argsu kwdsu exposedu gettypeidu functionu resu eu msgu typeidu ridentu rexposedu tokenu
fallback_funcu result( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu serve_clientÒ sl
-
u Server.serve_clientc C s | S( N( ( u selfu connu identu obj( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu fallback_getvalue s u Server.fallback_getvaluec C s
t | ƒ S( N( u str( u selfu connu identu obj( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu fallback_str s u Server.fallback_strc C s
t | ƒ S( N( u repr( u selfu connu identu obj( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu
fallback_repr" s u Server.fallback_repru __str__u __repr__u #GETVALUEc C s d S( N( ( u selfu c( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu dummy+ s u Server.dummyc C s´ | j j ƒ z’ g } t | j j ƒ ƒ } | j ƒ xY | D]Q } | d k r< | j d | | j | t | j | d ƒ d d … f ƒ q< q< Wd j | ƒ SWd | j j
ƒ Xd S( uO
Return some info --- useful to spot problems with refcounting
u 0u %s: refcount=%s
%si NiK u
( u mutexu acquireu listu id_to_obju keysu sortu appendu id_to_refcountu stru joinu release( u selfu cu resultu keysu ident( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu
debug_info. s
-u Server.debug_infoc C s t | j ƒ d S( u*
Number of shared objects
i ( u lenu id_to_obj( u selfu c( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu number_of_objects@ s u Server.number_of_objectsc C sX zC y t j d ƒ | j d ƒ Wn d d l } | j ƒ Yn XWd | j j ƒ Xd S( u'
Shutdown this process
u! manager received shutdown messageu #RETURNi N( u #RETURNN( u utilu debugu sendu Noneu tracebacku print_excu
stop_eventu set( u selfu cu traceback( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu shutdownF s
u Server.shutdownc
O s% | j j ƒ z| j | \ } } } } | d k rB | d } n | | | Ž } | d k rl t | ƒ } n | d k r‘ t | ƒ t | ƒ } n d t | ƒ }
t j d | |
ƒ | t | ƒ | f | j
|
<|
| j k rï d | j |
Create a new shared object and return its id
i u %xu& %r callable returned object with id %rN( u mutexu acquireu registryu Noneu public_methodsu listu idu utilu debugu setu id_to_obju id_to_refcountu increfu tupleu release( u selfu cu typeidu argsu kwdsu callableu exposedu method_to_typeidu proxytypeu obju ident( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu createS s$
u
Server.createc C s t | j | j d ƒ S( uL
Return the methods of the shared object indicated by token
i ( u tupleu id_to_obju id( u selfu cu token( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu get_methodsy s u Server.get_methodsc C s- | t j ƒ _ | j d ƒ | j | ƒ d S( u=
Spawn a new thread to serve this connection
u #RETURNN( u #RETURNN( u threadingu current_threadu nameu sendu Noneu serve_client( u selfu cu name( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu accept_connection s
u Server.accept_connectionc
C s7 | j j ƒ z | j | d 7
Connect manager object to the server process
u authkeyu dummyN(
u listener_clientu _serializeru _addressu _authkeyu dispatchu Noneu Stateu STARTEDu _stateu value( u selfu Listeneru Clientu conn( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu connectÉ s u BaseManager.connectc C sL | d k r( t | ƒ r( t d ƒ ‚ n t j d d ƒ \ } } t d t | ƒ j d | j | j
| j | j | | | f ƒ | _
d j d d „ | j
j Dƒ ƒ } t | ƒ j d | | j
_ | j
j ƒ | j ƒ | j ƒ | _
| j ƒ t j | j _ t j | t | ƒ j d | j
| j
| j | j | j f d d
ƒ| _ d S(
u@
Spawn a server process for this manager object
u initializer must be a callableu duplexu targetu argsu :c s s | ] } t | ƒ Vq d S( N( u str( u .0u i( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu ä s u$ BaseManager.start..u -u exitpriorityi NF( u Noneu callableu TypeErroru
connectionu Pipeu Falseu Processu typeu _run_serveru _registryu _addressu _authkeyu _serializeru _processu joinu _identityu __name__u nameu startu closeu recvu Stateu STARTEDu _stateu valueu utilu Finalizeu _finalize_manageru _Clientu shutdown( u selfu initializeru initargsu readeru writeru ident( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu startÒ s& "
u BaseManager.startc C sl | d k r | | Œ n | j | | | | ƒ } | j | j ƒ | j ƒ t j d | j ƒ | j ƒ d S( u@
Create a server, report its address and run it
u manager serving at %rN( u Noneu _Serveru sendu addressu closeu utilu infou
serve_forever( u clsu registryu addressu authkeyu
serializeru writeru initializeru initargsu server( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu _run_serverö s
u BaseManager._run_serverc O sk | j | j d | j ƒ} z) t | d d | f | | ƒ \ } } Wd | j ƒ Xt | | j | ƒ | f S( uP
Create a new shared object; return the token and exposed tuple
u authkeyu createN( u _Clientu _addressu _authkeyu dispatchu Noneu closeu Token( u selfu typeidu argsu kwdsu connu idu exposed( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu _create
s
) u BaseManager._createc C sA | j d k r= | j j | ƒ | j j ƒ s= d | _ q= n d S( uC
Join the manager process (if it has been spawned)
N( u _processu Noneu joinu is_alive( u selfu timeout( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu join s u BaseManager.joinc
C sA | j | j d | j ƒ} z t | d d ƒ SWd | j ƒ Xd S( uS
Return some info about the servers shared objects and connections
u authkeyu
debug_infoN( u _Clientu _addressu _authkeyu dispatchu Noneu close( u selfu conn( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu _debug_info s u BaseManager._debug_infoc
C sA | j | j d | j ƒ} z t | d d ƒ SWd | j ƒ Xd S( u5
Return the number of shared objects
u authkeyu number_of_objectsN( u _Clientu _addressu _authkeyu dispatchu Noneu close( u selfu conn( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu _number_of_objects) s u BaseManager._number_of_objectsc C s& | j j t j k r" | j ƒ n | S( N( u _stateu valueu Stateu INITIALu start( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __enter__3 s
u BaseManager.__enter__c C s | j ƒ d S( N( u shutdown( u selfu exc_typeu exc_valu exc_tb( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __exit__9 s u BaseManager.__exit__c C s | j ƒ rê t j d ƒ y8 | | d | ƒ} z t | d d ƒ Wd | j ƒ XWn t k
re Yn X| j d d ƒ | j ƒ rê t j d ƒ t | d ƒ rç t j d ƒ | j ƒ | j d d
ƒ | j ƒ rä t j d ƒ qä qç qê n t
j | _ y t
j | =Wn t k
rYn Xd S( uQ
Shutdown the manager process; will be registered as a finalizer
u# sending shutdown message to manageru authkeyu shutdownNu timeoutg ð?u manager still aliveu terminateu' trying to `terminate()` manager processgš™™™™™¹?u# manager still alive after terminate( u is_aliveu utilu infou dispatchu Noneu closeu Exceptionu joinu hasattru terminateu Stateu SHUTDOWNu valueu BaseProxyu _address_to_localu KeyError( u processu addressu authkeyu stateu _Clientu conn( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu _finalize_manager< s.
u BaseManager._finalize_managerc C s | j S( N( u _address( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu \ s u BaseManager.c
sé d | j k r$ | j j ƒ | _ n ˆ d k r9 t ‰ n | pN t ˆ d d ƒ } | pf t ˆ d d ƒ } | r• x# t | j ƒ ƒ D] \ } } q‚ Wn | | | ˆ f | j ˆ <| rå ‡ ‡ f d d † } ˆ | _ t | ˆ | ƒ n d S( u9
Register a typeid with the manager type
u _registryu _exposed_u _method_to_typeid_c sŠ t j d ˆ ƒ | j ˆ | | Ž \ } } ˆ | | j d | d | j d | ƒ} | j | j d | j ƒ} t | d d | j f ƒ | S( Nu) requesting creation of a shared %r objectu manageru authkeyu exposedu decref(
u utilu debugu _createu _serializeru _authkeyu _Clientu addressu dispatchu Noneu id( u selfu argsu kwdsu tokenu expu proxyu conn( u proxytypeu typeid( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu tempy s u" BaseManager.register..tempN(
u __dict__u _registryu copyu Noneu AutoProxyu getattru listu itemsu __name__u setattr(
u clsu typeidu callableu proxytypeu exposedu method_to_typeidu
create_methodu keyu valueu temp( ( u proxytypeu typeidu= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu register^ s
u BaseManager.registerNT( u __name__u
__module__u __qualname__u __doc__u _registryu Serveru _Serveru Noneu __init__u
get_serveru connectu startu classmethodu _run_serveru _createu joinu _debug_infou _number_of_objectsu __enter__u __exit__u staticmethodu _finalize_manageru propertyu addressu Trueu register( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu BaseManager° s(
$
c B s, | Ee Z d Z d d „ Z d d „ Z d S( u ProcessLocalSetc C s t j | d d „ ƒ d S( Nc S s
| j ƒ S( N( u clear( u obj( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu Œ s u* ProcessLocalSet.__init__..( u utilu register_after_fork( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __init__‹ s u ProcessLocalSet.__init__c C s t | ƒ f f S( N( u type( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu
__reduce__ s u ProcessLocalSet.__reduce__N( u __name__u
__module__u __qualname__u __init__u
__reduce__( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu ProcessLocalSetŠ s u ProcessLocalSetc B sÈ | Ee Z d Z d Z i Z e j ƒ Z d d d d d d „ Z
d d „ Z f i d d „ Z d d „ Z
d
d „ Z e d d
„ ƒ Z d d „ Z d d „ Z d d „ Z d d „ Z d d „ Z d S( u BaseProxyu.
A base for proxies of shared objects
c C s; t j j ƒ zP t j j | j d ƒ } | d k r\ t j ƒ t ƒ f } | t j | j u 0x%x( u typeu __name__u _tokenu typeidu id( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __repr__/ s u BaseProxy.__repr__c C sB y | j d ƒ SWn* t k
r= t | ƒ d d … d SYn Xd S( uV
Return representation of the referent (or a fall-back if that fails)
u __repr__Ni u ; '__str__()' failed>iÿÿÿÿ( u _callmethodu Exceptionu repr( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __str__3 s
u BaseProxy.__str__NT( u __name__u
__module__u __qualname__u __doc__u _address_to_localu utilu ForkAwareThreadLocku _mutexu Noneu Trueu __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 %
c C s t t ƒ d d ƒ } | r? | j | j k r? | j | j d S| j d d ƒ od t t ƒ d d ƒ } | | | d | | Sd S( u‚
Function used for unpickling proxy objects.
If possible the shared object is returned, or otherwise a proxy for it.
u _manager_serveri u increfu _inheritingNTF( u getattru current_processu Noneu addressu id_to_obju idu popu Trueu False( u funcu tokenu
serializeru kwdsu serveru incref( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu RebuildProxy@ s u RebuildProxyc
C s“ t | ƒ } y | | | f SWn t k
r2 Yn Xi } x% | D] } t d | | f | ƒ q@ Wt | t f | ƒ } | | _ | | | | f <| S( uC
Return an proxy type whose methods are given by `exposed`
uL def %s(self, *args, **kwds):
return self._callmethod(%r, args, kwds)( u tupleu KeyErroru execu typeu BaseProxyu _exposed_( u nameu exposedu _cacheu dicu methu ProxyType( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu
MakeProxyTypeU s
u
MakeProxyTypec
C sß t | d } | d k r\ | | j d | ƒ} z t | d d | f ƒ } Wd | j ƒ Xn | d k r€ | d k r€ | j } n | d k r› t ƒ j } n t d | j | ƒ } | | | d | d | d | ƒ} d | _ | S( u*
Return an auto-proxy for `token`
i u authkeyu get_methodsNu
AutoProxy[%s]u manageru increfT( u listener_clientu Noneu addressu dispatchu closeu _authkeyu current_processu authkeyu
MakeProxyTypeu typeidu Trueu _isauto(
u tokenu
serializeru manageru authkeyu exposedu increfu _Clientu connu ProxyTypeu proxy( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu AutoProxyk s u AutoProxyc B s, | Ee Z d Z d d „ Z d d „ Z d S( u Namespacec K s | j j | ƒ d S( N( u __dict__u update( u selfu kwds( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __init__‰ s u Namespace.__init__c C sy t | j j ƒ ƒ } g } x= | D]5 \ } } | j d ƒ s" | j d | | f ƒ q" q" W| j ƒ d t j d | ƒ S( Nu _u %s=%ru
Namespace(%s)u , ( u listu __dict__u itemsu
startswithu appendu sortu stru join( u selfu itemsu tempu nameu value( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __repr__‹ s
u Namespace.__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 Namespacec B sV | Ee Z d Z d
d d „ Z d d „ Z d d „ Z d d „ Z e e e ƒ Z d S( u Valuec C s | | _ | | _ d S( N( u _typecodeu _value( u selfu typecodeu valueu lock( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __init__• s u Value.__init__c C s | j S( N( u _value( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu get˜ s u Value.getc C s
| | _ d S( N( u _value( u selfu value( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu setš s u Value.setc C s d t | ƒ j | j | j f S( Nu
%s(%r, %r)( u typeu __name__u _typecodeu _value( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __repr__œ s u Value.__repr__NT(
u __name__u
__module__u __qualname__u Trueu __init__u getu setu __repr__u propertyu value( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu Value” s
u Valuec C s t j | | ƒ S( N( u array( u typecodeu sequenceu lock( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu Array s u Arrayc B sV | Ee Z d Z d Z d d „ Z d d „ Z d d
„ Z d d „ Z d
d „ Z d S( u
IteratorProxyu __next__u sendu throwu closec C s | S( N( ( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __iter__© s u IteratorProxy.__iter__c G s | j d | ƒ S( Nu __next__( u _callmethod( u selfu args( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __next__« s u IteratorProxy.__next__c G s | j d | ƒ S( Nu send( u _callmethod( u selfu args( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu send s u IteratorProxy.sendc G s | j d | ƒ S( Nu throw( u _callmethod( u selfu args( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu throw¯ s u IteratorProxy.throwc G s | j d | ƒ S( Nu close( u _callmethod( u selfu args( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu close± s u IteratorProxy.closeN( u __next__u sendu throwu close( u __name__u
__module__u __qualname__u _exposed_u __iter__u __next__u sendu throwu close( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu
IteratorProxy§ s u
IteratorProxyc B sP | Ee Z d Z d Z d
d d d „ Z d d „ Z d d „ Z d d
„ Z d S( u
AcquirerProxyu acquireu releasec C s1 | d k r | f n | | f } | j d | ƒ S( Nu acquire( u Noneu _callmethod( u selfu blockingu timeoutu args( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu acquire· s !u AcquirerProxy.acquirec C s
| j d ƒ S( Nu release( u _callmethod( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu releaseº s u AcquirerProxy.releasec C s
| j d ƒ S( Nu acquire( u _callmethod( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __enter__¼ s u AcquirerProxy.__enter__c C s
| j d ƒ S( Nu release( u _callmethod( u selfu exc_typeu exc_valu exc_tb( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __exit__¾ s u AcquirerProxy.__exit__N( u acquireu releaseT(
u __name__u
__module__u __qualname__u _exposed_u Trueu Noneu acquireu releaseu __enter__u __exit__( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu
AcquirerProxyµ s
u
AcquirerProxyc B sP | Ee Z d Z d Z d d d „ Z d d „ Z d
d „ Z d d d
„ Z d S( u ConditionProxyu acquireu releaseu waitu notifyu
notify_allc C s | j d | f ƒ S( Nu wait( u _callmethod( u selfu timeout( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu waitÄ s u ConditionProxy.waitc C s
| j d ƒ S( Nu notify( u _callmethod( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu notifyÆ s u ConditionProxy.notifyc C s
| j d ƒ S( Nu
notify_all( u _callmethod( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu
notify_allÈ s u ConditionProxy.notify_allc C sŽ | ƒ } | r | S| d k r/ t ƒ | } n d } d } xL | s‰ | d k rp | t ƒ } | d k rp Pqp n | j | ƒ | ƒ } q> W| S( Ni ( u Noneu _timeu wait( u selfu predicateu timeoutu resultu endtimeu waittime( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu wait_forÊ s
u ConditionProxy.wait_forN( u acquireu releaseu waitu notifyu
notify_all( u __name__u
__module__u __qualname__u _exposed_u Noneu waitu notifyu
notify_allu wait_for( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu ConditionProxy s
u ConditionProxyc B sM | Ee Z d Z d Z d d „ Z d d „ Z d d
„ Z d
d d „ Z d
S( u
EventProxyu is_setu setu clearu waitc C s
| j d ƒ S( Nu is_set( u _callmethod( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu is_setß s u EventProxy.is_setc C s
| j d ƒ S( Nu set( u _callmethod( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu setá s u EventProxy.setc C s
| j d ƒ S( Nu clear( u _callmethod( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu clearã s u EventProxy.clearc C s | j d | f ƒ S( Nu wait( u _callmethod( u selfu timeout( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu waitå s u EventProxy.waitN( u is_setu setu clearu wait( u __name__u
__module__u __qualname__u _exposed_u is_setu setu clearu Noneu wait( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu
EventProxyÝ s
u
EventProxyc B sw | Ee Z d Z d Z d d d „ Z d d „ Z d d
„ Z e d d „ ƒ Z e d
d „ ƒ Z
e d d „ ƒ Z d S( u BarrierProxyu __getattribute__u waitu abortu resetc C s | j d | f ƒ S( Nu wait( u _callmethod( u selfu timeout( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu waitë s u BarrierProxy.waitc C s
| j d ƒ S( Nu abort( u _callmethod( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu abortí s u BarrierProxy.abortc C s
| j d ƒ S( Nu reset( u _callmethod( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu resetï s u BarrierProxy.resetc C s | j d d ƒ S( Nu __getattribute__u parties( u parties( u _callmethod( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu partiesñ s u BarrierProxy.partiesc C s | j d d ƒ S( Nu __getattribute__u n_waiting( u n_waiting( u _callmethod( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu n_waitingô s u BarrierProxy.n_waitingc C s | j d d ƒ S( Nu __getattribute__u broken( u broken( u _callmethod( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu broken÷ s u BarrierProxy.brokenN( u __getattribute__u waitu abortu reset( u __name__u
__module__u __qualname__u _exposed_u Noneu waitu abortu resetu propertyu partiesu n_waitingu broken( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu BarrierProxyé s u BarrierProxyc B s> | Ee Z d Z d Z d d „ Z d d „ Z d d „ Z d
S( u NamespaceProxyu __getattribute__u __setattr__u __delattr__c C sB | d d k r t j | | ƒ St j | d ƒ } | d | f ƒ S( Ni u _u _callmethodu __getattribute__( u objectu __getattribute__( u selfu keyu
callmethod( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __getattr__þ s u NamespaceProxy.__getattr__c C sH | d d k r# t j | | | ƒ St j | d ƒ } | d | | f ƒ S( Ni u _u _callmethodu __setattr__( u objectu __setattr__u __getattribute__( u selfu keyu valueu
callmethod( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __setattr__ s u NamespaceProxy.__setattr__c C sB | d d k r t j | | ƒ St j | d ƒ } | d | f ƒ S( Ni u _u _callmethodu __delattr__( u objectu __delattr__u __getattribute__( u selfu keyu
callmethod( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __delattr__ s u NamespaceProxy.__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.pyu NamespaceProxyü s u NamespaceProxyc B sA | Ee Z d Z d Z d d „ Z d d „ Z e e e ƒ Z d S( u
ValueProxyu getu setc C s
| j d ƒ S( Nu get( u _callmethod( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu get s u ValueProxy.getc C s | j d | f ƒ S( Nu set( u _callmethod( u selfu value( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu set s u ValueProxy.setN( u getu set( u __name__u
__module__u __qualname__u _exposed_u getu setu propertyu value( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu
ValueProxy s u
ValueProxyu
BaseListProxyu __add__u __contains__u __delitem__u __getitem__u __len__u __mul__u __reversed__u __rmul__u __setitem__u appendu countu extendu indexu insertu popu removeu reverseu sortu __imul__c B s, | Ee Z d Z d d „ Z d d „ Z d S( u ListProxyc C s | j d | f ƒ | S( Nu extend( u _callmethod( u selfu value( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __iadd__ s u ListProxy.__iadd__c C s | j d | f ƒ | S( Nu __imul__( u _callmethod( u selfu value( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __imul__" s u ListProxy.__imul__N( u __name__u
__module__u __qualname__u __iadd__u __imul__( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu ListProxy s u ListProxyu DictProxyu clearu copyu getu has_keyu popitemu
setdefaultu updateu
ArrayProxyu PoolProxyu applyu apply_asyncu closeu imapu imap_unorderedu joinu mapu map_asyncu starmapu
starmap_asyncu terminateu AsyncResultu Iteratorc B s | Ee Z d Z d Z d S( 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 SyncManagerC s u Queueu
JoinableQueueu Eventu Locku RLocku Semaphoreu BoundedSemaphoreu Conditionu Barrieru Poolu listu dictu proxytypeu
create_method(P u __all__u sysu threadingu arrayu queueu tracebacku
format_excu multiprocessingu Processu current_processu active_childrenu Poolu utilu
connectionu multiprocessing.processu AuthenticationStringu multiprocessing.forkingu Popenu ForkingPickleru timeu _timeu reduce_arrayu registeru
view_typesu listu rebuild_as_listu view_typeu copyregu pickleu objectu Tokenu dispatchu convert_to_erroru Exceptionu RemoteErroru all_methodsu public_methodsu Serveru Stateu Listeneru Clientu XmlListeneru XmlClientu listener_clientu BaseManageru setu ProcessLocalSetu BaseProxyu RebuildProxyu
MakeProxyTypeu Noneu Trueu AutoProxyu Namespaceu Valueu Arrayu
IteratorProxyu
AcquirerProxyu ConditionProxyu
EventProxyu BarrierProxyu NamespaceProxyu
ValueProxyu
BaseListProxyu ListProxyu DictProxyu
ArrayProxyu PoolProxyu _method_to_typeid_u SyncManageru Queueu Eventu Locku RLocku Semaphoreu BoundedSemaphoreu Conditionu Barrieru dictu False( ( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu s® .
ÿ #
Ú
¬