locker Namespace Reference

Classes
class	LockFile
	Lock a file. More...

Functions
def	lock

def	unlock

def	_tmpFileName

def	_lckFileName

def	_linkCount

def	_read

def	_sleep

Variables
	LOCK_EX fcntl.F_WRLCK

	LOCK_SH fcntl.F_RDLCK

	LOCK_NB fcntl.F_UNLCK

Function Documentation

def locker._lckFileName ( fileName )

private

Definition at line 51 of file locker.py.

 
     def _lckFileName(fileName):
         return "%s.lock" % fileName

def locker._linkCount ( lockFileName )

private

Definition at line 54 of file locker.py.

 
     def _linkCount( lockFileName ):
         try:
             return os.stat(lockFileName).st_nlink
         except OSError, e:
             if e.errno != errno.ENOENT:
                 raise
return -1

def locker._read ( fileName )

private

Definition at line 61 of file locker.py.

 
     def _read(fileName):
         try:
             fp = open(fileName)
             try:     readFileName = fp.read()
             finally: fp.close()
             return readFileName
         except EnvironmentError, e:
             if e.errno != errno.ENOENT:
                 raise
             return None

def locker._sleep ( )

private

Definition at line 72 of file locker.py.

73 def _sleep(): time.sleep(8)

def locker._tmpFileName ( fileName )

private

Definition at line 49 of file locker.py.

50 def _tmpFileName(fileName):

return "%s.%s.%d" % ( fileName, socket.gethostname(), os.getpid() )

def locker.lock ( file )

Lock first 10 bytes of a file.

Definition at line 19 of file locker.py.

 
     def lock(file):
         """
         Lock first 10 bytes of a file.
         """ 
         pos = file.tell() # remember current position
         file.seek(0)
         # By default, python tries about 10 times, then throws an exception.
         # We want to wait forever.
         acquired = False
         while not acquired:
             try:
                 msvcrt.locking(file.fileno(),msvcrt.LK_LOCK,10)
                 acquired = True
             except IOError, x:
                 if x.errno != 36: # 36, AKA 'Resource deadlock avoided', is normal
                     raise
         file.seek(pos) # reset position

def locker.unlock ( file )

Unlock first 10 bytes of a file.

Definition at line 37 of file locker.py.

 
     def unlock(file):
         """
         Unlock first 10 bytes of a file.
         """ 
         pos = file.tell() # remember current position
         file.seek(0)
         msvcrt.locking(file.fileno(),msvcrt.LK_UNLCK,10)
         file.seek(pos) # reset position

Gaudi Framework, version v24r2

Classes

Functions

Variables

Function Documentation

Variable Documentation