⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.30
Server IP:
45.79.8.107
Server:
Linux localhost 5.15.0-140-generic #150-Ubuntu SMP Sat Apr 12 06:00:09 UTC 2025 x86_64
Server Software:
nginx/1.18.0
PHP Version:
8.1.2-1ubuntu2.21
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3.10
/
multiprocessing
/
__pycache__
/
View File Name :
managers.cpython-310.pyc
o }5h @ sP g d Z ddlZddlZddlZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z ddlmZmZmZ ddl mZ dd l mZ dd l mZ dd l mZ zdd l mZ W n eyk d ZY nw dZe d dd Zeeje dd dD Z e d e urdd Z e D ]Z ee e qG dd de Z!di fddZ"d d Z#G d d d e$Z%d d! Z&d"d# Z'G d$d% d%e Z(G d&d' d'e Z)e j*e j+fe j,e j-fd(Z.G d)d* d*e Z/G d+d, d,e0Z1G d-d. d.e Z2d/d0 Z3i fd1d2Z4 dmd3d4Z5G d5d6 d6e Z6G d7d8 d8e Z7dnd9d:Z8G d;d< d<e2Z9G d=d> d>e2Z:G d?d@ d@e:Z;G dAdB dBe2Z<G dCdD dDe2Z=G dEdF dFe2Z>G dGdH dHe2Z?e4dIdJZ@G dKdL dLe@ZAe4dMdNZBdOdPieB_Ce4dQdRZDe4dSdTZEdUdUdUdPdPdVeE_CG dWdS dSeEZFG dXdY dYe/ZGeGdZejH eGd[ejH eGd\ejIe< eGd]ejJe: eGd^ejKe: eGd_ejLe: eGd`ejMe: eGdaejNe; eGdbejOe= eGdcejPeF eGdde eA eGdeeQeB eGd8e7e? eGd:e8eD eGd6e6e> eGjdPe9d df eGjdUd dg er&G dhdi diZRG djdk dke(ZSG dld de/ZTdS dS )o) BaseManager SyncManager BaseProxyToken N)getpid) format_exc ) connection) reductionget_spawning_popen ProcessError)pool)process)util) get_context) shared_memoryFTSharedMemoryManagerc C s t j | j| ffS N)arraytypecodetobytes)a r //usr/lib/python3.10/multiprocessing/managers.py reduce_array/ r c C s g | ] }t ti | qS r )typegetattr.0namer r r <listcomp>3 r! )itemskeysvaluesc C s t t | ffS r )listobjr r r rebuild_as_list5 r) c @ s4 e Zd ZdZdZdd Zdd Zdd Zd d Zd S ) r z3 Type to uniquely identify a shared object typeidaddressidc C s |||| _ | _| _d S r r+ )selfr, r- r. r r r __init__D s zToken.__init__c C s | j | j| jfS r r+ r/ r r r __getstate__G zToken.__getstate__c C s |\| _ | _| _d S r r+ r/ stater r r __setstate__J r zToken.__setstate__c C s d| j j| j| j| jf S )Nz %s(typeid=%r, address=%r, id=%r)) __class____name__r, r- r. r1 r r r __repr__M s zToken.__repr__N) r8 __module__ __qualname____doc__ __slots__r0 r2 r6 r9 r r r r r > s r r c C s4 | ||||f | \}}|dkr|S t||)zL Send a message to manager using connection `c` and return response #RETURN)sendrecvconvert_to_error)cr. methodnameargskwdskindresultr r r dispatchU s rH c C s^ | dkr|S | dv r(t |tstd|| t|| dkr$td| S t|S td| S )N#ERROR) #TRACEBACK#UNSERIALIZABLEz.Result {0!r} (kind '{1}') type is {2}, not strrK zUnserializable message: %s z Unrecognized message type {!r}) isinstancestr TypeErrorformatr RemoteError ValueError)rF rG r r r rA _ s rA c @ s e Zd Zdd ZdS )rP c C s dt | jd d S )NzM --------------------------------------------------------------------------- r zK---------------------------------------------------------------------------)rM rD r1 r r r __str__o s zRemoteError.__str__N)r8 r: r; rR r r r r rP n s rP c C s2 g }t | D ]}t| |}t|r|| q|S )z4 Return a list of names of methods of `obj` )dirr callableappend)r( tempr funcr r r all_methodsv s rX c C s dd t | D S )zP Return a list of names of methods of `obj` which do not start with '_' c S s g | ] }|d dkr|qS )r _r r r r r r! r" z"public_methods.<locals>.<listcomp>)rX r' r r r public_methods s rZ c @ s e Zd ZdZg dZdd Zdd Zdd Zd d Zd d Z d d Z dd Z dd Z dd Z e e e dZdd Zdd Zdd Zd d Zd d Zd d! Zd"d# Zd$d% Zd&d' Zd(S ))ServerzM Server class which runs in a process controlled by a manager object ) shutdowncreateaccept_connection get_methods debug_infonumber_of_objectsdummyincrefdecrefc C sx t |tstd|t||| _t|| _t | \}}||dd| _ | j j | _ ddi| _ i | _ i | _t | _d S )Nz&Authkey {0!r} is type {1!s}, not bytes )r- backlog0Nr )rL bytesrN rO r registryr AuthenticationStringauthkeylistener_clientlistenerr- id_to_objid_to_refcountid_to_local_proxy_obj threadingLockmutex)r/ rj r- rl serializerListenerClientr r r r0 s zServer.__init__c C s t | _| t _zGt j| jd}d|_| z| j s*| j d | j r W n t t fy6 Y nw W tjtjkrKtd tjt_tjt_td dS tjtjkretd tjt_tjt_td w )z( Run the server forever )targetTr zresetting stdout, stderrr N)rr Event stop_eventr current_process_manager_serverThreadaccepterdaemonstartis_setwaitKeyboardInterrupt SystemExitsysstdout __stdout__r debug __stderr__stderrexit)r/ r~ r r r serve_forever s2 zServer.serve_foreverc C sF z| j }W n ty Y q w tj| j|fd}d|_| q)NTrx rD )rn acceptOSErrorrr r} handle_requestr r )r/ rB tr r r r~ s zServer.accepterc C s: d }z*t || j t || j | }|\}}}}|| jv s&J d| t| |}W n ty: dt f}Y n!w z ||g|R i |} W n tyV dt f}Y nw d| f}z| | W d S ty } z-z | dt f W n ty~ Y nw t d| t d| t d| W Y d } ~ d S d } ~ ww )Nz%r unrecognizedrJ r> zFailure to send message: %rz ... request was %r ... exception was %r) r deliver_challengerl answer_challenger@ publicr Exceptionr r? r info) r/ rB requestignorefuncnamerD rE rW msgrG er r r _handle_request s< zServer._handle_requestc C sJ z z| | W n ty Y nw W | dS W | dS | w )z) Handle a new connection N)r r closer/ connr r r r s zServer.handle_requestc C s t dt j |j}|j}| j}| j sdzd }}| }|\}}} } z || \}} } W n& t yU } zz | j | \}} } W n t yJ | w W Y d} ~ nd} ~ ww || vret d|t || f t||}z || i | }W n ty } z d|f}W Y d}~n*d}~ww | o| |d}|r| |||\}}t|| j|}d||ff}nd|f}W n` t y |du rdt f}n(z| j| }|| |||g| R i | }d|f}W n ty dt f}Y nw Y n& ty t dt j td Y n ty dt f}Y nw zz|| W n ty) |d t f Y nw W n1 ty\ } z$t d t j t d | t d | | td W Y d}~nd}~ww | j rdS dS )zQ Handle requests from the proxies in a particular process/thread z$starting server thread to service %rNz+method %r of %r object is not in exposed=%rrI #PROXYr> rJ z$got EOF -- exiting thread serving %rr rK z exception in thread serving %rz ... message was %rr r )r r rr current_threadr r@ r? ro rz r KeyErrorrq AttributeErrorr r r getr] r r- r fallback_mappingEOFErrorr r r r )r/ r r@ r? ro rC r( r identrD rE exposed gettypeidkefunctionresr r r, ridentrexposedtoken fallback_funcrG r r r serve_client s zServer.serve_clientc C s |S r r r/ r r r( r r r fallback_getvalue? zServer.fallback_getvaluec C t |S r rM r r r r fallback_strB zServer.fallback_strc C r r )reprr r r r fallback_reprE r zServer.fallback_repr)rR r9 #GETVALUEc C s d S r r r/ rB r r r rb N r z Server.dummyc C s | j ; g }t| j }| |D ] }|dkr1|d|| j| t| j| d dd f qd|W d S 1 sAw Y dS )zO Return some info --- useful to spot problems with refcounting rg z %s: refcount=%s %sr NK ) rt r& rp r$ sortrU rM ro join)r/ rB rG r$ r r r r r` Q s $zServer.debug_infoc C s t | jS )z* Number of shared objects )lenrp r r r r ra a s zServer.number_of_objectsc C s` z)z t d |d W n ddl}| Y W | j dS W | j dS | j w )z' Shutdown this process z!manager received shutdown messager> Nr N)r r r? traceback print_excrz set)r/ rB r r r r r\ h s zServer.shutdownc O s | j q | j| \}}}}|du r"|st|dkr td|d } n||i |} |du r1t| }|durLt|tsDtd|t |t |t | }dt | } t d|| | t||f| j| < | | jvrmd| j| < W d n1 sww Y | || | t|fS )z> Create a new shared object and return its id Nr z4Without callable, must have one non-keyword argumentr z,Method_to_typeid {0!r}: type {1!s}, not dictz%xz&%r callable returned object with id %r)rt rj r rQ rZ rL dictrN rO r r& r. r r r ro rp rc tuple) r/ rB r, rD rE rT r method_to_typeid proxytyper( r r r r r] u s: z Server.createc C s t | j|j d S )zL Return the methods of the shared object indicated by token r )r ro r. )r/ rB r r r r r_ s zServer.get_methodsc C s" |t _|d | | dS )z= Spawn a new thread to serve this connection r N)rr r r r? r )r/ rB r r r r r^ s zServer.accept_connectionc C s | j R z | j| d7 < W n5 tyD } z)|| jv r8d| j|< | j| | j|< | j| \}}}td| n|W Y d }~n d }~ww W d d S W d d S 1 sXw Y d S )Nr z&Server re-enabled tracking & INCREF %r)rt rp r rq ro r r )r/ rB r r r( r r r r r rc s$ "z Server.increfc C s || j vr|| jv rtd| d S | j2 | j | dkr,td|| j| | j | | j | d8 < | j | dkr@| j |= W d n1 sJw Y || j vryd| j|< td| | j | j|= W d d S 1 srw Y d S d S )NzServer DECREF skipping %rr z+Id {0!s} ({1!r}) has refcount {2:n}, not 1+r )Nr Nzdisposing of obj with id %r)rp rq r r rt AssertionErrorrO ro )r/ rB r r r r rd s0 "z Server.decrefN)r8 r: r; r< r r0 r r~ r r r r r r r rb r` ra r\ r] r_ r^ rc rd r r r r r[ s2 Q $ r[ c @ s e Zd ZdgZdZdZdZdS )Statevaluer r N)r8 r: r; r= INITIALSTARTEDSHUTDOWNr r r r r s r )pickle xmlrpclibc @ s e Zd ZdZi ZeZ d"ddZdd Zdd Z d#d d Z e d#d dZ dd Z d$ddZdd Zdd Zdd Zdd Zedd Zed d Ze d%d d!ZdS )&r z! Base class for managers Nr c C s\ |d u r t j}|| _t || _t | _tj| j_ || _ t | \| _ | _ |p*t | _d S r )r r{ rl _addressrk _authkeyr _stater r _serializerrm _Listener_Clientr _ctx)r/ r- rl ru ctxr r r r0 s zBaseManager.__init__c C sb | j jtjkr&| j jtjkrtd| j jtjkr tdtd| j jt| j | j | j | j S )zX Return server object with serve_forever() method and address attribute Already started serverManager has shut downUnknown state {!r}) r r r r r r r rO r[ _registryr r r r1 r r r get_server s zBaseManager.get_serverc C s8 t | j \}}|| j| jd}t|dd tj| j_dS )z> Connect manager object to the server process rl Nrb ) rm r r r rH r r r r )r/ rv rw r r r r connect s zBaseManager.connectr c C s0 | j jtjkr&| j jtjkrtd| j jtjkr tdtd| j j|dur2t|s2t dt j dd\}}| j j t| j| j| j| j| j|||fd| _d d d | jjD }t| jd | | j_| j | | | _| tj| j _t j | t| j | j| j| j| j | j fd d| _ dS )z@ Spawn a server process for this manager object r r r Nz initializer must be a callableF)duplexr :c s s | ]}t |V qd S r r )r ir r r <genexpr>0 s z$BaseManager.start.<locals>.<genexpr>-r rD exitpriority)!r r r r r r r rO rT rN r Piper Processr _run_serverr r r r _processr _identityr8 r r r r@ r Finalize_finalize_managerr r\ )r/ initializerinitargsreaderwriterr r r r r s> zBaseManager.startc C s^ t t jt j |dur|| | ||||}||j | td|j | dS )z@ Create a server, report its address and run it Nzmanager serving at %r) signalSIGINTSIG_IGN_Serverr? r- r r r r ) clsrj r- rl ru r r r serverr r r r B s zBaseManager._run_serverc O sl | j jtjks J d| j| j| jd}zt|dd|f| |\}}W | n| w t || j||fS )zP Create a new shared object; return the token and exposed tuple zserver not yet startedr Nr] ) r r r r r r r rH r r )r/ r, rD rE r r. r r r r _createY s zBaseManager._createc C s2 | j dur| j | | j sd| _ dS dS dS )zC Join the manager process (if it has been spawned) N)r r is_aliver/ timeoutr r r r e s zBaseManager.joinc C 4 | j | j| jd}z t|ddW | S | w )zS Return some info about the servers shared objects and connections r Nr` r r r rH r r r r r _debug_infon zBaseManager._debug_infoc C r )z5 Return the number of shared objects r Nra r r r r r _number_of_objectsx r z BaseManager._number_of_objectsc C sf | j jtjkr | | j jtjkr1| j jtjkr td| j jtjkr(tdtd| j j| S )NzUnable to start serverr r ) r r r r r r r r rO r1 r r r __enter__ s zBaseManager.__enter__c C | d S r )r\ r/ exc_typeexc_valexc_tbr r r __exit__ zBaseManager.__exit__c C s | rYtd z|||d}z t|dd W | n| w W n ty, Y nw | jdd | rYtd t| drYtd | | jdd | rYtd t j |_ zt j |= W dS tyn Y dS w ) zQ Shutdown the manager process; will be registered as a finalizer z#sending shutdown message to managerr Nr\ g ?)r zmanager still alive terminatez'trying to `terminate()` manager processz#manager still alive after terminate)r r r rH r r r hasattrr r r r r _address_to_localr )r r- rl r5 r r r r r r s2 z BaseManager._finalize_managerc C | j S r )r r1 r r r r- s zBaseManager.addressTc s d| j vr | j | _ du rt |pt dd}|p t dd}|rFt| D ] \}}t|tu s9J d| t|tu sEJ d| q)||| f| j< |rc fdd} | _ t | | dS dS )z9 Register a typeid with the manager type r N _exposed__method_to_typeid_z%r is not a stringc sf t d | jg|R i |\}} || j| | j|d}| j|j| jd}t|d d|jf |S )Nz)requesting creation of a shared %r objectmanagerrl r r rd ) r r r r r r r- rH r. )r/ rD rE r expproxyr r r, r r rV s z"BaseManager.register.<locals>.temp) __dict__r copy AutoProxyr r& r# r rM r8 setattr) r r, rT r r r create_methodkeyr rV r r r register s& zBaseManager.register)NNr Nrh r )NNNNT)r8 r: r; r< r r[ r r0 r r r classmethodr r r r r r r staticmethodr propertyr- r r r r r r s6 + r c @ e Zd Zdd Zdd ZdS )ProcessLocalSetc C s t | dd d S )Nc S | S r )clearr' r r r <lambda> s z*ProcessLocalSet.__init__.<locals>.<lambda>)r register_after_forkr1 r r r r0 r zProcessLocalSet.__init__c C s t | dfS rh )r r1 r r r __reduce__ r zProcessLocalSet.__reduce__N)r8 r: r; r0 r' r r r r r" r" c @ s e Zd ZdZi Ze Z d ddZdd Z d i fd d Z d d Z dd Z e dd Zdd Zdd Zdd Zdd Zdd ZdS ) r z. A base for proxies of shared objects NTFc C s t j! t j|jd }|d u r t t f}|t j|j< W d n1 s'w Y |d | _|d | _ || _ | j j | _ || _ || _t| d | _|| _|d urYt|| _n| j d urd| j j| _nt j| _|rp| t| t j d S )Nr r )r _mutexr r r- r ForkAwareLocalr" _tls_idset_tokenr. _id_managerr rm r _owned_by_managerr rk r r{ rl _increfr& _after_fork) r/ r ru r rl r rc manager_owned tls_idsetr r r r0 s. zBaseProxy.__init__c C sd t d t j}t jdkr|dt j 7 }| j| jj | j d}t |d d|f || j _ d S )Nz making connection to manager MainThread|r r^ )r r r r{ r rr r r r- r- r rH r+ r )r/ r r r r r _connect s zBaseProxy._connectr c C s z| j j}W n ty tdt j | | j j}Y nw | | j |||f | \}}|dkr7|S |dkrm|\}}| j j |j d } | jj|_| || j| j | j|d} | j|j| jd}t|dd|jf | S t||) zV Try to call a method of the referent and return a copy of the result z#thread %r does not own a connectionr> r r r Nrd )r+ r r r r rr r r r7 r? r. r@ r/ r r, r- r- r r r rH r. rA ) r/ rC rD rE r rF rG r r r r r r r _callmethod% s2 zBaseProxy._callmethodc C | dS )z9 Get a copy of the value of the referent r r9 r1 r r r _getvalueC s zBaseProxy._getvaluec C s | j r td| jj d S | j| jj| jd}t|d d| j f td| jj | j | j | j o5| j j }tj| tj| j| j|| j| j | jfdd| _d S )Nz%owned_by_manager skipped INCREF of %rr rc z INCREF %r r )r0 r r r- r. r r- r rH r. r, addr/ r r r _decrefr+ _close)r/ r r5 r r r r1 I s zBaseProxy._increfc C s | | j |d u s|jtjkrBztd| j || j|d}t|d d| jf W n t yA } z td| W Y d }~n d }~ww td| j |sbt |drdtdt j |j |`d S d S d S )Nz DECREF %rr rd z... decref failed %sz%DECREF %r -- manager already shutdownr z-thread %r has no more proxies so closing conn)discardr. r r r r r r- rH r r rr r r r r )r rl r5 tlsidsetr r r r r r r? ] s$ zBaseProxy._decrefc C sJ d | _ z| W d S ty$ } ztd| W Y d }~d S d }~ww )Nzincref failed: %s)r/ r1 r r r )r/ r r r r r2 v s zBaseProxy._after_forkc C sZ i }t d ur | j|d< t| ddr!| j|d< tt| j| j|ffS tt| | j| j|ffS )Nrl _isautoFr ) r r r r RebuildProxyr r- r r r/ rE r r r r' ~ s zBaseProxy.__reduce__c C r# r )r< )r/ memor r r __deepcopy__ r zBaseProxy.__deepcopy__c C s dt | j| jjt| f S )Nz <%s object, typeid %r at %#x>)r r8 r- r, r. r1 r r r r9 s zBaseProxy.__repr__c C s4 z| dW S ty t| dd d Y S w )zV Return representation of the referent (or a fall-back if that fails) r9 Nr8 z; '__str__()' failed>)r9 r r r1 r r r rR s zBaseProxy.__str__NNNTF)r8 r: r; r< r r ForkAwareThreadLockr) r0 r7 r9 r< r1 r r? r2 r' rH r9 rR r r r r r s$ ) r c C s t t dd}|r*|j|jkr*td| d|d< |j|jvr*|j|j |j|j< | ddo8t t dd }| ||fd|i|S ) z5 Function used for unpickling proxy objects. r| Nz*Rebuild a proxy owned by manager, token=%rTr3 rc _inheritingF) r r r{ r- r r r. rq ro pop)rW r ru rE r rc r r r rE s rE c C sn t |}z|| |f W S ty Y nw i }|D ] }td||f | qt| tf|}||_||| |f< |S )zB Return a proxy type whose methods are given by `exposed` zOdef %s(self, /, *args, **kwds): return self._callmethod(%r, args, kwds))r r execr r r )r r _cachedicmeth ProxyTyper r r MakeProxyType s" rR c C s t | d }|du r%|| j|d}zt|dd| f}W | n| w |du r0|dur0|j}|du r9t j}td| j |} | | |||||d} d| _ | S )z* Return an auto-proxy for `token` r Nr r_ z AutoProxy[%s])r rl rc r3 T) rm r- rH r r r r{ rl rR r, rD ) r ru r rl r rc r3 r r rQ r r r r r s r c @ r! ) Namespacec K s | j | d S r )r updaterF r r r r0 r3 zNamespace.__init__c C sZ t | j }g }|D ]\}}|ds |d||f q | d| jjd|f S )NrY z%s=%rz%s(%s)z, ) r& r r# startswithrU r r7 r8 r )r/ r# rV r r r r r r9 s zNamespace.__repr__N)r8 r: r; r0 r9 r r r r rS r( rS c @ s8 e Zd Zd ddZdd Zdd Zdd ZeeeZd S ) ValueTc C || _ || _d S r ) _typecode_value)r/ r r lockr r r r0 zValue.__init__c C r r rY r1 r r r r s z Value.getc C s || _ d S r r\ r/ r r r r r z Value.setc C s dt | j| j| jf S )Nz %s(%r, %r))r r8 rX rY r1 r r r r9 s zValue.__repr__NT) r8 r: r; r0 r r r9 r r r r r r rV s rV c C s t | |S r )r )r sequencerZ r r r Array r ra c @ s8 e Zd ZdZdd Zdd Zdd Zdd Zd d Zd S ) IteratorProxy)__next__r? throwr c C | S r r r1 r r r __iter__ r zIteratorProxy.__iter__c G | d|S )Nrc r; r/ rD r r r rc r zIteratorProxy.__next__c G rg )Nr? r; rh r r r r? r zIteratorProxy.sendc G rg )Nrd r; rh r r r rd r zIteratorProxy.throwc G rg )Nr r; rh r r r r r zIteratorProxy.closeN) r8 r: r; r rf rc r? rd r r r r r rb s rb c @ s2 e Zd ZdZd ddZdd Zdd Zd d ZdS ) AcquirerProxy)acquirereleaseTNc C s" |d u r|fn||f}| d|S Nrj r; )r/ blockingr rD r r r rj s zAcquirerProxy.acquirec C r: Nrk r; r1 r r r rk r^ zAcquirerProxy.releasec C r: rl r; r1 r r r r r^ zAcquirerProxy.__enter__c C r: rn r; r r r r r r^ zAcquirerProxy.__exit__)TN)r8 r: r; r rj rk r r r r r r ri s ri c @ s6 e Zd ZdZd ddZd ddZdd Zd d d ZdS )ConditionProxy)rj rk r notify notify_allNc C | d|fS Nr r; r r r r r # r* zConditionProxy.waitr c C rr )Nrp r; )r/ nr r r rp % r* zConditionProxy.notifyc C r: )Nrq r; r1 r r r rq ' r^ zConditionProxy.notify_allc C sj | }|r|S |d urt | }nd }d }|s3|d ur)|t }|dkr) |S | | | }|r|S )Nr )time monotonicr )r/ predicater rG endtimewaittimer r r wait_for) s" zConditionProxy.wait_forr )r )r8 r: r; r r rp rq rz r r r r ro ! s ro c @ s2 e Zd ZdZdd Zdd Zdd Zd d d ZdS ) EventProxy)r r r$ r c C r: )Nr r; r1 r r r r > r^ zEventProxy.is_setc C r: Nr r; r1 r r r r @ r^ zEventProxy.setc C r: )Nr$ r; r1 r r r r$ B r^ zEventProxy.clearNc C rr rs r; r r r r r D r* zEventProxy.waitr )r8 r: r; r r r r$ r r r r r r{ < s r{ c @ sN e Zd ZdZdddZdd Zdd Zed d Zed d Z ed d Z dS ) BarrierProxy)__getattribute__r abortresetNc C rr rs r; r r r r r J r* zBarrierProxy.waitc C r: )Nr r; r1 r r r r L r^ zBarrierProxy.abortc C r: )Nr r; r1 r r r r N r^ zBarrierProxy.resetc C | ddS )Nr~ )partiesr; r1 r r r r P zBarrierProxy.partiesc C r )Nr~ ) n_waitingr; r1 r r r r S r zBarrierProxy.n_waitingc C r )Nr~ )brokenr; r1 r r r r V r zBarrierProxy.brokenr ) r8 r: r; r r r r r r r r r r r r r} H s r} c @ s( e Zd ZdZdd Zdd Zdd ZdS ) NamespaceProxy)r~ __setattr__ __delattr__c C s0 |d dkr t | |S t | d}|d|fS )Nr rY r9 r~ )objectr~ r/ r callmethodr r r __getattr__] zNamespaceProxy.__getattr__c C s4 |d dkr t | ||S t | d}|d||fS )Nr rY r9 r )r r r~ )r/ r r r r r r r b s zNamespaceProxy.__setattr__c C s0 |d dkr t | |S t | d}|d|fS )Nr rY r9 r )r r r~ r r r r r g r zNamespaceProxy.__delattr__N)r8 r: r; r r r r r r r r r [ s r c @ s4 e Zd ZdZdd Zdd ZeeeZee j Z dS ) ValueProxy)r r c C r: )Nr r; r1 r r r r p r^ zValueProxy.getc C rr r| r; r] r r r r r r* zValueProxy.setN) r8 r: r; r r r r r r types GenericAlias__class_getitem__r r r r r n s r BaseListProxy)__add__ __contains__ __delitem__ __getitem____len____mul__ __reversed____rmul__ __setitem__rU countextendindexinsertrL removereverser __imul__c @ r! ) ListProxyc C | d|f | S )Nr r; r] r r r __iadd__ zListProxy.__iadd__c C r )Nr r; r] r r r r r zListProxy.__imul__N)r8 r: r; r r r r r r r s r DictProxy)r r r rf r r r$ r r r# r$ rL popitem setdefaultrT r% rf Iterator ArrayProxy)r r r PoolProxy) apply apply_asyncr imapimap_unorderedr map map_asyncstarmap starmap_asyncr AsyncResult)r r r r r c @ r! )r c C re r r r1 r r r r r zPoolProxy.__enter__c C r r )r r r r r r r zPoolProxy.__exit__N)r8 r: r; r r r r r r r r( c @ s e Zd ZdZdS )r a( 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)r8 r: r; r< r r r r r s r Queue JoinableQueuery rs RLock SemaphoreBoundedSemaphore ConditionBarrierPoolr& r )r r )r c @ sL e Zd ZdZg fddZdd Zdd Zdd Zd d Zd d Z dd Z dS )_SharedMemoryTrackerz+Manages one or more shared memory segments.c C rW r shared_memory_context_name segment_names)r/ r r r r r r0 r[ z _SharedMemoryTracker.__init__c C s( t d|dt | j| dS )z6Adds the supplied shared memory block name to tracker.zRegister segment in pid N)r r r r rU r/ segment_namer r r register_segment s z%_SharedMemoryTracker.register_segmentc C sB t d|dt | j| t|}| | dS )zCalls unlink() on the shared memory block with the supplied name and removes it from the list of blocks being tracked.zDestroy segment r N) r r r r r r SharedMemoryr unlink)r/ r segmentr r r destroy_segment s z$_SharedMemoryTracker.destroy_segmentc C s" | j dd D ]}| | qdS )z<Calls destroy_segment() on all tracked shared memory blocks.N)r r r r r r r s z_SharedMemoryTracker.unlinkc C s( t d| jj dt | d S )NzCall z .__del__ in )r r r7 r8 r r r1 r r r __del__ s z _SharedMemoryTracker.__del__c C s | j | jfS r r r1 r r r r2 r z!_SharedMemoryTracker.__getstate__c C s | j | d S r )r0 r4 r r r r6 r* z!_SharedMemoryTracker.__setstate__N) r8 r: r; r< r0 r r r r r2 r6 r r r r r s r c @ sJ e Zd Zejg d Zdd Zdd Zdd Zdd Zd d Z d d Z dS )SharedMemoryServer) track_segmentrelease_segment list_segmentsc O s` t j| g|R i | | j}t|trt|}td| dt | _ t dt d S )Nshm_rY z"SharedMemoryServer started by pid ) r[ r0 r- rL ri osfsdecoder r shared_memory_contextr r )r/ rD kwargsr- r r r r0 s zSharedMemoryServer.__init__c O s: t | j| d dr| j|d< tj| ||g|R i |S )zCreate a new distributed-shared object (not backed by a shared memory block) and return its id to be used in a Proxy Object.r8 _shared_memory_proxyr )r rj r r[ r] )r/ rB r, rD r r r r r] s zSharedMemoryServer.createc C s | j t| |S )zACall unlink() on all tracked shared memory, terminate the Server.)r r r[ r\ r r r r r\ s zSharedMemoryServer.shutdownc C | j | dS )z?Adds the supplied shared memory block name to Server's tracker.N)r r r/ rB r r r r r s z SharedMemoryServer.track_segmentc C r )zCalls unlink() on the shared memory block with the supplied name and removes it from the tracker instance inside the Server.N)r r r r r r r s z"SharedMemoryServer.release_segmentc C s | j jS )zbReturns a list of names of shared memory blocks that the Server is currently tracking.)r r r r r r r s z SharedMemoryServer.list_segmentsN) r8 r: r; r[ r r0 r] r\ r r r r r r r r s r c @ s< e Zd ZdZeZdd Zdd Zdd Zdd Z d d Z d S ) r a Like SyncManager but uses SharedMemoryServer instead of Server. It provides methods for creating and returning SharedMemory instances and for creating a list-like object (ShareableList) backed by shared memory. It also provides methods that create and return Proxy Objects that support synchronization across processes (i.e. multi-process-safe locks and semaphores). c O sT t jdkrddlm} | tj| g|R i | t| j j dt d S )Nposixr )resource_trackerz created by pid ) r r r ensure_runningr r0 r r r7 r8 r )r/ rD r r r r r r0 / s z SharedMemoryManager.__init__c C s t | jj dt d S )Nz.__del__ by pid )r r r7 r8 r r1 r r r r ; s zSharedMemoryManager.__del__c C sd | j jtjkr&| j jtjkrtd| j jtjkr tdtd| j j| | j | j | j | j S )z@Better than monkeypatching for now; merge into Server ultimatelyz"Already started SharedMemoryServerz!SharedMemoryManager has shut downr ) r r r r r r r rO r r r r r r1 r r r r ? s z SharedMemoryManager.get_serverc C s | j | j| jd/}tjdd|d}z t|dd|jf W n ty/ } z| |d}~ww W d |S 1 s;w Y |S )zoReturns a new SharedMemory instance with the specified size in bytes, to be tracked by the manager.r NT)r] sizer ) r r r r r rH r BaseExceptionr )r/ r r smsr r r r r L s z SharedMemoryManager.SharedMemoryc C s | j | j| jd.}t|}z t|dd|jjf W n ty. } z|j |d}~ww W d |S 1 s:w Y |S )zReturns a new ShareableList instance populated with the values from the input sequence, to be tracked by the manager.r Nr ) r r r r ShareableListrH shmr r r )r/ r` r slr r r r r X s z!SharedMemoryManager.ShareableListN) r8 r: r; r< r r r0 r r r r r r r r r # s rI r_ )U__all__r rr r r queueru r r r r r r r contextr r r r r r r r ImportError HAS_SHMEMrU r r view_typesr& r) view_typer r rH rA r rP rX rZ r[ r rv rw XmlListener XmlClientrm r r r" r rE rR r rS rV ra rb ri ro r{ r} r r r r r r r BasePoolProxyr r r ry rs r r r r r r r r r r r r r r <module> s P w 4 %-