/opt/alt/python37/lib/python3.7/site-packages/beaker/
/opt/alt/python37/lib/python3.7/site-packages/beaker
NameSizeModeActions
crypto/-0755rm
ext/-0755rm
__pycache__/-0755rm
cache.py219170644editdlrm
cache.pyc228710644editdlrm
cache.pyo228710644editdlrm
container.py240790644editdlrm
container.pyc299380644editdlrm
container.pyo299380644editdlrm
converters.py8980644editdlrm
converters.pyc11980644editdlrm
converters.pyo11980644editdlrm
cookie.py31890644editdlrm
cookie.pyc22850644editdlrm
cookie.pyo22850644editdlrm
exceptions.py4430644editdlrm
exceptions.pyc17600644editdlrm
exceptions.pyo17600644editdlrm
middleware.py64820644editdlrm
middleware.pyc68190644editdlrm
middleware.pyo68190644editdlrm
session.py328270644editdlrm
session.pyc333150644editdlrm
session.pyo332270644editdlrm
synchronization.py115250644editdlrm
synchronization.pyc139330644editdlrm
synchronization.pyo139330644editdlrm
util.py171180644editdlrm
util.pyc217010644editdlrm
util.pyo216250644editdlrm
_compat.py42560644editdlrm
_compat.pyc61010644editdlrm
_compat.pyo61010644editdlrm
__init__.py230644editdlrm
__init__.pyc1840644editdlrm
__init__.pyo1840644editdlrm
Edit: /opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyc (13933B)
Ñò ø[c@s†dZddkZddkZddkZddkZyddkZWnej oddkZnXyei ƒe Z Wn9yddk Z e Z Wq¸ej o e Z q¸XnXddklZddklZddddd gZdefd „ƒYZeiƒZd „Zd „Zd „Zdefd„ƒYZdefd„ƒYZdefd„ƒYZdefd„ƒYZdS(s¸Synchronization functions. File- and mutex-based mutual exclusion synchronizers are provided, as well as a name-based mutex which locks within an application based on a string name. iÿÿÿÿN(tutil(t LockErrortfile_synchronizertmutex_synchronizertnull_synchronizertNameLockt _threadingcBsTeZdZeiƒZdefd„ƒYZde d„Z e d„Z d„Z RS(sØa proxy for an RLock object that is stored in a name based registry. Multiple threads can get a reference to the same RLock based on the name alone, and synchronize operations related to that name. t NLContainercBseZd„Zd„ZRS(cCs-|otiƒ|_ntiƒ|_dS(N(RtRLocktlocktLock(tselft reentrant((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyt__init__/scCs|iS(N(R (R ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyt__call__5s(t__name__t __module__R R(((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR.s cCsE|djoti|ƒ|_ntii|ti|ƒ|_dS(N(tNoneRRt_locktlockstget(R t identifierR ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR 8s cCs|iƒi|ƒS(N(Rtacquire(R twait((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR?scCs|iƒiƒdS(N(Rtrelease(R ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyRBsN(RRt__doc__RtWeakValuedRegistryRtobjectRRtFalseR tTrueRR(((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR$s    cKsti||f|||S(N(t_synchronizerstsync_get(Rtclstkwargs((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyt _synchronizerIscKs4t p d|jo t|ƒSt|t|SdS(Ntlock_dir(t has_flockRR"tFileSynchronizer(RR!((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyRMs cKst|t|S(N(R"tConditionSynchronizer(RR!((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyRTscBsAeZdZed„Zd„Zd„Zd„ZeZeZ RS(smA 'null' synchronizer, which provides the :class:`.SynchronizerImpl` interface without any locking. cCstS(N(R(R R((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pytacquire_write_lock]scCsdS(N((R ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pytacquire_read_lock`scCsdS(N((R ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pytrelease_write_lockcscCsdS(N((R ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pytrelease_read_lockfs( RRRRR'R(R)R*RR(((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyRXs    tSynchronizerImplcBsœeZdZd„Zdefd„ƒYZd„ZeeƒZd„Ze d„Z d„Z e Z e d„Z e Zd „Zd „Zd „Zd „ZRS( s_Base class for a synchronization object that allows multiple readers, single writers. cCstiƒ|_dS(N(Rt ThreadLocalt_state(R ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR qst SyncStatecBseZdZd„ZRS(treentrantcounttwritingtreadingcCsd|_t|_t|_dS(Ni(R/RR0R1(R ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR ws  (sreentrantcountswritingsreading(RRt __slots__R (((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR.tscCsB|iiƒp!tiƒ}|ii|ƒ|S|iiƒSdS(N(R-thasR+R.tputR(R tstate((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR5|s  cCsw|i}|iotdƒ‚n|iptdƒ‚n|idjo|iƒt|_n|id8_dS(Nslock is in writing stateslock is not in reading statei(R5R0RR1R/tdo_release_read_lockR(R R5((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR*…s     cCs“|i}|iotdƒ‚n|idjo>|i|ƒ}|p|o|id7_t|_n|S|io|id7_tSdS(Nslock is in writing stateii(R5R0RR/tdo_acquire_read_lockRR1(R RR5tx((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR(“s    cCsw|i}|iotdƒ‚n|iptdƒ‚n|idjo|iƒt|_n|id8_dS(Nslock is in reading stateslock is not in writing statei(R5R1RR0R/tdo_release_write_lockR(R R5((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR)£s     cCs“|i}|iotdƒ‚n|idjo>|i|ƒ}|p|o|id7_t|_n|S|io|id7_tSdS(Nslock is in reading stateii(R5R1RR/tdo_acquire_write_lockRR0(R RR5R8((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR'³s    cCs tƒ‚dS(N(tNotImplementedError(R ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR6ÅscCs tƒ‚dS(N(R;(R R((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR7ÈscCs tƒ‚dS(N(R;(R ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR9ËscCs tƒ‚dS(N(R;(R R((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR:Îs(RRRR RR.R5tpropertyR*RR(R)RR'RR6R7R9R:(((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR+ls          R%cBskeZdZd„Zd„ZeeƒZd„Zd„Zd„Zd„Z d„Z d„Z d „Z RS( s/A synchronizer which locks using flock(). cCstt|ƒiƒtiƒ|_|djotiƒ}n|}ti ||gddƒ|_ t i i |i ƒ|_dS(Nt extensions.lock(tsuperR%R RR,t_filedescriptorRttempfilet gettempdirt encoded_pathtfilenametostpathtdirnameR#(R RR#((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR Ös   cCs |iiƒS(N(R?R(R ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyt _filedescæscCs.tii|iƒpti|iƒndS(N(RDREtexistsR#Rtverify_directory(R ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyt _ensuredirêscCsM|i}|djo3|iƒti|i|ƒ}|ii|ƒn|S(N(RGRRJRDtopenRCR?R4(R tmodetfiledescriptor((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyt_openîs    cCs’|ititiBƒ}|pWy"ti|titiBƒtSWqŽt j o"ti |ƒ|i i ƒt SXnti|tiƒtSdS(N(RNRDtO_CREATtO_RDONLYtfcntltflocktLOCK_SHtLOCK_NBRtIOErrortcloseR?tremoveR(R RRM((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR7ös   cCs’|ititiBƒ}|pWy"ti|titiBƒtSWqŽt j o"ti |ƒ|i i ƒt SXnti|tiƒtSdS(N(RNRDROtO_WRONLYRQRRtLOCK_EXRTRRURVR?RWR(R RRM((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR:s   cCs|iƒdS(N(t_release_all_locks(R ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR6scCs|iƒdS(N(RZ(R ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR9scCsK|i}|dj o1ti|tiƒti|ƒ|iiƒndS(N( RGRRQRRtLOCK_UNRDRVR?RW(R RM((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyRZs    ( RRRR RGR<RJRNR7R:R6R9RZ(((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR%Òs         R&cBsAeZdZd„Zed„Zd„Zed„Zd„ZRS(s!a synchronizer using a Condition.cCsAtt|ƒiƒd|_d|_titiƒƒ|_ dS(Ni( R>R&R tasynchRtcurrent_sync_operationRt ConditionR t condition(R R((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR #s  cCs†|iiƒzX|o)x;|idj o|iiƒqWn|idj otS|id7_Wd|iiƒX|ptSdS(Ni( R_RR]RRRR\RR(R R((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR7/s cCsŠ|iiƒzh|id8_|idjo%|idj o|iiƒqtn!|idjotdƒ‚nWd|iiƒXdS(Niis7Synchronizer error - too many release_read_locks called(R_RR\R]Rt notifyAllRR(R ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR6Cs cCs¿|iiƒz‘|o)x;|idj o|iiƒqWn|idj otStiƒ|_|idjo)|o|iiƒqd|_tSnWd|ii ƒX|pt SdS(Ni( R_RR]RRRRt currentThreadR\RR(R R((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR:Us"   cCsb|iiƒz@|itiƒj otdƒ‚nd|_|iiƒWd|iiƒXdS(Ns>Synchronizer error - current thread doesnt have the write lock( R_RR]RRaRRR`R(R ((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR9ys  ( RRRR RR7R6R:R9(((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyR& s    $(RterrnoRDtsysR@t threadingRt ImportErrortdummy_threadingtgetwindowsversionRR$RQRtbeakerRtbeaker.exceptionsRt__all__RRRRR"RRRR+R%R&(((sG/opt/alt/python37/lib/python3.7/site-packages/beaker/synchronization.pyts<          "    fN