�
��Wc@s
dZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dljZd
dlm	Z	m
Z

d
dlmZm
Z
mZmZmZ
ddddd	d
ddd
dddgZejd�
Zejej�
r�ejZn	d�Zd
ef
d��YZdef
d��YZdef
d��YZdef
d��YZdef
d��YZdef
d��YZdef
d��YZiZe Z!de"f
d��YZ#def
d��YZ$d
e$f
d��YZ%de$f
d��YZ&d	e$f
d ��YZ'e'Z(dS(!sContainer and Namespace classesi����N(tCreationAbortedErrortMissingCacheParameter(t
_threadingtfile_synchronizertmutex_synchronizertNameLocktnull_synchronizertValuet	ContainertContainerContexttMemoryContainertDBMContainertNamespaceManagertMemoryNamespaceManagertDBMNamespaceManagert
FileContainertOpenResourceNamespaceManagertFileNamespaceManagerRsbeaker.containerc

GsdS(
N((tmessagetargs((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pytdebugs
cBs�eZ
dZed
��
Zd�Zd�Zd�Zd�Zd�Z	e
d�
Zd�Zd	�Z
d
�Zd�Zdd�
Zd
�Zd�Zd�Zd�ZRS(s�Handles dictionary operations and locking for a namespace of
    values.
    
    The implementation for setting and retrieving the namespace data is
    handled by subclasses.
    
    NamespaceManager may be used alone, or may be privately accessed by
    one or more Container objects.  Container objects provide per-key
    services like expiration times and automatic recreation of values.
    
    Multiple NamespaceManagers created with a particular name will all
    share access to the same underlying datasource and will attempt to
    synchronize against a common mutex object.  The scope of this
    sharing may be within a single process or across multiple
    processes, depending on the type of NamespaceManager used.
    
    The NamespaceManager itself is generally threadsafe, except in the
    case of the DBMNamespaceManager in conjunction with the gdbm dbm
    implementation.

    c


CsdS(
N((
tcls((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt_init_dependencies4scCs|j�
|
|_
dS(
N(Rt	namespace(tselfR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt__init__8s


c
Cs
t��
dS(
N(
tNotImplementedError(Rtkey((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pytget_creation_lock<s
c


Cs
t��
dS(
N(
R(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt	do_remove?s
c


CsdS(
N((
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pytacquire_read_lockBs
c


CsdS(
N((
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pytrelease_read_lockEs
c
CstS(
N(
tTrue(Rtwait((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pytacquire_write_lockHs
c


CsdS(
N((
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pytrelease_write_lockKs
cCs
|j|
�
S(
N(
t__contains__(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pythas_keyNs
c
Cs
t��
dS(
N(
R(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt__getitem__Qs
c
Cs
t��
dS(
N(
R(RRtvalue((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt__setitem__Ts
cCs|||
<d
S(s�Optional set_value() method called by Value.
        
        Allows an expiretime to be passed, for namespace
        implementations which can prune their collections
        using expiretime.
        
        N((RRR't
expiretime((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt	set_valueWsc
Cs
t��
dS(
N(
R(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR$as
c
Cs
t��
dS(
N(
R(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt__delitem__ds
c


Cs
t��
dS(
N(
R(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pytkeysgs
c


Cs|j�
dS(
N(
R(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pytremovejs
N(t__name__t
__module__t__doc__tclassmethodRRRRRRR R"R#R%R&R(tNoneR*R$R+R,R-(((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRs"									
			cBszeZ
dZd
�Zd�Zd�Zd�Zd�Zd�Ze	d�
Z
d�Zed	�
Z
ed
�
Zd�ZRS(s~A NamespaceManager where read/write operations require opening/
    closing of a resource which is possibly mutexed.
    
    cCs;tj
||
�
|j�|_d
|_tj�|_dS(Ni(RRtget_access_locktaccess_locktopenersRtLocktmutex(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRss


	
c


Cs
t��
dS(
N(
R(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR3ys
c
Cs
t��
dS(
N(
R(Rtflags((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pytdo_open|s
c


Cs
t��
dS(
N(
R(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pytdo_closes
c

CsB|jj
�
y|jd
dt�


Wn


|jj�
�n
XdS(Nt
rt
checkcount(R4RtopenR R(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR�s







c

Cs)z|jd
t
�

Wd|jj�
XdS(NR<(tcloseR R4R(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR�s

cCsZ|jj
|
�
}y*|
s!|r7|jd
dt�


n|SWn


|jj�
�n
XdS(Nt
cR<(R4R"R=R R#(RR!R;((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR"�s








c

Cs)z|jd
t
�

Wd|jj�
XdS(NR<(R>R R4R#(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR#�s

cCss|jj
�
zQ|rG|jd
kr5|j|
�

n|jd7_n|j|
�

d|_Wd|jj�
XdS(Nii
(R7tacquireR5R9trelease(RR8R<((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR=�s









cCs|jj
�
z]|
rD|jd
8_|jdkri|j�
qin%|jdkr`|j�
nd|_Wd|jj�
XdS(Ni
i(R7R@R5R:RA(RR<((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR>�s










c

Cs@|jj
�
z|jd
t�

|j�
Wd|jj�
XdS(NR<(R4R"R>tFalseRR#(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR-�s





(R.R/R0RR3R9R:RRR R"R#RBR=R>R-(((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRns
						
	
cBskeZ
dZdddd�Zd�Zd	�Zd
�Zd�Zd�Z	d
�Z
dd�
Zd�ZRS(Rt
createfuncR)texpire_argumentt	starttimet
storedtimeRcCs:|
|_||_
||_||_d
|_||_dS(Ni����(RRCRDRERFR(RRRRCR)RE((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR�s
	
	
	
	
	
c

Cs9|jj
�
z|jj|j�
SWd
|jj�
Xd
S(srreturn true if the container has a value stored.

        This is regardless of it being expired or not.

        N(RRR%RR(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt	has_value�s


c

Cs|j�p|j
dk	S(
N(thas_current_valueRCR2(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pytcan_have_value�s
c
Cs�|jj
�
zd|jj|j�
}
|
rly*|j�\}}}|j||�SWqltk
rh


qlXntSWd|jj�
XdS(
N(	RRR%Rt
_get_valuet_is_expiredtKeyErrorRBR(RRGtstoredtexpiredR'((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRH�s











cCs>|jd
k	r|
|jkp=|d
k	o=tj�||
kS(s1Return true if this container's value is expired.N(RER2ttime(RRFR)((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRK�s

c
Cs�
|jj
�
z}|j�}
|
rny/|j�\}}}|j||�sP|SWqntk
rj


t}
qnXn|js�t|j�
�
nWd|jj	�
Xt}|jj
|j�
}|
r�|jd
t�
s�td�

|Std�

t
}n|s
td�

|j�
td�

nz�|jj
�
zV|j�r{
y/|j�\}}}|j||�sc
|SWq{
tk
rw



q{
XnWd|jj	�
Xtd�

|j�}|j|�

|SWd|j�
td�

XdS(NR!s6get_value returning old value while new one is createdslock_creatfunc (didnt wait)slock_createfunc (waiting)slock_createfunc (waited)sget_value creating new valuesreleased create lock(RRRGRJRKRLRBRCRRRR@RR R*RA(RRGRMRNR'thas_createlockt
creation_lockt
v((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt	get_value�sT











	








	





















c
Cs�|j|j
}
y|
\}}}
Wn�tk
r�


t|
�
d
ksK�n|
\}}
|j}td||j�
|jj�
|j|
|�
|jj�
n t	k
r�


t
|j
�
�
n
X|||
fS(Nis*get_value upgrading time %r expire time %r(RRt
ValueErrortlenRDRRR*Rt	TypeErrorRL(RR'RMRN((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRJ2
s







	







cCsv|jj
�
zT|dkr+tj�}ntd
||j�
|jj|j||j|
f�
Wd|jj�
XdS(Ns'set_value stored time %r expire time %r(	RR"R2RORRDR*RR#(RR'RF((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR*G
s






&c

Csv|jj
�
zTtd
�

|jj|j�
rWy|j|j=WqWtk
rS


qWXnd|_Wd|jj�
XdS(Ntclear_valuei����(RR"RR%RRLRFR#(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRWQ
s











(skeys
createfuncs
expiretimesexpire_arguments	starttimes
storedtimes	namespaceN(
R.R/t	__slots__R2RRGRIRHRKRSRJR*RW(((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR�s

					8	
tAbstractDictionaryNSManagerc
BsVeZ
dZd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
RS(	s�A subclassable NamespaceManager that places data in a dictionary.
    
    Subclasses should provide a "dictionary" attribute or descriptor
    which returns a dict-like object.   The dictionary will store keys
    that are local to the "namespace" attribute of this manager, so
    ensure that the dictionary will not be used by any other namespace.

    e.g.::
    
        import collections
        cached_data = collections.defaultdict(dict)
        
        class MyDictionaryManager(AbstractDictionaryNSManager):
            def __init__(self, namespace):
                AbstractDictionaryNSManager.__init__(self, namespace)
                self.dictionary = cached_data[self.namespace]
                
    The above stores data in a global dictionary called "cached_data",
    which is structured as a dictionary of dictionaries, keyed
    first on namespace name to a sub-dictionary, then on actual
    cache key to value.
    
    cCs td
d|j
|
fdt�S(Nt
identifiersmemorynamespace/funclock/%s/%st	reentrant(RRR (RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRx
s


cCs|j|
S(
N(
t
dictionary(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR&~
s
cCs|jj
|
�
S(
N(R\R$(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR$�
s
cCs|jj
|
�
S(
N(R\R$(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR%�
s
cCs||j|
<dS(
N(
R\(RRR'((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR(�
s
cCs|j|
=dS(
N(
R\(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR+�
s
c


Cs|jj
�
dS(
N(R\tclear(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR�
s
c


Cs
|jj
�S(
N(R\R,(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR,�
s
(R.R/R0RR&R$R%R(R+RR,(((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRY_
s							c
BseZ
ej�Zd�ZRS(
cKs/tj
||
�
tjj|jt�|_dS(
N(RYRR
t
namespacestgetRtdictR\(RRtkwargs((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR�
s


(R.R/tutiltSyncDictR^R(((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR
�
s
cBs�eZ
dddded�Zd
�Zd�Zd�Zd�Zd�Z	d�Z
d�Zd�Zd	�Z
d
�Zd�Zd�Zd
�ZRS(cKs
||_|r&|r&t
d
�
�
n|r8||_n
|d|_tj|j�

|rr|rrt
d�
�
n|r�||_n
|d|_tj|j�

|p�t|_d|_	t
j||
�
tjd|jd|j
g
ddd	|j�|_td
|j�
|j�
dS(Nsdata_dir or dbm_dir is requireds/container_dbms data_dir or lock_dir is requireds/container_dbm_locktroottidentifierst	extensions.dbmtdigest_filenamessdata file %s(RgR
tdbm_dirRbtverify_directorytlock_dirtanydbmt	dbmmoduleR2tdbmRRtencoded_pathRtfileRt
_checkfile(RRRltdata_dirRhRjRgRa((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR�
s,	









	




c

Cstd
|j
d|j�S(NRZRj(RRRj(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR3�
s

cCstd
d|j
d|j�S(NRZsdbmcontainer/funclock/%sRj(RRRj(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR�
s



cCsRtj
|
tj�rtSx2dD]*}tj
|
tj|tj�r tSq WtS(Ntdbtdattpagtdir(RrRsRtsdir(tostaccesstF_OKR textsepRB(RRotext((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pytfile_exists�
s



 
c
Cs;|j|j
�
s7|jj|j
d
�}
|
j�
ndS(NR?(R{RoRlR=R>(Rt
g((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRp�
s


c
Cs�g}
tj
|jtj�r1|
j|j�

nxOdD]G}tj
|jtj|tj�r8|
j|jtj|�

q8q8W|
S(NRtRuRrRs(spagsdirsdbsdat(RvRwRoRxtappendRy(RtlistRz((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt
get_filenames�
s




#
"
cCsbtd
|j
�
y|jj|j
|
�|_Wn,


|j�
|jj|j
|
�|_n
XdS(Nsopening dbm file %s(RRoRlR=RmRp(RR8((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR9�
s






c

Cs3|jdk	r/td
|j�
|jj�
ndS(Nsclosing dbm file %s(RmR2RRoR>(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR:�
s


c
Cs(x!|j�D]}
t
j|
�

q
WdS(
N(RRvR-(Rt
f((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR�
s

cCstj
|j|
�
S(
N(tcPickletloadsRm(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR&�
s
cCs|jj
|
�
S(
N(RmR%(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR$�
s
cCstj
|�
|j|
<dS(
N(R�tdumpsRm(RRR'((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR(�
s
cCs|j|
=dS(
N(
Rm(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR+�
s
c


Cs
|jj
�S(
N(RmR,(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR,�
s
N(R.R/R2R RR3RR{RpRR9R:RR&R$R(R+R,(((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR�
s

 			
		
							cBs�eZ
ddded�Zd
�Zd�Zd�Zd�Zd�Z	d�Z
d�Zd�Zd	�Z
d
�Zd�ZRS(
cKs

||_|r&|r&t
d
�
�
n|r8||_n
|d|_tj|j�

|rr|rrt
d�
�
n|r�||_n
|d|_tj|j�

tj||
�
tjd|jd|j	g
ddd	|j�|_
i|_td
|j
�
dS(Ns data_dir or file_dir is requireds/container_files data_dir or lock_dir is requireds/container_file_lockRdReRfs.cacheRgsdata file %s(
RgR
tfile_dirRbRiRjRRRnRRothashR(RRRqR�RjRgRa((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRs(	














	c

Cstd
|j
d|j�S(NRZRj(RRRj(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR3s

cCstd
d|j
d|j�S(NRZsfilecontainer/funclock/%sRj(RRRj(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR#s



cCstj
|
tj�S(
N(RvRwRx(RRo((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR{)s
c	Csz|j|j
�
rmt|j
d
�}ytj|�
|_Wn#ttttj	t
fk
r_


n
X|j�
n|
|_dS(Ntrb(
R{RoR=R�tloadR�tIOErrortOSErrortEOFErrortPickleErrorRTR>R8(RR8tfh((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR9,s







c
Csf|jd
ks|jdkrPt
|jd�}
tj|j|
�
|
j�
ni|_d|_dS(NR?t
wtwb(R8R=RoR�tdumpR�R>R2(RR�((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR:7s




	
c
Cs7ytj
|j�

Wntk
r)
}

n
Xi|_dS(
N(RvR-RoR�R�(Rterr((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR@s




cCs|j|
S(
N(
R�(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR&Is
cCs|jj
|
�
S(
N(R�R%(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR$Ls
cCs||j|
<dS(
N(
R�(RRR'((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR(Os
cCs|j|
=dS(
N(
R�(RR((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR+Rs
c


Cs
|jj
�S(
N(R�R,(
R((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR,Us
N(R.R/R2R RR3RR{R9R:RR&R$R(R+R,(((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR
s
	
												t
ContainerMetacBs#eZ
d�Zdddd
�ZRS(cCs#|jt
|<tj||
||�S(
N(tnamespace_classtnamespace_classesttypeR(Rt	classnametbasestdict_((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR`s


c
	KsY||kr||}n!t|}	|	||�
||<}t
|
|d
|d|d|�S(NRCR)RE(R�R(
RRtcontextRRCR)RERatnstnscls((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt__call__cs





N(R.R/RR2R�(((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR�_s
	
c
BseZ
eZeZRS((R.R/R�t
__metaclass__RR�(((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRms

c
BseZ
eZRS((R.R/RR�(((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRqs
c
BseZ
eZRS((R.R/R
R�(((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR
ts
c
BseZ
eZRS((R.R/RR�(((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRws
()R0RkR�tloggingRvROtbeaker.utilRbtbeaker.exceptionsRR
tbeaker.synchronizationRRRRRt__all__t	getLoggertloggertisEnabledFortDEBUGRtobjectRRRRYR
RRR�R`R	R�R�RRR
RtDbmContainer(((sA/opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt<module>
s@





(	
	
	



	QU�4fZ