File "sharedctypes.pyc"

Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyc
File size: 8.76 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit


V~gc@sddlZddlZddlZddlmZmZddlmZmZdddddd	gZ	iej
d
6ejd6ejd6ej
d
6ejd6ejd6ejd6ejd6ejd6ejd6ejd6Zyejed<Wnek
rnXdZdZdZdZdZdZddZdZ dZ!dZ"d Z#iZ$ej%Z&d!e'fd"YZ(d#e(fd$YZ)d%e(fd&YZ*d'e*fd(YZ+dS()iN(theaptRLock(tassert_spawningtForkingPicklertRawValuetRawArraytValuetArraytcopytsynchronizedtctbtBthtHtitItltLtftdtucCs.tj|}tj|}t||dS(N(tctypestsizeofRt
BufferWrappert
rebuild_ctypetNone(ttype_tsizetwrapper((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyt
_new_valueBscGsTtj||}t|}tjtj|dtj||j||S(s>
    Returns a ctypes object allocated from shared memory
    i(ttypecode_to_typetgetRRtmemsett	addressofRt__init__(ttypecode_or_typetargsRtobj((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyRGs
%
cCstj||}t|ttfrf||}t|}tjtj|dtj	||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((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyRQs
%
cOs|jdd}|r1td|jnt||}|tkrP|S|tdfkrnt}nt|dst	d|nt
||S(s6
    Return a synchronization wrapper for a Value
    tlocks$unrecognized keyword argument(s): %stacquires'%r' has no method 'acquire'N(tpopRt
ValueErrortkeysRtFalsetTrueRthasattrtAttributeErrorR	(R$R%tkwdsR-R&((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyRascKs|jdd}|r1td|jnt||}|tkrP|S|tdfkrnt}nt|dst	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/RR0R1RR2R3RR4R5R	(R$R+R6R-R&((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyRqscCs)tt|}|tj|d<|S(Ni(RttypeRtpointer(R&tnew_obj((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyRscCst|tstdt|tjr;t||St|tjry|jtjkrlt	||St
||St|}yt|}Wnqt
k
rg|jD]}|d^q}td|D}d|j}t|tf|}t|<nX|||SdS(Nsobject already synchronizedicss!|]}|t|fVqdS(N(t
make_property(t.0tname((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pys	<genexpr>stSynchronized(R'tSynchronizedBasetAssertionErrorRt_SimpleCDataR=Rt_type_tc_chartSynchronizedStringtSynchronizedArrayR7tclass_cachetKeyErrort_fields_tdictt__name__(R&R-tclstsclstfieldtnamesRt	classname((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyR	s 



 
!cCsXt|t|tjr8t|j|j|jffStt||jdffSdS(N(
RR'RRRRAt_wrappert_length_R7R(R&((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pytreduce_ctypes
cCsK|dk	r||}ntj|t|j|j}||_|S(N(RRtregisterRQtfrom_addresstget_addressRO(RRtlengthR&((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyRs
	cBsPye|SWn=ek
rKi}e|fd|U||e|<||SXdS(Ni(t
prop_cacheRFttemplate(R<R((sA/opt/alt/python27/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>cBs8eZddZdZdZdZdZRS(cCs=||_|pt|_|jj|_|jj|_dS(N(t_objRt_lockR.trelease(tselfR&R-((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyR#s	cCs t|t|j|jffS(N(RR	RXRY(R[((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyt
__reduce__s
cCs|jS(N(RX(R[((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pytget_objscCs|jS(N(RY(R[((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pytget_lockscCsdt|j|jfS(Ns<%s wrapper for %s>(R7RIRX(R[((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyt__repr__sN(RIt
__module__RR#R\R]R^R_(((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyR>s
			R=cBseZedZRS(tvalue(RIR`R:Ra(((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyR=sRDcBs5eZdZdZdZdZdZRS(cCs
t|jS(N(R*RX(R[((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyt__len__scCs+|jz|j|SWd|jXdS(N(R.RXRZ(R[R((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyt__getitem__s
cCs-|jz||j|<Wd|jXdS(N(R.RXRZ(R[RRa((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyt__setitem__s
cCs.|jz|j||!SWd|jXdS(N(R.RXRZ(R[tstarttstop((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyt__getslice__s
cCs0|jz||j||+Wd|jXdS(N(R.RXRZ(R[ReRftvalues((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyt__setslice__s
(RIR`RbRcRdRgRi(((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyRDs
				RCcBs eZedZedZRS(Ratraw(RIR`R:RaRj(((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyRC
s(,tsysRtweakreftmultiprocessingRRtmultiprocessing.forkingRRt__all__RBtc_bytetc_ubytetc_shorttc_ushorttc_inttc_uinttc_longtc_ulongtc_floattc_doubleRtc_wcharR5RRRRRRRR	RQRR:RWRVtWeakKeyDictionaryREtobjectR>R=RDRC(((sA/opt/alt/python27/lib64/python2.7/multiprocessing/sharedctypes.pyt<module>#sB

		
							"