/opt/alt/python27/lib/python2.7/site-packages/beaker
Edit: /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyo (26102B)
Ñò
§ŸWc @ s d Z d d k Z d d k Z d d k Z d d k Z d d k Z d d k i Z d d k l Z l
Z
d d k l Z l
Z
l Z l Z l Z d d d d d d
d d d
d d d g Z e i d ƒ Z e i e i ƒ o
e i Z n
d „ Z d
e f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ d e f d „ ƒ YZ h Z e Z! d e" f d „ ƒ YZ# d e f d „ ƒ YZ$ d
e$ f d „ ƒ YZ% d e$ f d „ ƒ YZ& d e$ f d „ ƒ YZ' e' Z( d S(! s Container and Namespace classesiÿÿÿÿN( t CreationAbortedErrort MissingCacheParameter( t
_threadingt file_synchronizert mutex_synchronizert NameLockt null_synchronizert Valuet Containert ContainerContextt MemoryContainert DBMContainert NamespaceManagert MemoryNamespaceManagert DBMNamespaceManagert
FileContainert OpenResourceNamespaceManagert FileNamespaceManagerR s beaker.containerc G s d S( N( ( t messaget args( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt debug s c B sª e Z d Z e d „ ƒ Z d „ Z d „ Z d „ Z d „ Z d „ Z e
d „ Z d „ Z d „ Z
d
„ Z d „ Z d d „ Z d
„ Z d „ Z d „ Z d „ Z RS( 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 C s d S( N( ( t cls( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt _init_dependencies4 s c C s | i ƒ | | _ d S( N( R t namespace( t selfR ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt __init__8 s
c C s
t ƒ ‚ d S( N( t NotImplementedError( R t key( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt get_creation_lock< s c C s
t ƒ ‚ d S( N( R ( R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt do_remove? s c C s d S( N( ( R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt acquire_read_lockB s c C s d S( N( ( R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt release_read_lockE s c C s t S( N( t True( R t wait( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt acquire_write_lockH s c C s d S( N( ( R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt release_write_lockK s c C s
| i | ƒ S( N( t __contains__( R R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt has_keyN s c C s
t ƒ ‚ d S( N( R ( R R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt __getitem__Q s c C s
t ƒ ‚ d S( N( R ( R R t value( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt __setitem__T s c C s | | |
R R4 R# ( R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR# š s c C sw | i i ƒ zU | o4 | i d j o | i | ƒ n | i d 7_ n | i | ƒ d | _ Wd | i i ƒ Xd S( Ni i ( R7 t acquireR5 R9 t release( R R8 R< ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR= s
c C s… | i i ƒ zc | o1 | i d 8_ | i d j o | i ƒ qo n( | i d j o | i ƒ n d | _ Wd | i i ƒ Xd S( Ni i ( R7 R@ R5 R: RA ( R R< ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR> s
c C s@ | i i ƒ z | i d t ƒ | i ƒ Wd | i i ƒ Xd S( NR< ( R4 R" R> t FalseR R# ( R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR- » s
( R. R/ R0 R R3 R9 R: R R R R" R# RB R= R> R- ( ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR n s
c B sk e Z d Z d d d d „ Z d „ Z d „ Z d
„ Z d „ Z d „ Z d
„ Z
d d „ Z d „ Z RS( R t
createfuncR) t expire_argumentt starttimet
storedtimeR c C s: | | _ | | _ | | _ | | _ d | _ | | _ d S( Niÿÿÿÿ( R RC RD RE RF R ( R R R RC R) RE ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR Ç s c C s9 | i i ƒ z | i i | i ƒ SWd | i i ƒ Xd S( sr return true if the container has a value stored.
This is regardless of it being expired or not.
N( R R R% R R ( R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt has_valueÏ s
c C s | i ƒ p
| i d j S( N( t has_current_valueRC R2 ( R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt can_have_valueÛ s c C sŠ | i i ƒ zh | i i | i ƒ } | oD y* | i ƒ \ } } } | i | | ƒ SWqp t j
o qp Xn t SWd | i i ƒ Xd S( N( R R R% R t
_get_valuet _is_expiredt KeyErrorRB R ( R RG t storedt expiredR' ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRH Þ s
c C sA | i d j o | | i j p! | d j o t i ƒ | | j S( s1 Return true if this container's value is expired.N( RE R2 t time( R RF R) ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRK ì s
c C så | i i ƒ z… | i ƒ } | oQ y1 | i ƒ \ } } } | i | | ƒ p | SWqt t j
o
t } qt Xn | i p t | i ƒ ‚ n Wd | i i ƒ Xt } | i i
| i ƒ } | o6 | i d t ƒ p t d ƒ | St d ƒ t
} n | p" t d ƒ | i ƒ t d ƒ n z¥ | i i ƒ z\ | i ƒ oK y1 | i ƒ \ } } } | i | | ƒ p | SWqt j
o qXn Wd | i i ƒ Xt d ƒ | i ƒ } | i | ƒ | SWd | i ƒ t d ƒ Xd S( NR! s6 get_value returning old value while new one is createds lock_creatfunc (didnt wait)s lock_createfunc (waiting)s lock_createfunc (waited)s get_value creating new values released create lock( R R RG RJ RK RL RB RC R R R R@ R R R* RA ( R RG RM RN R' t has_createlockt
creation_lockt v( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt get_valueú sT
c C sÓ | i | i } y | \ } } } Wn t j
os t | ƒ d j p ‚ n | \ } } | i } t d | | i ƒ | i i ƒ | i | | ƒ | i i ƒ n# t j
o t
| i ƒ ‚ n X| | | f S( Ni s* get_value upgrading time %r expire time %r( R R t
ValueErrort lenRD R R R* R t TypeErrorRL ( R R' RM RN ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRJ 2 s
c C sx | i i ƒ zV | d j o t i ƒ } n t d | | i ƒ | i i | i | | i | f ƒ Wd | i i ƒ Xd S( Ns' set_value stored time %r expire time %r( R R" R2 RO R RD R* R R# ( R R' RF ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR* G s
&c C sz | i i ƒ zX t d ƒ | i i | i ƒ o+ y | i | i =Wq[ t j
o q[ Xn d | _ Wd | i i ƒ Xd S( Nt clear_valueiÿÿÿÿ( R R" R R% R RL RF R# ( R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRW Q s
( s keys
createfuncs
expiretimes expire_arguments starttimes
storedtimes namespaceN(
R. R/ t __slots__R2 R RG RI RH RK RS RJ R* RW ( ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR Ã s 8
t AbstractDictionaryNSManagerc B sV e Z d Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ 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.
c C s t d d | i | f d t ƒ S( Nt
identifiers memorynamespace/funclock/%s/%st reentrant( R R R ( R R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR x s c C s | i | S( N( t
dictionary( R R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR& ~ s c C s | i i | ƒ S( N( R\ R$ ( R R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR$ s c C s | i i | ƒ S( N( R\ R$ ( R R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR% „ s c C s | | i | ( R t g( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyRp Ñ s c C s‹ g } t i | i t i ƒ o | i | i ƒ n xQ d D]I } t i | i t i | t i ƒ o | i | i t i | ƒ q: q: W| S( NRt Ru Rr Rs ( s pags dirs dbs dat( Rv Rw Ro Rx t appendRy ( R t listRz ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyt
get_filenamesÖ s $#c C sb t d | i ƒ y | i i | i | ƒ | _ Wn, | i ƒ | i i | i | ƒ | _ n Xd S( Ns opening dbm file %s( R Ro Rl R= Rm Rp ( R R8 ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR9 à s
c C s5 | i d j o! t d | i ƒ | i i ƒ n d S( Ns closing dbm file %s( Rm R2 R Ro R> ( R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR: è s c C s( x! | i ƒ D] } t i | ƒ q
Wd S( N( R Rv R- ( R t f( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR í s
c C s t i | i | ƒ S( N( t cPicklet loadsRm ( R R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR& ñ s c C s | i i | ƒ S( N( Rm R% ( R R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR$ ô s c C s t i | ƒ | i | R8 ( R R8 t fh( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR9 , s c C si | i d j p | i d j o3 t | i d ƒ } t i | i | ƒ | i ƒ n h | _ d | _ d S( NR? t wt wb( R8 R= Ro R t dumpR… R> R2 ( R RŒ ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR: 7 s c C s9 y t i | i ƒ Wn t j
o } n Xh | _ d S( N( Rv R- Ro R‰ R… ( R t err( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR @ s
c C s | i | S( N( R… ( R R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR& I s c C s | i i | ƒ S( N( R… R% ( R R ( ( sA /opt/alt/python27/lib/python2.7/site-packages/beaker/container.pyR$ L s c C s | | i | s@ (
QUœ4fZ