⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.177
Server IP:
50.6.168.112
Server:
Linux server-617809.webnetzimbabwe.com 5.14.0-570.25.1.el9_6.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Jul 9 04:57:09 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.4.10
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
usr
/
lib64
/
python3.9
/
multiprocessing
/
__pycache__
/
View File Name :
managers.cpython-39.opt-2.pyc
a DOgǸ @ sL 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 ey d ZY n0 dZe d dd Zeeje dd dD Z e d e ur8dd Z e D ]Z ee e q$G 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 fd1d2Z4dmd3d4Z5G 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 erHG dhdi diZRG djdk dke(ZSG dld de/ZTdS )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 0/usr/lib64/python3.9/multiprocessing/managers.py reduce_array/ s 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 s r( c @ s0 e Zd ZdZdd Zdd Zdd Zdd Zd S ) r 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 s zToken.__getstate__c C s |\| _ | _| _d S r r) r- stater r r __setstate__J s 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, r/ r r r __repr__M s zToken.__repr__N)r5 __module__ __qualname__ __slots__r. r0 r3 r6 r r r r r > s r r c C s8 | ||||f | \}}|dkr*|S t||d S )N#RETURN)sendrecvconvert_to_error)cr, methodnameargskwdskindresultr r r dispatchU s rD c C sd | dkr |S | dv rRt |ts4td|| t|| dkrHtd| S t|S ntd| S d S )N#ERROR) #TRACEBACK#UNSERIALIZABLEz.Result {0!r} (kind '{1}') type is {2}, not strrG zUnserializable message: %s z Unrecognized message type {!r}) isinstancestr TypeErrorformatr RemoteError ValueError)rB rC r r r r= _ s r= c @ s e Zd Zdd ZdS )rL c C s dt | jd d S )NzM --------------------------------------------------------------------------- r zK---------------------------------------------------------------------------)rI r@ r/ r r r __str__o s zRemoteError.__str__N)r5 r7 r8 rN r r r r rL n s rL c C s2 g }t | D ] }t| |}t|r || q |S r )dirr callableappend)r' tempr funcr r r all_methodsv s rT c C s dd t | D S )Nc S s g | ]}|d dkr|qS )r _r r r r r r r! z"public_methods.<locals>.<listcomp>)rT r& r r r public_methods s rV c @ s e Zd Zg dZdd Zdd Zdd Zdd Zd d Zd d Z dd Z dd Z e e e dZ dd Z dd Zdd Zdd Zdd Zd d Zd d Zd!d" Zd#d$ Zd%S )&Server) shutdowncreateaccept_connection get_methods debug_infonumber_of_objectsdummyincrefdecrefc C sx t |ts td|t||| _t|| _t | \}}||dd| _ | j j | _ ddi| _ i | _ i | _t | _d S )Nz&Authkey {0!r} is type {1!s}, not bytes )r+ backlog0Nr )rH bytesrJ rK r registryr AuthenticationStringauthkeylistener_clientlistenerr+ id_to_objid_to_refcountid_to_local_proxy_obj threadingLockmutex)r- rf r+ rh serializerListenerClientr r r r. s zServer.__init__c C s t | _| t _zt j| jd}d|_| z | j sL| j d q4W n t t fyd Y n0 W tjtjkrtd tjt_tjt_td n2tjtjkrtd tjt_tjt_td 0 d S )N)targetTr zresetting stdout, stderrr )rn Event stop_eventr current_process_manager_serverThreadaccepterdaemonstartis_setwaitKeyboardInterrupt SystemExitsysstdout __stdout__r debug __stderr__stderrexit)r- rz r r r serve_forever s* zServer.serve_foreverc C sL z| j }W n ty$ Y q Y n0 tj| j|fd}d|_| q d S )Nrt r@ T)rj acceptOSErrorrn ry handle_requestr{ r| )r- r> tr r r rz s zServer.accepterc C s6 d } }}z>t || j t || j | }|\}}}}t| |}W n tyf dt f} Y nB0 z||g|R i |}W n ty dt f} Y n 0 d|f} z|| W nr ty( } zXz|dt f W n ty Y n0 t d| t d| t d| W Y d } ~ n d } ~ 0 0 | d S )NrF r: zFailure to send message: %rz ... request was %r ... exception was %r) r deliver_challengerh answer_challenger< r Exceptionr r; r infoclose) r- r> funcnamerC requestignorer@ rA rS msger r r r s2 "zServer.handle_requestc C s t dt j |j}|j}| j}| j sΐz:d }}| }|\}}} } z|| \}} } W nP t y } z8z| j | \}} } W n t y | Y n0 W Y d } ~ n d } ~ 0 0 || vrt d|t || f t||}z|| i | }W n. ty } zd|f}W Y d }~nXd }~0 0 | o,| |d }|rb| |||\}}t|| j|}d||ff}nd|f}W n t y |d u rdt f}nRz2| j| }|| |||g| R i | }d|f}W n ty dt f}Y n0 Y nL ty t dt j td Y n ty2 dt f}Y n0 z4z || W n" tyd |d t f Y n0 W q$ ty } zHt d t j t d | t d | | td W Y d }~q$d }~0 0 q$d S )Nz$starting server thread to service %rz+method %r of %r object is not in exposed=%rrE #PROXYr: rF z$got EOF -- exiting thread serving %rr rG z exception in thread serving %rz ... message was %rr r )r r rn current_threadr r< r; rk rv r} KeyErrorrm AttributeErrorr r r getrY r r+ r fallback_mappingEOFErrorr r r r )r- connr< r; rk r? r' r identr@ rA exposed gettypeidkefunctionresr r r* ZridentZrexposedtokenZ fallback_funcrC r r r serve_client s zServer.serve_clientc C s |S r r r- r r r' r r r fallback_getvalue7 s zServer.fallback_getvaluec C s t |S r rI r r r r fallback_str: s zServer.fallback_strc C s t |S r )reprr r r r fallback_repr= s zServer.fallback_repr)rN r6 #GETVALUEc C s d S r r r- r> r r r r^ F s z Server.dummyc C s | j v g }t| j }| |D ]<}|dkr&|d|| j| t| j| d d d f q&d|W d S 1 s0 Y d S )Nrc z %s: refcount=%s %sr K ) rp r% rl r# sortrQ rI rk join)r- r> rC r# r r r r r\ I s zServer.debug_infoc C s t | jS r )lenrl r r r r r] Y s zServer.number_of_objectsc C sV zDzt d |d W n dd l}| Y n0 W | j n | j 0 d S )Nz!manager received shutdown messager: Nr )r r r; traceback print_excrv set)r- r> r r r r rX ` s zServer.shutdownc O s | j | j| \}}}}|d u rD|s2t|dkr:td|d } n||i |} |d u rbt| }|d urt|tstd|t |t |t | }dt | } t d|| | t||f| j| < | | jvrd| j| < W d n1 s0 Y | || | t|fS )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)rp rf r rM rV rH dictrJ rK r r% r, r r r rk rl r_ tuple) r- r> r* r@ rA rP r method_to_typeid proxytyper' r r r r rY m s6 ( z Server.createc C s t | j|j d S )Nr )r rk r, )r- r> r r r r r[ s zServer.get_methodsc C s" |t _|d | | d S )Nr )rn r r r; r )r- r> r r r r rZ s zServer.accept_connectionc C s | j z| j| d7 < W nj ty } zR|| jv rpd| j|< | j| | j|< | j| \}}}td| n|W Y d }~n d }~0 0 W d n1 s0 Y d S )Nr z&Server re-enabled tracking & INCREF %r)rp rl r rm rk r r )r- r> r r r' r r r r r r_ s z Server.increfc C s || j vr$|| jv r$td| d S | jd | j | dkrXtd|| j| | j | | j | d8 < | j | dkr| j |= W d n1 s0 Y || j vrd| j|< td| | j | j|= W d n1 s0 Y 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)rl rm r r rp AssertionErrorrK rk )r- r> r r r r r` s* & z Server.decrefN)r5 r7 r8 publicr. r rz r r r r r r r^ r\ r] rX rY r[ rZ r_ r` r r r r rW s, "Q $rW c @ s e Zd ZdgZdZdZdZdS )Statevaluer r N)r5 r7 r8 r9 INITIALSTARTEDSHUTDOWNr r r r r s r )pickle xmlrpclibc @ s e Zd Zi ZeZd!ddZdd Zdd Zd"d d Z e d#d d Z dd Z d$ddZ dd Zdd Zdd Zdd Zedd Zed d Ze d%d d ZdS )&r Nr c C s\ |d u rt j}|| _t || _t | _tj| j_ || _ t | \| _ | _ |pTt | _d S r )r rw rh _addressrg _authkeyr _stater r _serializerri Z _Listener_Clientr _ctx)r- r+ rh rq ctxr r r r. s zBaseManager.__init__c C sf | j jtjkrP| j jtjkr&tdn*| j jtjkr>tdntd| j jt| j | j | j | j S )NAlready started serverManager has shut downUnknown state {!r}) r r r r r r r rK rW _registryr r r r/ r r r get_server s zBaseManager.get_serverc C s8 t | j \}}|| j| jd}t|d d tj| j_d S )Nrh r^ ) ri r r r rD r r r r )r- rr rs r r r r connect s zBaseManager.connectr c C s4 | j jtjkrP| j jtjkr&tdn*| j jtjkr>tdntd| j j|d urht|sht dt j dd\}}| j j t| j| j| j| j| j|||fd| _dd d | jjD }t| jd | | j_| j | | | _| tj| j _t j | t| j | j| j| j| j | j fd d | _ d S )Nr r r z initializer must be a callableF)duplexr :c s s | ]}t |V qd S r r )r ir r r <genexpr>( r! z$BaseManager.start.<locals>.<genexpr>-r r@ exitpriority)!r r r r r r r rK rP rJ r Piper Processr _run_serverr r r r _processr _identityr5 r r| r r< r Finalize_finalize_managerr rX )r- initializerinitargsreaderwriterr r r r r| s> zBaseManager.startc C s^ t t jt j |d ur || | ||||}||j | td|j | d S )Nzmanager serving at %r) signalSIGINTSIG_IGN_Serverr; r+ r r r r ) clsrf r+ rh rq r r r serverr r r r : s zBaseManager._run_serverc O sV | j | j| jd}z&t|d d|f| |\}}W | n | 0 t|| j||fS )Nr rY )r r r rD r r )r- r* r@ rA r r, r r r r _createQ s zBaseManager._createc C s* | j d ur&| j | | j s&d | _ d S r )r r is_aliver- timeoutr r r r ] s zBaseManager.joinc C s8 | j | j| jd}zt|d dW | S | 0 d S )Nr r\ r r r rD r r- r r r r _debug_infof s zBaseManager._debug_infoc C s8 | j | j| jd}zt|d dW | S | 0 d S )Nr r] r r r r r _number_of_objectsp s z BaseManager._number_of_objectsc C sj | j jtjkr| | j jtjkrf| j jtjkr<tdn*| j jtjkrTtdntd| j j| S )NzUnable to start serverr r ) r r r r r| r r r rK r/ r r r __enter__z s zBaseManager.__enter__c C s | d S r )rX r- exc_typeexc_valexc_tbr r r __exit__ s zBaseManager.__exit__c C s | rtd z4|||d}zt|d d W | n | 0 W n tyX Y n0 | jdd | rtd t| drtd | | jdd | rtd t j |_ z t j |= W n ty Y n0 d S ) Nz#sending shutdown message to managerr rX g ?)r zmanager still alive terminatez'trying to `terminate()` manager processz#manager still alive after terminate)r r r rD r r r hasattrr r r r r _address_to_localr )r r+ rh r2 r r r r r r s. z BaseManager._finalize_managerc C s | j S r )r r/ r r r r+ s zBaseManager.addressTc s d| j vr| j | _ d u r"t |p0t dd }|p@t dd }|r\t| D ]\}}qR||| f| j< |r fdd} | _t| | d S )Nr _exposed__method_to_typeid_c sf t d | jg|R i |\}} || j| | j|d}| j|j| jd}t|d d|jf |S )Nz)requesting creation of a shared %r objectmanagerrh r r r` ) r r r r r r r+ rD r, )r- r@ rA r expproxyr r r* r r rR s z"BaseManager.register.<locals>.temp) __dict__r copy AutoProxyr r% r" r5 setattr) r r* rP r r r create_methodkeyr rR r r r register s" zBaseManager.register)NNr N)Nr )Nr )N)NNNNT)r5 r7 r8 r rW r r. r r r| classmethodr r r r r r r staticmethodr propertyr+ r r r r r r s2 + r c @ s e Zd Zdd Zdd ZdS )ProcessLocalSetc C s t | dd d S )Nc S s | S r )clearr& r r r <lambda> r! z*ProcessLocalSet.__init__.<locals>.<lambda>)r register_after_forkr/ r r r r. s zProcessLocalSet.__init__c C s t | dfS rd )r r/ r r r __reduce__ s zProcessLocalSet.__reduce__N)r5 r7 r8 r. r r r r r r s r c @ s| e Zd Zi Ze ZdddZdd Zdi fd d Z d d Z d d Z e dd Z dd Zdd Zdd Zdd Zdd ZdS ) r NTFc C s t jB t j|jd }|d u r:t t f}|t j|j< W d n1 sN0 Y |d | _|d | _ || _ | j j | _ || _ || _t| d | _|| _|d urt|| _n"| j d ur| j j| _n t j| _|r| t| t j d S )Nr r )r _mutexr r r+ r ForkAwareLocalr _tls_idset_tokenr, _id_managerr ri r _owned_by_managerr rg r rw rh _increfr _after_fork) r- r rq r rh r r_ manager_ownedZ tls_idsetr r r r. s* * zBaseProxy.__init__c C sd t d t j}t jdkr4|dt j 7 }| j| jj | j d}t |d d|f || j _ d S )Nz making connection to manager MainThread|r rZ )r r r rw r rn r r r r+ r rD r r )r- r r r r r _connect s zBaseProxy._connectr c C s z | j j}W n4 ty@ tdt j | | j j}Y n0 | | j |||f | \}}|dkrn|S |dkr|\}}| j j |j d } | jj|_| || j| j | j|d} | j|j| jd}t|d d|jf | S t||d S )Nz#thread %r does not own a connectionr: r r r r` )r r r r r rn r r r" r; r r< r r r* r r+ r r r rD r, r= ) r- r? r@ rA r rB rC r r r r r r r _callmethod s0 zBaseProxy._callmethodc C s | dS )Nr r$ r/ r r r _getvalue; s zBaseProxy._getvaluec C s | j rtd| jj d S | j| jj| jd}t|d d| j f td| jj | j | j | j oj| j j }tj| tj| j| j|| j| j | jfdd| _d S )Nz%owned_by_manager skipped INCREF of %rr r_ z INCREF %r r )r r r r r, r r+ r rD r r addr r r r _decrefr _close)r- r r2 r r r r A s zBaseProxy._increfc C s | | j |d u s |jtjkrz2td| j || j|d}t|d d| jf W q t y } ztd| W Y d }~qd }~0 0 ntd| j |st |drtdt j |j |`d S )Nz DECREF %rr r` 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+ rD r r rn r r r r )r rh r2 ZtlsZidsetr r r r r r r) U s $ zBaseProxy._decrefc C sJ d | _ z | W n2 tyD } ztd| W Y d }~n d }~0 0 d S )Nzincref failed: %s)r r r r r )r- r r r r r n s zBaseProxy._after_forkc C s^ i }t d ur| j|d< t| ddrB| j|d< tt| j| j|ffS tt| | j| j|ffS d S )Nrh _isautoFr ) r r r r RebuildProxyr r r r r- rA r r r r v s zBaseProxy.__reduce__c C s | S r )r& )r- memor r r __deepcopy__ s zBaseProxy.__deepcopy__c C s dt | j| jjt| f S )Nz <%s object, typeid %r at %#x>)r r5 r r* r, r/ r r r r6 s zBaseProxy.__repr__c C s8 z | dW S ty2 t| d d d Y S 0 d S )Nr6 r# z; '__str__()' failed>)r$ r r r/ r r r rN s zBaseProxy.__str__)NNNTF)r5 r7 r8 r r ForkAwareThreadLockr r. r" r$ r& r r r) r r r0 r6 rN r r r r r s ) r c C s t t dd }|rT|j|jkrTtd| d|d< |j|jvrT|j|j |j|j< | ddopt t dd }| ||fd|i|S )Nrx z*Rebuild a proxy owned by manager, token=%rTr r_ Z _inheritingF) r r rw r+ r r r, rm rk pop)rS r rq rA r r_ r r r r- s r- c C sn t |}z|| |f W S ty( Y n0 i }|D ]}td||f | q2t| tf|}||_||| |f< |S )NzOdef %s(self, /, *args, **kwds): return self._callmethod(%r, args, kwds))r r execr r r )r r _cacheZdicmeth ProxyTyper r r MakeProxyType s r7 c C s t | d }|d u rJ|| j|d}z t|d d| f}W | n | 0 |d u r`|d ur`|j}|d u rrt j}td| j |} | | |||||d} d| _ | S )Nr r r[ z AutoProxy[%s])r rh r_ r T) ri r+ rD r r r rw rh r7 r* r, ) r rq r rh r r_ r r r r6 r r r r r s r c @ s e Zd Zdd Zdd ZdS ) Namespacec K s | j | d S r )r updater. r r r r. s zNamespace.__init__c C sZ t | j }g }|D ]$\}}|ds|d||f q| d| jjd|f S )NrU z%s=%rz%s(%s)z, ) r% r r" startswithrQ r r4 r5 r )r- r" rR r r r r r r6 s zNamespace.__repr__N)r5 r7 r8 r. r6 r r r r r8 s r8 c @ s8 e Zd Zd ddZdd Zdd Zdd ZeeeZd S ) ValueTc C s || _ || _d S r ) _typecode_value)r- r r lockr r r r. s zValue.__init__c C s | j S r r= r/ r r r r s z Value.getc C s || _ d S r r? r- r r r r r s z Value.setc C s dt | j| j| jf S )Nz %s(%r, %r))r r5 r< r= r/ r r r r6 s zValue.__repr__N)T) r5 r7 r8 r. r r r6 r r r r r r r; s r; c C s t | |S r )r )r sequencer> r r r Array s rB c @ s8 e Zd ZdZdd Zdd Zdd Zdd Zd d Zd S ) IteratorProxy)__next__r; throwr c C s | S r r r/ r r r __iter__ s zIteratorProxy.__iter__c G s | d|S )NrD r% r- r@ r r r rD s zIteratorProxy.__next__c G s | d|S )Nr; r% rG r r r r; s zIteratorProxy.sendc G s | d|S )NrE r% rG r r r rE s zIteratorProxy.throwc G s | d|S )Nr r% rG r r r r s zIteratorProxy.closeN) r5 r7 r8 r rF rD r; rE r r r r r rC s rC c @ s2 e Zd ZdZd ddZdd Zdd Zd d ZdS ) AcquirerProxy)acquirereleaseTNc C s" |d u r|fn||f}| d|S NrI r% )r- blockingr r@ r r r rI s zAcquirerProxy.acquirec C s | dS NrJ r% r/ r r r rJ s zAcquirerProxy.releasec C s | dS rK r% r/ r r r r s zAcquirerProxy.__enter__c C s | dS rM r% r r r r r s zAcquirerProxy.__exit__)TN)r5 r7 r8 r rI rJ r r r r r r rH s rH c @ s6 e Zd ZdZd ddZd ddZdd Zdd d ZdS )ConditionProxy)rI rJ r~ notify notify_allNc C s | d|fS Nr~ r% r r r r r~ s zConditionProxy.waitr c C s | d|fS )NrO r% )r- nr r r rO s zConditionProxy.notifyc C s | dS )NrP r% r/ r r r rP s zConditionProxy.notify_allc C sd | }|r|S |d ur$t | }nd }d }|s`|d urN|t }|dkrNq`| | | }q,|S )Nr )time monotonicr~ )r- predicater rC endtimewaittimer r r wait_for! s zConditionProxy.wait_for)N)r )N)r5 r7 r8 r r~ rO rP rX r r r r rN s rN c @ s2 e Zd ZdZdd Zdd Zdd Zd d d ZdS ) EventProxy)r} r r r~ c C s | dS )Nr} r% r/ r r r r} 6 s zEventProxy.is_setc C s | dS Nr r% r/ r r r r 8 s zEventProxy.setc C s | dS )Nr r% r/ r r r r : s zEventProxy.clearNc C s | d|fS rQ r% r r r r r~ < s zEventProxy.wait)N)r5 r7 r8 r r} r r r~ r r r r rY 4 s rY c @ sN e Zd ZdZdddZdd Zdd Zed d Zed d Z ed d Z dS ) BarrierProxy)__getattribute__r~ abortresetNc C s | d|fS rQ r% r r r r r~ B s zBarrierProxy.waitc C s | dS )Nr] r% r/ r r r r] D s zBarrierProxy.abortc C s | dS )Nr^ r% r/ r r r r^ F s zBarrierProxy.resetc C s | ddS )Nr\ )partiesr% r/ r r r r_ H s zBarrierProxy.partiesc C s | ddS )Nr\ ) n_waitingr% r/ r r r r` K s zBarrierProxy.n_waitingc C s | ddS )Nr\ )brokenr% r/ r r r ra N s zBarrierProxy.broken)N) r5 r7 r8 r r~ r] r^ r r_ r` ra r r r r r[ @ s r[ c @ s( e Zd ZdZdd Zdd Zdd ZdS ) NamespaceProxy)r\ __setattr__ __delattr__c C s0 |d dkrt | |S t | d}|d|fS )Nr rU r$ r\ )objectr\ r- r callmethodr r r __getattr__U s zNamespaceProxy.__getattr__c C s4 |d dkrt | ||S t | d}|d||fS )Nr rU r$ rc )re rc r\ )r- r r rg r r r rc Z s zNamespaceProxy.__setattr__c C s0 |d dkrt | |S t | d}|d|fS )Nr rU r$ rd )re rd r\ rf r r r rd _ s zNamespaceProxy.__delattr__N)r5 r7 r8 r rh rc rd r r r r rb S s rb c @ s4 e Zd ZdZdd Zdd ZeeeZee j Z dS ) ValueProxy)r r c C s | dS )Nr r% r/ r r r r h s zValueProxy.getc C s | d|fS rZ r% r@ r r r r j s zValueProxy.setN) r5 r7 r8 r r r r r r types GenericAlias__class_getitem__r r r r ri f s ri BaseListProxy)__add__ __contains__ __delitem__ __getitem____len____mul__ __reversed____rmul__ __setitem__rQ countextendindexinsertr2 removereverser __imul__c @ s e Zd Zdd Zdd ZdS ) ListProxyc C s | d|f | S )Nrx r% r@ r r r __iadd__x s zListProxy.__iadd__c C s | d|f | S )Nr} r% r@ r r r r} { s zListProxy.__imul__N)r5 r7 r8 r r} r r r r r~ w s r~ DictProxy)ro rp rq rF rr rv r r r r" r# r2 popitem setdefaultr9 r$ rF Iterator ArrayProxy)rr rq rv PoolProxy) Zapply apply_asyncr imapimap_unorderedr map map_asyncstarmap starmap_asyncr Z AsyncResult)r r r r r c @ s e Zd Zdd Zdd ZdS )r c C s | S r r r/ r r r r s zPoolProxy.__enter__c C s | d S r )r r r r r r s zPoolProxy.__exit__N)r5 r7 r8 r r r r r r r s c @ s e Zd ZdS )r N)r5 r7 r8 r r r r r s r Queue JoinableQueueru ro RLock SemaphoreBoundedSemaphore ConditionBarrierPoolr% r )r r )r c @ sH e Zd Zg fddZdd Zdd Zdd Zd d Zd d Zd d Z dS )_SharedMemoryTrackerc C s || _ || _d S r Zshared_memory_context_name segment_names)r- r r r r r r. s z _SharedMemoryTracker.__init__c C s( t d|dt | j| d S )NzRegister segment in pid )r r r r rQ r- segment_namer r r register_segment s z%_SharedMemoryTracker.register_segmentc C sB t d|dt | j| t|}| | d S )NzDestroy segment r ) r r r r r{ r SharedMemoryr unlink)r- r Zsegmentr r r destroy_segment s z$_SharedMemoryTracker.destroy_segmentc C s" | j d d D ]}| | qd S r )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 r4 r5 r r r/ r r r __del__ s z _SharedMemoryTracker.__del__c C s | j | jfS r r r/ r r r r0 s z!_SharedMemoryTracker.__getstate__c C s | j | d S r )r. r1 r r r r3 s z!_SharedMemoryTracker.__setstate__N) r5 r7 r8 r. r r r r r0 r3 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|tr2t|}td| dt | _ t dt d S )NZshm_rU z"SharedMemoryServer started by pid ) rW r. r+ rH re osfsdecoder r shared_memory_contextr r )r- r@ kwargsr+ r r r r. s zSharedMemoryServer.__init__c O s: t | j| d dr | j|d< tj| ||g|R i |S )Nr# Z_shared_memory_proxyr )r rf r rW rY )r- r> r* r@ r r r r rY s zSharedMemoryServer.createc C s | j t| |S r )r r rW rX r r r r rX s zSharedMemoryServer.shutdownc C s | j | d S r )r r r- r> r r r r r s z SharedMemoryServer.track_segmentc C s | j | d S r )r r r r r r r s z"SharedMemoryServer.release_segmentc C s | j jS r )r r r r r r r s z SharedMemoryServer.list_segmentsN) r5 r7 r8 rW r r. rY rX r r r r r r r r s r c @ s8 e Zd ZeZdd Zdd Zdd Zdd Zd d Z d S ) r c O sT t jdkr ddlm} | tj| g|R i | t| j j dt d S )Nposixr )resource_trackerz created by pid ) r r r Zensure_runningr r. r r r4 r5 r )r- r@ r r r r r r. ' s z SharedMemoryManager.__init__c C s t | jj dt d S )Nz.__del__ by pid )r r r4 r5 r r/ r r r r 3 s zSharedMemoryManager.__del__c C sh | j jtjkrP| j jtjkr&tdn*| j jtjkr>tdntd| j j| | j | j | j | j S )Nz"Already started SharedMemoryServerz!SharedMemoryManager has shut downr ) r r r r r r r rK r r r r r r/ r r r r 7 s z SharedMemoryManager.get_serverc C s | j | j| jdh}tjd d|d}zt|d d|jf W n0 tyj } z| |W Y d }~n d }~0 0 W d n1 s0 Y |S )Nr T)rY sizer ) r r r r r rD r BaseExceptionr )r- r r Zsmsr r r r r D s 8z SharedMemoryManager.SharedMemoryc C s | j | j| jdf}t|}zt|d d|jjf W n2 tyh } z|j |W Y d }~n d }~0 0 W d n1 s~0 Y |S )Nr r ) r r r r ShareableListrD Zshmr r r )r- rA r slr r r r r P s 8z!SharedMemoryManager.ShareableListN) r5 r7 r8 r r r. r r r r r r r r r s )NNNTF)T)U__all__r rn r r queuerS rj r r r r r r contextr r r r r r r r ImportErrorZ HAS_SHMEMrQ r r Z view_typesr% r( Z view_typere r rD r= r rL rT rV rW r rr rs XmlListener XmlClientri r r r r r- r7 r r8 r; rB rC rH rN rY r[ rb ri rm r~ r r r Z BasePoolProxyr r r ru ro r r r r r r r r r r r r r r <module> s H w 4 %-