File manager

�
{fc@s�
dd
lZdd
l
Z
dd
lZddlmZmZ
ddlmZmZ
dddddd	gZ	ie
j
d
6e
jd6e
jd6e
j
d
6e
jd6e
jd6e
jd6e
jd6e
jd6e
jd6e
jd6Zye
jed<Wnek
r



n
Xd�Zd�Zd�Zd�Zd�Zd�Zd
d�
Zd�Z d�Z!d�Z"d Z#iZ$ej%�Z&d!e'f
d"��YZ(d#e(f
d$��YZ)d%e(f
d&��YZ*d'e*f
d(��YZ+d
S()i����N(theaptRLock(tassert_spawningtForkingPicklertRawValuetRawArraytValuetArraytcopytsynchronizedt
ct
bt
Bt
ht
Ht
it
It
lt
Lt
ft
dt
uc
Cs.tj
|�
}
tj|
�
}t||d�S(
N(tctypestsizeofRt
BufferWrappert
rebuild_ctypetNone(ttype_tsizetwrapper((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyt
_new_valueBs


c
GsTtj
||�}t|�
}tjtj|�
d
tj|�
�
|j|
�
|S(s>
    Returns a ctypes object allocated from shared memory
    i(ttypecode_to_typetgetRRtmemsett	addressofRt__init__(ttypecode_or_typetargsRtobj((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyRGs


%


cCs�tj
||�}t|
ttf�rf||
}t|�
}tjtj|�
d
tj	|�
�
|S|t
|
�
}t|�
}|j|
�
|SdS(s=
    Returns a ctypes array allocated from shared memory
    iN(RR t
isinstancetinttlongRRR!R"RtlenR#(R$tsize_or_initializerRR&tresult((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyRQs




%




c
Os�|jd
d�}|r1td|j��
�
nt||
�
}|tkrP|S|tdfkrnt�}nt|d�s�t	d|�
�
nt
||�S(s6
    Return a synchronization wrapper for a Value
    tlocks$unrecognized keyword argument(s): %stacquires'%r' has no method 'acquire'N(tpopRt
ValueErrortkeysRtFalsetTrueR
thasattrtAttributeErrorR	(R$R%tkwdsR-R&((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyRas









cKs�|jd
d�}|r1td|j��
�
nt||
�}|tkrP|S|tdfkrnt�}nt|d�s�t	d|�
�
nt
||�S(s9
    Return a synchronization wrapper for a RawArray
    R-s$unrecognized keyword argument(s): %sR.s'%r' has no method 'acquire'N(R/RR0R1RR2R3R
R4R5R	(R$R+R6R-R&((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyRqs









c
Cs)tt
|�
�
}
|tj|
�
d
<|
S(Ni(RttypeRtpointer(R&tnew_obj((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyR�s


cCs
t|t
�std
�
�
t|tj�r;t||
�St|tj�ry|jtjkrlt	||
�St
||
�St|�
}yt|}Wnqt
k
r



g|jD]}|d^q�}td�|D�
�
}d|j}t|t
f
|�}t|<n
X|||
�SdS(Nsobject already synchronizedic
ss!|]}
|
t|
�
fV
qdS(
N(
t
make_property(t.0tname((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pys	<genexpr>�stSynchronized(R'tSynchronizedBasetAssertionErrorRt_SimpleCDataR=Rt_type_tc_chartSynchronizedStringtSynchronizedArrayR7tclass_cachetKeyErrort_fields_tdictt__name__(R&R-tclstsclstfieldtnamesRt	classname((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyR	�s 













 



!
c

CsXt|�

t
|tj�r8t|j|j|jffStt|�
|jdffSdS(
N(
RR'RRRRAt_wrappert_length_R7R(
R&((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pytreduce_ctype�s



cCsK|dk	r||}nt
j|t�
|j|
j��
}|
|_|S(
N(RRtregisterRQtfrom_addresstget_addressRO(RRtlengthR&((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyR�s





	
c
BsPye|SWn=e
k
rK


i}
e|f
d
|
U|
|e|<|
|SXdS(Ni(t
prop_cacheRFttemplate(R<R((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyR:�s







s�
def get%s(self):
    self.acquire()
    try:
        return self._obj.%s
    finally:
        self.release()
def set%s(self, value):
    self.acquire()
    try:
        self._obj.%s = value
    finally:
        self.release()
%s = property(get%s, set%s)
R>cBs8eZ
dd�
Zd
�Zd�Zd�Zd�ZRS(cCs=|
|_|pt
�|_|jj|_|jj|_dS(
N(t_objR
t_lockR.trelease(tselfR&R-((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyR#�s
	


c

Cs t|�

t
|j|jffS(
N(RR	RXRY(
R[((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyt
__reduce__�s


c


Cs|jS(
N(
RX(
R[((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pytget_obj�s
c


Cs|jS(
N(
RY(
R[((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pytget_lock�s
c

Csd
t|�
j
|jfS(Ns<%s wrapper for %s>(R7RIRX(
R[((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyt__repr__�s
N(RIt
__module__RR#R\R]R^R_(((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyR>�s
			R=cBseZ
ed�
ZRS(
tvalue(RIR`R:Ra(((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyR=�s
RDc
Bs5eZ
d�Zd
�Zd�Zd�Zd�ZRS(c

Cs
t|j
�
S(
N(R*RX(
R[((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyt__len__�s
cCs+|j�
z|j
|
SWd|j�
XdS(
N(R.RXRZ(R[R((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyt__getitem__�s



cCs-|j�
z||j
|
<Wd|j�
XdS(
N(R.RXRZ(R[RRa((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyt__setitem__�s



cCs.|j�
z|j
|
|!SWd|j�
XdS(
N(R.RXRZ(R[tstarttstop((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyt__getslice__�s



cCs0|j�
z||j
|
|+Wd|j�
XdS(
N(R.RXRZ(R[ReRftvalues((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyt__setslice__
s



(RIR`RbRcRdRgRi(((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyRD�s
				RCcBs eZ
ed�
Zed
�
ZRS(Ratraw(RIR`R:RaRj(((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyRC

s

(,tsysRtweakreftmultiprocessingRR
tmultiprocessing.forkingRRt__all__RBtc_bytetc_ubytetc_shorttc_ushorttc_inttc_uinttc_longtc_ulongtc_floattc_doubleRtc_wcharR5RRRRRRRR	RQRR:RWRVtWeakKeyDictionaryREtobjectR>R=RDRC(((s4/usr/lib64/python2.7/multiprocessing/sharedctypes.pyt<module>#sB













		
							
"