|
Server : Apache/2.2.2 (Fedora) System : Linux App1.pathumtani.go.th 2.6.20-1.2320.fc5smp #1 SMP Tue Jun 12 19:40:16 EDT 2007 i686 User : apache ( 48) PHP Version : 5.2.9 Disable Function : NONE Directory : /proc/self/root/usr/lib/python2.4/site-packages/mx/BeeBase/ |
Upload File : |
mò
ñÔ5;c @ s² d Z d k l Z d k Z d k Z d k Z d k Z d d d „ Z e ƒ \ Z Z d e i
f d „ ƒ YZ e Z d f d „ ƒ YZ
e
Z d
„ Z e d j o e ƒ n d S(
s FileLock - Implements a file lock mechanism that does not depend
on fcntl.
Copyright (c) 1997-2000, Marc-Andre Lemburg; mailto:mal@lemburg.com
See the documentation for further information on copyrights,
or contact the author. All Rights Reserved.
( s
ExitFunctionsNt localhosts 127.0.0.1c C s• y
d k } Wn t j
o | Sn XyC | d j o | i ƒ } n | i | ƒ } | i | ƒ d } Wn | i j
o | Sn X| | 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.
Ni (
t sockett ImportErrort defaultt hostnamet Nonet gethostnamet
gethostbynamet ipt
gethostbyaddrt error( R R R R ( ( t7 /usr/lib/python2.4/site-packages/mx/BeeBase/FileLock.pyt _fqhostname s
t Errorc B s t Z RS( N( t __name__t
__module__( ( ( R R
, s t SymbolicFileLockc B s‰ t 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 e i d „ Z d „ Z RS(
sÚ Implements a file lock mechanism that uses symbolic links
for locking.
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 selft lockfilenamet lockedt
ExitFunctionst registert unlock( R R ( ( R t __init__H s
c C s= | i o | i d ƒ n y t i | i ƒ Wn n Xd S( Ni ( R R R R t
deregister( R ( ( R t __del__P s
iô f0.0001c C sä | i o d Sn | i } d | t i ƒ f } | ƒ | d } t i
i } t i }
t i } xt| | ƒ p, y |
| | ƒ Wn | j
o qœ XPn | | ƒ | ƒ | j o y" t i | | ƒ d ƒ \ }
} Wn+ | j
o } | d | i | f ‚ n Xt i | ƒ } |
| j o& t |
d d ƒd } | | j } n d } | o] y t i | d ƒ Wq²| j
o6 } y t i | i ƒ Wqc | j
o q®Xqc q²Xn | d
| i |
| | f ‚ qc qc Wd | _ 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:%if0.001i t :s! file "%s" could not be locked: %sR s ???i s$ file "%s" is locked by process %s:%i( s ???s ???( R R R R t ost getpidt lockinfot timet timeoutt stopt patht islinkt symlinkt makelinkt readlinkR
t sleept sleeptimet stringt splitt hostt locking_pidR
t whyR t atoiR t other_ipR t samehostt killt unlink( R R R( R' R
R R
R R R R% R# R! R+ R& R- R0 R/ R, R ( ( R t lockY sN
"
%c C sk | i p d Sn d | _ 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 lock file "%s" is already gonei ( R R R2 R R
R
R( R' ( R R( R2 R
R' R
( ( R R ¢ s
c C s( d | _ y | | i ƒ Wn n Xd S( s/ Remove any existing lock on the file.
i N( R R R2 R ( R R2 ( ( R t remove_lock¿ s c C s d | i i | i t | ƒ f S( Ns <%s for "%s" at %x>( R t __class__R R t id( R ( ( R t __repr__Ë s ( R R t __doc__R R R R R' R
R R
R R R3 R2 R R4 R7 ( ( ( R R 4 s *I! c C sU t d ƒ } xA t d ƒ D]3 } d | G| i ƒ t i | d ƒ | i ƒ q WHd S( Ns test.locki' s %i
f100000.0( R R3 t ranget iR R' R ( R: R3 ( ( R t _testÔ s
t __main__( R s 127.0.0.1( R8 R R t
exceptionsR R) R R R R t
StandardErrorR
t
FileLockErrorR t FileLockR; R (
R@ R) R R R; R R R
R R R= R? R ( ( R t ?
s
$ž