³ò Ae|Mc@sdZddkZddkZddkZddkZddkZddkiZddkl Z l Z ddk l Z l Z lZlZlZddddd d d d d dddg ZeidƒZeieiƒo eiZn d„Zd efd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZd efd„ƒYZd efd„ƒYZdefd„ƒYZhZe Z!de"fd„ƒYZ#defd„ƒYZ$d e$fd„ƒYZ%de$fd„ƒYZ&d e$fd „ƒYZ'e'Z(dS(!sContainer and Namespace classesiÿÿÿÿN(tCreationAbortedErrortMissingCacheParameter(t _threadingtfile_synchronizertmutex_synchronizertNameLocktnull_synchronizertValuet ContainertContainerContexttMemoryContainert DBMContainertNamespaceManagertMemoryNamespaceManagertDBMNamespaceManagert FileContainertOpenResourceNamespaceManagertFileNamespaceManagerRsbeaker.containercGsdS(N((tmessagetargs((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pytdebugscBsªeZdZed„ƒZd„Zd„Zd„Zd„Zd„Z e d„Z d„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. cCsdS(N((tcls((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyt_init_dependencies3scCs|iƒ||_dS(N(Rt namespace(tselfR((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyt__init__7s cCs tƒ‚dS(N(tNotImplementedError(Rtkey((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pytget_creation_lock;scCs tƒ‚dS(N(R(R((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyt do_remove>scCsdS(N((R((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pytacquire_read_lockAscCsdS(N((R((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pytrelease_read_lockDscCstS(N(tTrue(Rtwait((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pytacquire_write_lockGscCsdS(N((R((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pytrelease_write_lockJscCs |i|ƒS(N(t __contains__(RR((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pythas_keyMscCs tƒ‚dS(N(R(RR((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyt __getitem__PscCs tƒ‚dS(N(R(RRtvalue((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyt __setitem__SscCs|||R R4R#(R((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR#™scCsw|iiƒzU|o4|idjo|i|ƒn|id7_n|i|ƒd|_Wd|iiƒXdS(Nii(R7tacquireR5R9trelease(RR8R<((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR=Ÿs   cCs…|iiƒzc|o1|id8_|idjo|iƒqon(|idjo|iƒnd|_Wd|iiƒXdS(Nii(R7R@R5R:RA(RR<((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR>¬s  cCs@|iiƒz|idtƒ|iƒWd|iiƒXdS(NR<(R4R"R>tFalseRR#(R((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR-ºs  (R.R/R0RR3R9R:RRR R"R#RBR=R>R-(((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyRms        cBskeZdZdddd„Zd„Zd „Zd „Zd „Zd „Z d „Z dd„Z d„Z RS(Rt createfuncR)texpire_argumentt starttimet storedtimeRcCs:||_||_||_||_d|_||_dS(Niÿÿÿÿ(RRCRDRERFR(RRRRCR)RE((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyRÆs      cCs9|iiƒz|ii|iƒSWd|iiƒXdS(srreturn true if the container has a value stored. This is regardless of it being expired or not. N(RRR%RR(R((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyt has_valueÎs cCs|iƒp |idj S(N(thas_current_valueRCR2(R((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pytcan_have_valueÚsc CsŠ|iiƒzh|ii|iƒ}|oDy*|iƒ\}}}|i||ƒ SWqptj oqpXntSWd|iiƒXdS(N( RRR%Rt _get_valuet _is_expiredtKeyErrorRBR(RRGtstoredtexpiredR'((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyRHÝs  cCsA|idj o||ijp!|dj otiƒ||jS(s1Return true if this container's value is expired.N(RER2ttime(RRFR)((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyRKës cCsî|iiƒzˆ|iƒ}|oTy4|iƒ\}}}|i||ƒp|SnWqwtj o t}qwXn|ipt|iƒ‚nWd|ii ƒXt}|ii |iƒ}|o9|i dtƒpt dƒ|Sqt dƒt }n|p"t dƒ|i ƒt dƒnz¨|iiƒz_|iƒoNy4|iƒ\}}}|i||ƒp|SnWq˜tj oq˜XnWd|ii ƒXt dƒ|iƒ}|i|ƒ|SWd|iƒ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_locktv((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyt get_valueùsT                 cCsÓ|i|i}y|\}}}Wn tj ost|ƒdjp‚n|\}}|i}td||iƒ|iiƒ|i||ƒ|iiƒn#t j ot |iƒ‚nX|||fS(Nis*get_value upgrading time %r expire time %r( RRt ValueErrortlenRDRRR*Rt TypeErrorRL(RR'RMRN((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyRJ1s   cCsx|iiƒzV|djotiƒ}ntd||iƒ|ii|i||i|fƒWd|iiƒXdS(Ns'set_value stored time %r expire time %r( RR"R2RORRDR*RR#(RR'RF((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR*Fs  &cCsz|iiƒzXtdƒ|ii|iƒo+y|i|i=Wq[tj oq[Xnd|_Wd|iiƒXdS(Nt clear_valueiÿÿÿÿ(RR"RR%RRLRFR#(R((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyRWPs    (skeys createfuncs expiretimesexpire_arguments starttimes storedtimes namespaceN( R.R/t __slots__R2RRGRIRHRKRSRJR*RW(((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyRÂs    8  tAbstractDictionaryNSManagercBsVeZdZd„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 tdd|i|fdtƒS(Nt identifiersmemorynamespace/funclock/%s/%st reentrant(RRR (RR((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyRwscCs |i|S(N(t dictionary(RR((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR&}scCs|ii|ƒS(N(R\R$(RR((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR$€scCs|ii|ƒS(N(R\R$(RR((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR%ƒscCs||i|(Rtg((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyRpÐscCs‹g}ti|itiƒo|i|iƒnxQdD]I}ti|iti|tiƒo|i|iti|ƒq:q:W|S(NRtRuRrRs(spagsdirsdbsdat(RvRwRoRxtappendRy(RtlistRz((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyt get_filenamesÕs$#cCsbtd|iƒy|ii|i|ƒ|_Wn,|iƒ|ii|i|ƒ|_nXdS(Nsopening dbm file %s(RRoRlR=RmRp(RR8((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR9ßs  cCs5|idj o!td|iƒ|iiƒndS(Nsclosing dbm file %s(RmR2RRoR>(R((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR:çscCs(x!|iƒD]}ti|ƒq WdS(N(RRvR-(Rtf((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyRìs cCsti|i|ƒS(N(tcPickletloadsRm(RR((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR&ðscCs|ii|ƒS(N(RmR%(RR((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR$óscCsti|ƒ|i|R8(RR8tfh((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR9+s cCsi|idjp|idjo3t|idƒ}ti|i|ƒ|iƒnh|_d|_dS(NR?twtwb(R8R=RoRtdumpR…R>R2(RRŒ((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR:6s   cCs9yti|iƒWntj o }nXh|_dS(N(RvR-RoR‰R…(Rterr((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR?s cCs |i|S(N(R…(RR((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR&HscCs|ii|ƒS(N(R…R%(RR((si/afs/athena.mit.edu/user/x/a/xavid/lib/python2.5/site-packages/Beaker-1.5.4-py2.5.egg/beaker/container.pyR$KscCs||i|s@     (      QUœ4fZ