Ñò
¦sÖIc @ 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 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( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyt debug s c B s› e Z 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 namespace( t selfR ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyt __init__2 s c C s
t ƒ ‚ d S( N( t NotImplementedError( R t key( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyt get_creation_lock5 s c C s
t ƒ ‚ d S( N( R ( R ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyt do_remove8 s c C s d S( N( ( R ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyt acquire_read_lock; s c C s d S( N( ( R ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyt release_read_lock> s c C s t S( N( t True( R t wait( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyt acquire_write_lockA s c C s d S( N( ( R ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyt release_write_lockD s c C s
| i | ƒ S( N( t __contains__( R R ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyt has_keyG s c C s
t ƒ ‚ d S( N( R ( R R ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyt __getitem__J s c C s
t ƒ ‚ d S( N( R ( R R t value( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyt __setitem__M s c C s | | | ( R R9 ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyR; ¦ s
c C s@ | i i ƒ z | i d t ƒ | i ƒ Wd | i i ƒ Xd S( NR9 ( R1 R R; t FalseR R! ( R ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyR+ ´ s
( R, R- R. R R0 R6 R7 R R R R R! R? R: R; R+ ( ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyR g s
c B sh e Z d Z d d d d „ Z d „ Z d „ Z d
„ Z d „ Z d „ Z d
„ Z
d „ Z d „ Z RS( R t
createfuncR' t expire_argumentt starttimet
storedtimeR c C s: | | _ | | _ | | _ | | _ d | _ | | _ d S( Niÿÿÿÿ( R R@ RA RB RC R ( R R R R@ R' RB ( ( s4 /usr/lib/python2.6/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 ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyt has_valueÈ s
c C s | i ƒ p
| i d j S( N( t has_current_valueR@ R/ ( R ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyt can_have_valueÔ s c C s^ | i i ƒ z< | i i | i ƒ } | o | i ƒ } | i ƒ St SWd | i i ƒ Xd S( N( R R R# R t _Value__get_valuet _is_expiredR? R ( R RD R% ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyRE × s
c C sM | i d j o | i | i j p* | i d j o t i ƒ | i | i j S( s Return true if this container's value is expired.
Note that this method is only correct if has_current_value()
or get_value() have been called already.
N( RB R/ RC R' t time( R ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyRH ã s c C sÁ | i i ƒ zp | i ƒ } | o< y" | i ƒ } | i ƒ p | SWq_ t j
o q_ 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 ƒ zM | i ƒ o< y" | i ƒ } | i ƒ p | SWqkt j
o qkXn 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 RD RG RH t KeyErrorR@ R R R? R R= R R R( R> ( R RD R% t has_createlockt
creation_lockt v( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyt get_valueö sT
c C s¹ | i | i } y | \ | _ | _ } Wn‰ t j
o} t | ƒ d j p ‚ n | \ | _ } d | _ | _ t d | i | i ƒ | i i ƒ | i
| ƒ | i i ƒ n X| S( Ni s* get_value upgrading time %r expire time %r( R R RC R' t
ValueErrort lenR/ RA R R R( R ( R R% ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyt __get_value. s
c C sp | i i ƒ zN t i ƒ | _ t d | i | i ƒ | i i | i | i | i | f ƒ Wd | i i ƒ Xd S( Ns' set_value stored time %r expire time %r( R R RI RC R RA R( R R! ( R R% ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyR( > 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 RJ RC R! ( R ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyRR G s
( s keys
createfuncs
expiretimes expire_arguments starttimes
storedtimes namespaceN(
R, R- t __slots__R/ R RD RF RE RH RN RG R( RR ( ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyR ¼ s 8 c B se e Z e i ƒ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d „ Z d „ Z
RS( c K s/ t i | | ƒ t i i | i t ƒ | _ d S( N( R R R
t
namespacest getR t dictt
dictionary( R R t kwargs( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyR Y s c C s t d d | i | f d t ƒ S( Nt
identifiers memorycontainer/funclock/%s/%st reentrant( R R R ( R R ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyR ] s c C s | i | S( N( RW ( R R ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyR$ c s c C s | i i | ƒ S( N( RW R" ( R R ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyR" f s c C s | i i | ƒ S( N( RW R" ( R R ( ( s4 /usr/lib/python2.6/site-packages/beaker/container.pyR# i s c C s | | i | s> (
KUš#fU