qi5 S r SSKrSSKrSSKrSSKJr SSKJrJrJ r J
r
SSK J r Sr
\R " S5 r " S S 5 r " S
S \5 rg) au
Implements two storage providers for `LockManager`.
Two alternative lock storage classes are defined here: one in-memory
(dict-based), and one persistent low performance variant using shelve.
See :class:`~wsgidav.lock_man.lock_manager.LockManager`
See :class:`~wsgidav.lock_man.lock_storage.LockStorageDict`
See :class:`~wsgidav.lock_man.lock_storage.LockStorageShelve`
N)util)generate_lock_token lock_stringnormalize_lock_root
validate_lock)
ReadWriteLockreStructuredTextzwsgidav.lock_manc h \ rS rSrSrSrSrS rS rS r S r
S r S
r S r
S rS
rS rS rS rSrg)LockStorageDict1 a
An in-memory lock manager storage implementation using a dictionary.
R/W access is guarded by a thread.lock object.
Also, to make it work with a Shelve dictionary, modifying dictionary
members is done by re-assignment and we call a _flush() method.
This is obviously not persistent, but should be enough in some cases.
For a persistent implementation, see lock_storage.LockStorageShelve().
Notes:
expire is stored as expiration date in seconds since epoch (not in
seconds until expiration).
The dictionary is built like::
{ 'URL2TOKEN:/temp/litmus/lockme': ['opaquelocktoken:0x1d7b86...',
'opaquelocktoken:0xd7d4c0...'],
'opaquelocktoken:0x1d7b86...': {
'depth': '0',
'owner': "\n"
+ "litmus test suite\n",
'principal': 'tester',
'root': '/temp/litmus/lockme',
'scope': 'shared',
'expire': 1261328382.4530001,
'token': 'opaquelocktoken:0x1d7b86...',
'type': 'write',
},
'opaquelocktoken:0xd7d4c0...': {
'depth': '0',
'owner': '\n'
+ 'litmus: notowner_sharedlock\n',
'principal': 'tester',
'root': '/temp/litmus/lockme',
'scope': 'shared',
'expire': 1261328381.6040001,
'token': 'opaquelocktoken:0xd7d4c0...',
'type': 'write'
},
}
i: i $ c 0 S U l [ 5 U l g N)_dictr _lockselfs R/home/kali/flask_env/lib/python3.13/site-packages/wsgidav/lock_man/lock_storage.py__init__LockStorageDict.__init__a s
"_
c . U R R $ r ) __class____name__r s r __repr__LockStorageDict.__repr__e s ~~&&&r c g)z$Overloaded by Shelve implementation.N r s r _flushLockStorageDict._flushk r c 0 U R b e0 U l g)zFCalled before first use.
May be implemented to initialize a storage.
Nr r s r openLockStorageDict.openo s
zz!!!
r c SU l g)zCalled on shutdown.Nr" r s r closeLockStorageDict.closew s
r c g)z Purge expired locks (optional).Nr r s r cleanupLockStorageDict.cleanup{ r r c T U R b U R R 5 ggzDelete all entries.N)r clearr s r r- LockStorageDict.clear s! :: ! JJ "r c p U R R 5 U R R U5 nUcE [ R SU 35 U R
U5 U R R 5 g[ US 5 nUS: aj U[ R " 5 : aQ [ R SU S[ U5 35 U R
U5 U R R 5 gUU R R 5 $ ! U R R 5 f = f)zReturn a lock dictionary for a token.
If the lock does not exist or is expired, None is returned.
token:
lock token
Returns:
Lock dictionary or
Side effect: if lock is expired, it will be purged and None is returned.
NzLock purged dangling: expirer zLock timed-out(): ) r acquire_readr get_loggerdebugdeletereleasefloattimer )r tokenlockr0 s r r3 LockStorageDict.get s
! !::>>%(D|
6ug >? E"
JJ 4>*F{v 3
xs;t;L:M NO E"
JJ JJ DJJ s AD ?A"D =D D5c U R R 5 UR S5 b eUR S5 b S5 eU( a SU; d eUn[ U5 nXS' [ UR S5 5 nUc [
R nO*US: d U[
R : a [
R nXBS' [ R " 5 U- US' [ U5 [ 5 nXRS' X R U' SU 3nX`R ; a U/U R U' O.U R U nUR U5 XpR U' U R 5 [ R S U< S
[! U5 35 UU R R# 5 $ ! U R R# 5 f = f) a Create a direct lock for a resource path.
path:
Normalized path (utf8 encoded string, no trailing '/')
lock:
lock dictionary, without a token entry
Returns:
New unique lock token.:
- lock['timeout'] may be normalized and shorter than requested
- lock['token'] is added
r: r0 z Use timeout instead of expire/roottimeoutr
URL2TOKEN:zLockStorageDict.set(r1 )r
acquire_writer3 r r8 r LOCK_TIME_OUT_DEFAULTLOCK_TIME_OUT_MAXr9 r r r appendr r4 r5 r r7 )r pathr; org_pathr@ r: keytokLists r createLockStorageDict.create s
"+ !88G$, ,,88H%- N/N N-C4K '' H&t,D L DHHY /0G)??1/*K*K K);; %O !YY[7 2DN $ ')E !M !%JJu tf%C**$#('
3 **S/u%")
3 KKM MM 0 C D@Q?RS T JJ DJJ s E4F+ + Gc XR ; d S5 eUS:X d US: d eUS: d U[ R : a [ R nU R R 5 U R U nX#S' [
R
" 5 U- US' X0R U' U R
5 U R R 5 U$ ! U R R 5 f = f)a Modify an existing lock's timeout.
token:
Valid lock token.
timeout:
Suggested lifetime in seconds (-1 for infinite).
The real expiration time may be shorter than requested!
Returns:
Lock dictionary.
Raises ValueError, if token is invalid.
zLock must existr r@ r0 )r r rD r rB r9 r r7 )r r: r@ r; s r refreshLockStorageDict.refresh s
"5$55""}! ++ Q;'O$E$EE%77G
" ! ::e$D %O !YY[7 2DN $JJu KKM JJ
JJ s
*A C C.c U R R 5 U R R U5 n[ R S[
U5 35 Uc U R R 5 gSR UR S5 5 nX0R ; aK U R U n[ U5 S: a UR U5 X@R U' O
U R U U R U U R 5 U R R 5 g! U R R 5 f = f)zVDelete lock.
Returns True on success. False, if token does not exist, or is expired.
zdelete Fz URL2TOKEN:{}r? T) r rB r r3 r4 r5 r r7 formatlenremover )r r: r; rH rI s r r6 LockStorageDict.delete s
" !::>>%(D MMGK$5#67 8| $
JJ ! !''(89Cjj **S/w.
Expired locks are *not* returned (but may be purged).
path:
Normalized path (utf8 encoded string, no trailing '/')
include_root:
False: don't add lock (only makes sense, when include_children
is True).
include_children:
True: Also check all sub-paths for existing locks.
token_only:
True: only a list of token is returned. This may be implemented
more efficiently by some providers.
Returns:
List of valid lock dictionaries (may be empty).
r> c > U HK nTR U5 nU( d M T( a TR US 5 M: TR U5 MM g )Nr: )r3 rE )toklistr: r; lockListr
token_onlys r
__appendLocks4LockStorageDict.get_lock_list..__appendLocks2 s@ !xx4! W
6 -
!r rA ) r is_str
startswithr r r2 r r3 items is_child_urir7 ) r rF include_rootinclude_childrenrZ _LockStorageDict__appendLocksrH rI ultoksrY s ` ` @r
get_lock_list LockStorageDict.get_lock_list s $ {{4 ,,,, /// . #4(
! ! tf%CjjnnS"-GH g& $
0 0 2HA((00%e, !3 JJ DJJ s >A1D 3
D D7)r r N)r
__module__ __qualname____firstlineno____doc__rC rD r r r r# r& r) r- r3 rJ rN r6 rf __static_attributes__r r r r r 1 sS *X #"%'
!:<!| < >1!r r c J ^ \ rS rSrSrU 4S jrS rS rS rS r S r
S r U =r $ )
LockStorageShelveiU z=
A low performance lock manager implementation using shelve.
c j > [ TU ] 5 [ R R U5 U l g r )superr osrF abspath
_storage_path)r storage_pathr s r r LockStorageShelve.__init__Z s#
WW__\ :r c $ SU R < S3$ )NzLockStorageShelve())rs r s r r LockStorageShelve.__repr__^ s #D$6$6#9;;r c
[ R S5 U R R 5 U R R 5 U R R
5 g! U R R
5 f = f)z$Write persistent dictionary to disc.z_flush()N)r4 r5 r rB r syncr7 r s r r LockStorageShelve._flusha sR
j!
" ! JJOO JJ DJJ s A& & Bc U R R 5 U R SL nU( a U R 5 [ U R 5 ( a4 U R R 5 U R R
5 U( a U R 5 U R R 5 g! U R R 5 f = fr, ) r rB r r# rS r- rz r& r7 )r
was_closeds r r- LockStorageShelve.clearj s
"
! t+J 4::
"
!
JJ DJJ s B
C C c [ R SU R < S35 [ R " U R SS9U l g )Nzopen(rw F) writeback)r4 r5 rs shelver# r r s r r# LockStorageShelve.openy s8
d 0 0 3156 [[!3!3uE
r c 2 [ R S5 U R R 5 U R b! U R R 5 S U l U R R
5 g ! U R R
5 f = f)Nzclose())r4 r5 r rB r r& r7 r s r r& LockStorageShelve.close se
i
" !zz%
" !
JJ DJJ s .A: : B)r rs )
r rh ri rj rk r r r r- r# r& rl
__classcell__)r s @r rn rn U s, ;<!
! F! !r rn )rk rq r r9 wsgidavr wsgidav.lock_man.lock_managerr r r r wsgidav.rw_lockr
__docformat__get_module_loggerr4 r rn r r r r sX
*"
!3
4$\! \!H 6! 6!r