/usr/lib64/python2.6/Demo/pdist
Edit: /usr/lib64/python2.6/Demo/pdist/cvslock.pyc (8597B)
Ñò
« gc @ sö d Z d d k Z d d k Z d d k Z d d k Z d Z d Z d Z d Z d Z d d d „ ƒ YZ
d
e
f d „ ƒ YZ d d d
„ ƒ YZ d „ Z
d e f d „ ƒ YZ d e f d „ ƒ YZ e d „ Z d „ Z e d j o e ƒ n d S( sû CVS locking algorithm.
CVS locking strategy
====================
As reverse engineered from the CVS 1.3 sources (file lock.c):
- Locking is done on a per repository basis (but a process can hold
write locks for multiple directories); all lock files are placed in
the repository and have names beginning with "#cvs.".
- Before even attempting to lock, a file "#cvs.tfl.
" is created
(and removed again), to test that we can write the repository. [The
algorithm can still be fooled (1) if the repository's mode is changed
while attempting to lock; (2) if this file exists and is writable but
the directory is not.]
- While creating the actual read/write lock files (which may exist for
a long time), a "meta-lock" is held. The meta-lock is a directory
named "#cvs.lock" in the repository. The meta-lock is also held while
a write lock is held.
- To set a read lock:
- acquire the meta-lock
- create the file "#cvs.rfl."
- release the meta-lock
- To set a write lock:
- acquire the meta-lock
- check that there are no files called "#cvs.rfl.*"
- if there are, release the meta-lock, sleep, try again
- create the file "#cvs.wfl."
- To release a write lock:
- remove the file "#cvs.wfl."
- rmdir the meta-lock
- To release a read lock:
- remove the file "#cvs.rfl."
Additional notes
----------------
- A process should read-lock at most one repository at a time.
- A process may write-lock as many repositories as it wishes (to avoid
deadlocks, I presume it should always lock them top-down in the
directory hierarchy).
- A process should make sure it removes all its lock files and
directories when it crashes.
- Limitation: one user id should not be committing files into the same
repository at the same time.
Turn this into Python code
--------------------------
rl = ReadLock(repository, waittime)
wl = WriteLock(repository, waittime)
list = MultipleWriteLock([repository1, repository2, ...], waittime)
iÿÿÿÿNi
i s #cvs.lcks #cvs.rfl.s #cvs.wfl.t Errorc B s# e Z d „ Z d „ Z d „ Z RS( c C s
| | _ d S( N( t msg( t selfR ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyt __init__` s c C s
t | i ƒ S( N( t reprR ( R ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyt __repr__c s c C s
t | i ƒ S( N( t strR ( R ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyt __str__f s ( t __name__t
__module__R R R ( ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR ^ s t Lockedc B s e Z RS( ( R R ( ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR
j s t Lockc B sV e Z d e d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
RS( t .c C sx | | _ | | _ d | _ d | _ t t i ƒ ƒ } | i t ƒ | _
| i t | ƒ | _ | i t
| ƒ | _ d S( N( t
repositoryt delayt Nonet lockdirt lockfileR t ost getpidt joint CVSLCKt cvslckt CVSRFLt cvsrflt CVSWFLt cvswfl( R R
R t pid( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR p s c C s d GH| i ƒ d S( Nt __del__( t unlock( R ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR z s c C sÅ x¾ y' | i | _ t i | i d ƒ d SWq t i j
o‚ } d | _ | d t j oF y t i | i ƒ } Wn t i j
o
q n X| i | ƒ q n t d | i
| f ƒ ‚ q Xq d S( Niÿ i s failed to lock %s: %s( R R R t mkdirt errorR t EEXISTt statt sleepR R
( R R t st( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyt
setlockdir~ s
c C s | i ƒ | i ƒ d S( N( t
unlockfilet unlockdir( R ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR s
c C sT | i oF d G| i GHy t i | i ƒ Wn t i j
o n Xd | _ n d S( Nt unlink( R R R' R R ( R ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR% ” s
c C sT | i oF d G| i GHy t i | i ƒ Wn t i j
o n Xd | _ n d S( Nt rmdir( R R R( R R ( R ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR& s
c C s t | | i | i ƒ d S( N( R" R
R ( R R# ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR" ¦ s c C s t i i | i | ƒ S( N( R t pathR R
( R t name( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR © s ( R R t DELAYR R R$ R R% R& R" R ( ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR n s
c C s£ | d j o t | ƒ ‚ n | t i } y t i | ƒ } | d } Wn t j
o d | } n Xd t i t i ƒ ƒ d d !Gd | G| GHt i | ƒ d S( Ni s uid %ds [%s]i i s Waiting for %s's lock in( R
R! t ST_UIDt pwdt getpwuidt KeyErrort timet ctimeR" ( R# R
R t uidt pwentt user( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR" s
t ReadLockc B s e Z e d „ Z RS( c C s| t i | | | ƒ d } z< | i ƒ | i | _ t | i d ƒ } | i ƒ d } Wd | p | i ƒ n | i ƒ Xd S( Ni t wi ( R R R$ R R t opent closeR% R& ( R R
R t okt fp( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR ½ s
( R R R+ R ( ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR5 » s t WriteLockc B s e Z e d „ Z d „ Z RS( c C s~ t i | | | ƒ | i ƒ x2 | i ƒ } | p Pn | i ƒ | i | ƒ q | i | _ t | i d ƒ } | i ƒ d S( NR6 (
R R R$ t
readers_existR& R" R R R7 R8 ( R R
R R2 R: ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR Î s
c C s{ t t ƒ } xh t i | i ƒ D]T } | | t j o= y t i | i | ƒ ƒ } Wn t i j
o
q n X| Sq Wd S( N( t lenR R t listdirR
R! R R R ( R t nR* R# ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR< Û s ( R R R+ R R< ( ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyR; Ì s
c C sk xd g } xE | D]< } y | i t | d ƒ ƒ Wq t j
o
} ~ Pq Xq WPt | i | | ƒ q t S( Ni ( t appendR; R
R" R t list( t repositoriesR t lockst rt instance( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyt MultipleWriteLockç s
c C sø d d k } | i d o | i d } n d } d } d } zD d GHt | ƒ } d GH| i ƒ d GHt | ƒ } d GH| i ƒ Wd d g GHd | _ d g GH| o | i ƒ n d g GH| o | i ƒ n d g GHd } d
g GHd } d g GHXd S( Niÿÿÿÿi R s attempting write lock ...s got it.s attempting read lock ...i i i i i ( t syst argvR R; R R5 t
exc_traceback( RG R
t rlt wl( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyt testö s8
t __main__( ( ( t __doc__R R0 R! R- R+ R R R R R R
R R" R5 R; RF RL R ( ( ( s* /usr/lib64/python2.6/Demo/pdist/cvslock.pyt G s& ? !