Server : LiteSpeed System : Linux premium84.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64 User : claqxcrl ( 523) PHP Version : 8.1.32 Disable Function : NONE Directory : /opt/alt/python33/lib64/python3.3/multiprocessing/__pycache__/ |
�
�� 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
<listcomp>$ s u
<listcomp>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
<listcomp>u s u" public_methods.<locals>.<listcomp>( 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 |
<n | j | |
� |
t
| � f SWd | j j � Xd S( u>
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<Wd | j j � Xd S( Ni ( u mutexu acquireu id_to_refcountu release( u selfu cu ident( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu incref� s
u
Server.increfc
C sq | j j � zO | j | d 8<| j | d k r[ | j | =| j | =t j d | � n Wd | j j � Xd S( Ni i u disposing of obj with id %r( u mutexu acquireu id_to_refcountu id_to_obju utilu debugu release( u selfu cu ident( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu decref� s
u
Server.decrefN( u __name__u
__module__u __qualname__u __doc__u publicu __init__u
serve_foreveru accepteru handle_requestu serve_clientu fallback_getvalueu fallback_stru
fallback_repru fallback_mappingu dummyu
debug_infou number_of_objectsu shutdownu createu get_methodsu accept_connectionu increfu decref( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu Server{ s0
" J
& u Serverc B s/ | Ee Z d Z d g Z d Z d Z d Z d S( u Stateu valuei i i N( u __name__u
__module__u __qualname__u __slots__u INITIALu STARTEDu SHUTDOWN( u
__locals__( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu State� s u Stateu pickleu xmlrpclibc B s
| Ee Z d Z d Z i Z e Z d d d d d � Z d d � Z d d � Z
d f d d
� Z e d f d d � � Z
d
d � Z d d d � Z d d � Z d d � Z d d � Z d d � Z e d d � � Z e d d � � Z e d d d d d d d � � Z d S(! u BaseManageru!
Base class for managers
u picklec C sq | d k r t � j } n | | _ t | � | _ t � | _ t j | j _ | | _
t | \ | _ | _
d S( N( u Noneu current_processu authkeyu _addressu AuthenticationStringu _authkeyu Stateu _stateu INITIALu valueu _serializeru listener_clientu _Listeneru _Client( u selfu addressu authkeyu
serializer( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __init__� s u BaseManager.__init__c C s t | j | j | j | j � S( uX
Return server object with serve_forever() method and address attribute
( u Serveru _registryu _addressu _authkeyu _serializer( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu
get_server� s u BaseManager.get_serverc C sN t | j \ } } | | j d | j �} t | d d � t j | j _ d S( u>
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 <genexpr>� s u$ BaseManager.start.<locals>.<genexpr>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 <lambda>\ s u BaseManager.<lambda>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.<locals>.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 <lambda>� s u* ProcessLocalSet.__init__.<locals>.<lambda>( 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 <n Wd t j j
� X| d | _ | d | _ | | _
| j
j | _ | | _ | | _ t | d | _ | d k r� t | � | _ n0 | j d k r| j j | _ n t � j | _ | r$| j � n t j | t j � d S( Ni i ( u BaseProxyu _mutexu acquireu _address_to_localu getu addressu Noneu utilu ForkAwareLocalu ProcessLocalSetu releaseu _tlsu _idsetu _tokenu idu _idu _manageru _serializeru listener_clientu _Clientu AuthenticationStringu _authkeyu current_processu authkeyu _increfu register_after_forku _after_fork( u selfu tokenu
serializeru manageru authkeyu exposedu increfu tls_idset( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __init__� s,
u BaseProxy.__init__c C s� t j d � t � j } t j � j d k rH | d t j � j 7} n | j | j j d | j �} t
| d d | f � | | j _
d S( Nu making connection to manageru
MainThreadu |u authkeyu accept_connection( u utilu debugu current_processu nameu threadingu current_threadu _Clientu _tokenu addressu _authkeyu dispatchu Noneu _tlsu
connection( u selfu nameu conn( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu _connect� s
u BaseProxy._connectc C sE y | j j } WnA t k
rS t j d t j � j � | j � | j j } Yn X| j | j
| | | f � | j � \ } } | d k r� | S| d k r2| \ } } | j j
| j d
} | j j | _ | | | j d | j d | j d | �}
| j | j d | j �} t | d d | j f � |
St | | � � d S( uW
Try to call a method of the referrent and return a copy of the result
u# thread %r does not own a connectionu #RETURNu #PROXYi u manageru authkeyu exposedu decrefNi����( u _tlsu
connectionu AttributeErroru utilu debugu threadingu current_threadu nameu _connectu sendu _idu recvu _manageru _registryu typeidu _tokenu addressu _serializeru _authkeyu _Clientu dispatchu Noneu idu convert_to_error( u selfu
methodnameu argsu kwdsu connu kindu resultu exposedu tokenu proxytypeu proxy( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu _callmethod� s,
u BaseProxy._callmethodc C s
| j d � S( u9
Get a copy of the value of the referent
u #GETVALUE( u _callmethod( u self( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu _getvalue� s u BaseProxy._getvaluec C s� | j | j j d | j �} t | d d | j f � t j d | j j � | j
j | j � | j or | j j
} t j | t j d | j | j | | j | j
| j f d d �| _ d S( Nu authkeyu increfu INCREF %ru argsu exitpriorityi
( u _Clientu _tokenu addressu _authkeyu dispatchu Noneu _idu utilu debugu idu _idsetu addu _manageru _stateu Finalizeu BaseProxyu _decrefu _tlsu _close( u selfu connu state( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu _incref� s u BaseProxy._increfc C s
| j | j � | d k s. | j t j k r� yE t j d | j � | | j d | �} t | d d | j f � Wq� t
k
r� } z t j d | � WYd d } ~ Xq� Xn t j d | j � | rt | d � rt j d t j
� j � | j j � | ` n d S( Nu DECREF %ru authkeyu decrefu ... decref failed %su% DECREF %r -- manager already shutdownu
connectionu- thread %r has no more proxies so closing conn( u discardu idu Noneu valueu Stateu STARTEDu utilu debugu addressu dispatchu Exceptionu hasattru threadingu current_threadu nameu
connectionu close( u tokenu authkeyu stateu tlsu idsetu _Clientu connu e( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu _decref� s &
u BaseProxy._decrefc C sT d | _ y | j � Wn6 t k
rO } z t j d | � WYd d } ~ Xn Xd S( Nu incref failed: %s( u Noneu _manageru _increfu Exceptionu utilu info( u selfu e( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu _after_fork s
u BaseProxy._after_forkc C s� i } t j � r" | j | d <n t | d d � r] | j | d <t t | j | j | f f St t
| � | j | j | f f Sd S( Nu authkeyu _isautou exposedF( u Popenu thread_is_spawningu _authkeyu getattru Falseu _exposed_u RebuildProxyu AutoProxyu _tokenu _serializeru type( u selfu kwds( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu
__reduce__ s
u BaseProxy.__reduce__c C s
| j � S( N( u _getvalue( u selfu memo( ( u= /opt/alt/python33/lib64/python3.3/multiprocessing/managers.pyu __deepcopy__, s u BaseProxy.__deepcopy__c C s* d t | � j | j j d t | � f S( Nu <%s object, typeid %r at %s>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 <module> s� .
� #
�
�