/usr/lib64/python2.6/site-packages/mx/BeeBase
Edit: /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyo (12094B)
Ñò
fÑNc @ sý d Z d d k l Z d d k Z d d k Z d d k Z d d k Z d Z d d d „ Z e ƒ \ Z
Z d e i f d „ ƒ YZ
e
Z d
d d „ ƒ YZ e Z d e f d
„ ƒ YZ e e d ƒ o
e Z n e Z d „ Z e d j o e ƒ n d S( sd FileLock - Implements a file lock mechanism that does not depend
on fcntl.
Copyright (c) 1997-2000, Marc-Andre Lemburg; mailto:mal@lemburg.com
Copyright (c) 2000-2008, eGenix.com Software GmbH; mailto:info@egenix.com
See the documentation for further information on copyrights,
or contact the author. All Rights Reserved.
iÿÿÿÿ( t
ExitFunctionsNs 1.0t localhosts 127.0.0.1c C s’ y d d k } Wn t j
o | SXyC | d j o | i ƒ } n | i | ƒ } | i | ƒ d } Wn | i j
o | SX| | f Sd S( sÿ Returns fully qualified (hostname, ip) for the given hostname.
If hostname is not given, the default name of the local host
is chosen.
Defaults to default in case an error occurs while trying to
determine the data.
iÿÿÿÿNi ( t sockett ImportErrort Nonet gethostnamet
gethostbynamet
gethostbyaddrt error( t hostnamet defaultR t ip( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyt _fqhostname s
t Errorc B s e Z RS( ( t __name__t
__module__( ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyR
/ s t SymbolicFileLockc B s³ e Z d Z d Z d Z d „ Z d „ Z d d e i e e i e
i e e
d „ Z d e
i e e i e
i d „ Z d „ Z d „ Z d
„ Z d „ Z e
i d „ Z d
„ Z RS( s Implements a file lock mechanism.
The base class implements the locking mechanism using symbolic
links.
Note that since the mechanism does not use file system
function calls this may not always work in the desired
way.
The lock is acquired per process, not per thread.
Instancevariables:
filename - file the lock applies to
lockfilename - name of the lock file
locked - indicator if the lock is in position (1) or not (0)
i c C s3 | | _ | d | _ d | _ t i | i ƒ d S( Ns .lockedi ( t filenamet lockfilenamet lockedR t registert unlock( t selfR ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyt __init__P s
c C s= | i o | i d ƒ n y t i | i ƒ Wn n Xd S( Ni ( R R R t
deregister( R ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyt __del__X s
iô g-C ëâ6?c C s | i o d S| i } d | t i ƒ f }
| ƒ | d } t i i } t i }
t i } x™ | | ƒ p, y |
|
| ƒ Wn | j
o q™ XPn | | ƒ | ƒ | j oC | i ƒ p q` n | i ƒ \ } } | d | i
| | f ‚ q` q` d | _ d S( s= Try to lock the file for this process, waiting
timeout ms if necessary.
Raises an exception if a timeout occurs. Multiple locking
by the same process is not an error.
Note that a non existent path to the file will also result
in a timeout.
If the lock is held by a process running on our host, a
timeout will first invoke a check of the locking
process. If it is not alive anymore, the lock is removed
and granted to the current process.
Ns %s:%igü©ñÒMbP?s$ file "%s" is locked by process %s:%ii ( R R t ost getpidt patht islinkt symlinkt readlinkt
validate_lockt lock_infoR ( R t timeoutt sleeptimet sleepR
t timeR R R R t lockinfot stopR t makelinkR t hostt locking_pid( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyt locka s0
c C sh | i p d Sd | _ y | | i ƒ Wn# | j
o | d | i ‚ n X| o | | ƒ n d S( s Release the lock, letting other processes using this
mechanism access the file.
Multiple unlocking is not an error. Raises an exception if
the lock file was already deleted by another process.
After having unlocked the file the process sleeps for
sleeptime seconds to give other processes a chance to
acquire the lock too. If the lock will only be used every
once in a while by the process, it is safe to set it to 0.
Ni s file lock "%s" is already gonei ( R R ( R R# t unlinkR
R$ R ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyR “ s
c C s. | i o d St i i | i ƒ o d Sd S( sÕ Returns the current state of the file lock: 1 - a lock
exists, 0 - no lock exists.
Note that in case a lock exists, this lock is not checked
for being valid.
i i ( R R R R R ( R ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyt has_lock° s
c C so y( t i t i | i ƒ d ƒ \ } } Wn. t i j
o } t d | i | f ‚ n Xt | ƒ } | | f S( s° Returns a tuple (hostname, PID integer) indicating the
host and process id currently holding the lock.
An Error is raised if no lock exists.
t :s! file "%s" could not be locked: %s( t stringt splitR R R R R
R t int( R R) R* t why( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyR! ¿ s ( c C s& | i ob | i ƒ } | t i ƒ | i j o8 y t i | i ƒ Wn t i j
o
} d SXd Sql n | i ƒ \ } } | t j o& t | d d ƒd } t
| j } n d } | od y t i | d ƒ Wq"t i j
o: } y t i | i ƒ Wn t i j
o q Xd Sq"Xn d S( sL Validates a lock on the file and return 1 for a valid lock,
0 for an invalid one.
Note that it is only possible to check for valid locks
which are owned by the same host. This method removes any
invalid locks it may find.
An Error is raised if no lock exists.
i i R
s ???( s ???s ???( t locktimeoutt lock_timeR% R R, R R R! R R R t kill( R t ctimeR2 R) R* t other_ipt samehost( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyR Ð s.
c C sO y t i | i ƒ d } Wn. t i j
o } t d | i | f ‚ n X| S( sš Returns a Unix time value indicating the time when the
current lock was created.
An Error is raised if no lock exists.
i s* could not read file lock info for "%s": %s( R t lstatR R R
R ( R R6 R2 ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyR4 s c C s( d | _ y | | i ƒ Wn n Xd S( s/ Remove any existing lock on the file.
i N( R R ( R R, ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyt remove_lock s
c C s d | i i | i t | ƒ f S( Ns <%s for "%s" at %x>( t __class__R R t id( R ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyt __repr__ s ( R R t __doc__R R3 R R R% R$ R
R R R R R+ R, R R- R! R R4 R: R= ( ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyR 7 s / 1
t DirectyFileLockc
B s’ e Z d Z d d e i e e i e i e e e i
d „ Z d e i e e i e i d „ Z
d „ Z d „ Z d „ Z d „ Z e i d „ Z RS(
sØ This class implements a file lock mechanism that uses
temporary directories for locking.
See FileLock for documentation of the various methods.
Thanks to Thomas Heller for this idea !
iô g-C ëâ6?c
C s¹ | i o d S| i }
d | t i ƒ f } | ƒ | d } xj y | |
ƒ Wn | j
o n XP| | ƒ | ƒ | j o( | i ƒ p qB n | d | i ‚ qB qB d | _ d S( Ns %s:%igü©ñÒMbP?s file "%s" is currently lockedi ( R R R R R R (
R R" R# R$ R
R% R R R t mkdirR R& R' ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyR+ 3 s$
c C sh | i p d Sd | _ y | | i ƒ Wn# | j
o | d | i ‚ n X| o | | ƒ n d S( Ni s file lock "%s" is already gonei ( R R ( R R# t rmdirR
R$ R ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyR O s
c C s. | i o d St i i | i ƒ o d Sd S( Ni i ( R R R t isdirR ( R ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyR- ` s
c C sp | i ob | i ƒ } | t i ƒ | i j o8 y t i | i ƒ Wn t i j
o
} d SXd Sql n d S( Ni i ( R3 R4 R% R RA R R ( R R6 R2 ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyR h s
c C s
t d ‚ d S( s€ Locking info is not available for DirectyFileLocks.
A TypeError is raised in case this method is called.
s4 .lock_info() is not implemented for DirectyFileLocksN( t TypeError( R ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyR! y s c C sO y t i | i ƒ d } Wn. t i j
o } t d | i | f ‚ n X| S( Ni s* could not read file lock info for "%s": %s( R t statR R R
R ( R R6 R2 ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyR4 ƒ s c C s( d | _ y | | i ƒ Wn n Xd S( Ni ( R R ( R RA ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyR: s
( R R R> R% R$ R
R R R R R@ R+ RA R R- R R! R4 R: ( ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyR? ( s
R c
C sª t d ƒ } t i ƒ } yH xA t d ƒ D]3 } d | G| i ƒ t i | d ƒ | i ƒ q( WWn t j
o | i ƒ n Xt i ƒ | } d | | | | f GHd S( Ns test-locki' s %i
g jø@s5 %i lock/release cycles in %5.2f sec. = %i cycles/sec.( t FileLockR% t rangeR+ R$ R t KeyboardInterrupt( R+ t starttimet it totaltime( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyt _testž s
t __main__( R s 127.0.0.1( ( R> t mx.Misc.ExitFunctionsR R t
exceptionsR% R/ t __version__R R R R t
StandardErrorR
t
FileLockErrorR t BaseFileLockR? t hasattrRE RK R ( ( ( s9 /usr/lib64/python2.6/site-packages/mx/BeeBase/FileLock.pyt
s 0íq