/opt/alt/python37/lib/python3.7/site-packages/beaker
Edit: /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyo (29938B)
Ñò
ø[c @ s7 d Z d d k Z d d k l Z l Z l Z l Z l Z d d k i Z d d k
Z
d d k Z d d k 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( e e( ƒ d e f d „ ƒ Yƒ Z) d e) f d „ ƒ YZ* d
e) f d! „ ƒ YZ+ d e) f d" „ ƒ YZ, e, Z- d S(# s Container and Namespace classesiÿÿÿÿNi ( t picklet anydbmt
add_metaclasst PYVERt unicode_text( 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/python37/lib/python3.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
e d „ Z d „ Z
d „ Z d
„ Z d „ Z d d „ Z d
„ Z d „ Z d „ Z d „ Z RS( sH Handles dictionary operations and locking for a namespace of
values.
:class:`.NamespaceManager` provides a dictionary-like interface,
implementing ``__getitem__()``, ``__setitem__()``, and
``__contains__()``, as well as functions related to lock
acquisition.
The implementation for setting and retrieving the namespace data is
handled by subclasses.
NamespaceManager may be used alone, or may be accessed by
one or more :class:`.Value` objects. :class:`.Value` 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( s` Initialize module-level dependent libraries required
by this :class:`.NamespaceManager`.N( ( t cls( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyt _init_dependencies: s c C s | i ƒ | | _ d S( N( R t namespace( t selfR ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyt __init__? s
c C s
t ƒ ‚ d S( s+ Return a locking object that is used to synchronize
multiple threads or processes which wish to generate a new
cache value.
This function is typically an instance of
:class:`.FileSynchronizer`, :class:`.ConditionSynchronizer`,
or :class:`.null_synchronizer`.
The creation lock is only used when a requested value
does not exist, or has been expired, and is only used
by the :class:`.Value` key-management object in conjunction
with a "createfunc" value-creation function.
N( t NotImplementedError( R t key( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyt get_creation_lockC s c C s
t ƒ ‚ d S( s Implement removal of the entire contents of this
:class:`.NamespaceManager`.
e.g. for a file-based namespace, this would remove
all the files.
The front-end to this method is the
:meth:`.NamespaceManager.remove` method.
N( R ( R ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyt do_removeT s c C s d S( s‰ Establish a read lock.
This operation is called before a key is read. By
default the function does nothing.
N( ( R ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyt acquire_read_locka s c C s d S( s† Release a read lock.
This operation is called after a key is read. By
default the function does nothing.
N( ( R ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyt release_read_locki s c C s t S( sÆ Establish a write lock.
This operation is called before a key is written.
A return value of ``True`` indicates the lock has
been acquired.
By default the function returns ``True`` unconditionally.
'replace' is a hint indicating the full contents
of the namespace may be safely discarded. Some backends
may implement this (i.e. file backend won't unpickle the
current contents).
( t True( R t waitt replace( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyt acquire_write_lockq s c C s d S( sŽ Release a write lock.
This operation is called after a new value is written.
By default this function does nothing.
N( ( R ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyt release_write_lock‚ s c C s
| i | ƒ S( sY Return ``True`` if the given key is present in this
:class:`.Namespace`.
( t __contains__( R R ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyt has_keyŠ s c C s
t ƒ ‚ d S( N( R ( R R ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyt __getitem__ s c C s
t ƒ ‚ d S( N( R ( R R t value( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyt __setitem__“ s c C s | | |
t acquireR< R@ t release( R R? RC R' ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyRD ë 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 ( R> RG R< RA RH ( R RC ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyRE ø s
c C s@ | i i ƒ z | i d t ƒ | i ƒ Wd | i i ƒ Xd S( NRC ( R; R( RE R8 R" R) ( R ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyR3 s
( R4 R5 R6 R R: R@ RA R# R$ R% R8 R( R) RD RE R3 ( ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyR ¹ s
c B sq e Z d 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( s… Implements synchronization, expiration, and value-creation logic
for a single value stored in a :class:`.NamespaceManager`.
R t
createfuncR/ t expire_argumentt starttimet
storedtimeR c C s: | | _ | | _ | | _ | | _ d | _ | | _ d S( Niÿÿÿÿ( R RI RJ RK RL R ( R R R RI R/ RK ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyR s c C s6 | i i ƒ z | i | i j 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 ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyt has_value s
c C s | i ƒ p
| i d j S( N( t has_current_valueRI R9 ( R ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyt can_have_value, s c C s‡ | i i ƒ ze | i | i j } | oD y* | i ƒ \ } } } | i | | ƒ SWqm t j
o qm Xn t SWd | i i ƒ Xd S( N( R R# R t
_get_valuet _is_expiredt KeyErrorR8 R$ ( R RM t storedt expiredR- ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyRN / 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( RK R9 t time( R RL R/ ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyRQ = 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# RM RP RQ RR R8 RI R R$ R! RG R R% R0 RH ( R RM RS RT R- t has_createlockt
creation_lockt v( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyt get_valueK 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 lenRJ R R$ R0 R# t TypeErrorRR ( R R- RS RT ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyRP ƒ s
c C s | i i ƒ z_ | d j o t i ƒ } n t d | | i ƒ | i i | i | | i | f d | i ƒWd | i i ƒ Xd S( Ns' set_value stored time %r expire time %rR/ ( R R( R9 RU R RJ R0 R R) ( R R- RL ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyR0 ˜ s
!c C sw | i i ƒ zU t d ƒ | i | i j o+ y | i | i =WqX t j
o qX Xn d | _ Wd | i i ƒ Xd S( Nt clear_valueiÿÿÿÿ( R R( R R RR RL R) ( R ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyR] £ s
( s keys
createfuncs
expiretimes expire_arguments starttimes
storedtimes namespaceN( R4 R5 R6 t __slots__R9 R RM RO RN RQ RY RP R0 R] ( ( ( sA /opt/alt/python37/lib/python3.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/python37/lib/python3.7/site-packages/beaker/container.pyR! Ë s c C s | i | S( N( t
dictionary( R R ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyR, Ò s c C s | i i | ƒ S( N( Rb R* ( R R ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyR* Õ s c C s | i i | ƒ S( N( Rb R* ( R R ( ( sA /opt/alt/python37/lib/python3.7/site-packages/beaker/container.pyR+ Ø s c C s | | i | sB ( (
›V£6 vd