python.SingleAppInstance.SingleAppInstance Class Reference

Inheritance diagram for python.SingleAppInstance.SingleAppInstance:

Collaboration diagram for python.SingleAppInstance.SingleAppInstance:

Classes
class	FileLockAcquisitionError
class	FileLockReleaseError

Public Types
typedef HLT::TypeInformation::for_each_type_c< typenameEDMLIST::map, my_functor, my_result<>, my_arg< HLT::TypeInformation::get_cont, CONTAINER > >::type	result

Public Member Functions
	__init__ (self, path, debug=None, blocking=False)
	acquire (self)
	release (self)
	islocked (self)
	ownlock (self)
	__del__ (self)
	__enter__ (self)
	__exit__ (self, typ, value, tb)

Public Attributes
	pid = os.getpid()
	host = socket.gethostname()
	path = path
	debug = debug
bool	locked = False
	lockfile = None
	blocking = blocking

Static Public Attributes
str	addr = lambda self: '%d@%s' % (self.pid, self.host)
str	fddr = lambda self: '<%s %s>' % (self.path, self.addr())
str	pddr

Protected Member Functions
	_readlock (self)

Detailed Description

Class to handle creating and removing lockfiles

Definition at line 13 of file SingleAppInstance.py.

Member Typedef Documentation

result

typedef HLT::TypeInformation::for_each_type_c<typenameEDMLIST::map,my_functor,my_result<>,my_arg<HLT::TypeInformation::get_cont,CONTAINER>>::type master_search< typenameEDMLIST::map, HLT::TypeInformation::get_cont, CONTAINER >::result

inherited

Definition at line 90 of file EDM_MasterSearch.h.

Constructor & Destructor Documentation

__init__()

python.SingleAppInstance.SingleAppInstance.__init__	(		self,
			path,
			debug = None,
			blocking = False )

Definition at line 27 of file SingleAppInstance.py.

    def __init__(self, path, debug=None, blocking = False):
        self.pid   = os.getpid()
        self.host  = socket.gethostname()
        self.path  = path
        self.debug = debug # set this to get status messages
        self.locked = False
        self.lockfile = None
        self.blocking = blocking
  

__del__()

python.SingleAppInstance.SingleAppInstance.__del__

(

self

)

Magic method to clean up lock when program exits

Definition at line 119 of file SingleAppInstance.py.

    def __del__(self):
        '''Magic method to clean up lock when program exits'''
        self.release()
 

Member Function Documentation

__enter__()

python.SingleAppInstance.SingleAppInstance.__enter__

(

self

)

Definition at line 123 of file SingleAppInstance.py.

    def __enter__(self):
        self.acquire()
        return self
 

__exit__()

python.SingleAppInstance.SingleAppInstance.__exit__	(		self,
			typ,
			value,
			tb )

Definition at line 127 of file SingleAppInstance.py.

    def __exit__(self, typ, value, tb):
        self.release()
        return self

_readlock()

python.SingleAppInstance.SingleAppInstance._readlock ( self )

protected

Internal method to read lock info

Definition at line 99 of file SingleAppInstance.py.

    def _readlock(self):
        '''Internal method to read lock info'''
        try:
            lock = {}
            fh   = open(self.path)
            data = fh.read().rstrip().split('@')
            fh.close()
            lock['pid'], lock['host'] = data
            return lock
        except Exception:
            return {'pid': 8**10, 'host': ''}
        

acquire()

python.SingleAppInstance.SingleAppInstance.acquire

(

self

)

Acquire a lock, returning self if successful, False otherwise

Definition at line 36 of file SingleAppInstance.py.

    def acquire(self):
        '''Acquire a lock, returning self if successful, False otherwise'''
        if self.islocked():
            if self.debug:
                lock = self._readlock()
                print('Previous lock detected: %s' % self.pddr(lock))
            return False
        try:
            fd = os.open(self.path, os.O_RDWR | os.O_CREAT, 0o777)
            fh = os.fdopen(fd, 'r+')
            self.lockfile = fh
            fh.seek(0)
            try:
                fcntlflag = fcntl.LOCK_EX
                if not self.blocking:
                    fcntlflag |= fcntl.LOCK_NB
                    fcntl.lockf(fh, fcntlflag)
                    self.locked = True
            except IOError:
                print('Unable to acquire lock on %s: existing lock %s' % (self.path, fh.read()))
                fh.close()
                return False
            fh.write(self.addr())
            fh.truncate()
            fh.flush()
            os.fsync(fh)
            if self.debug:
                modtime = os.stat(self.path)
                outstring = 'Acquired lock: '+ self.fddr() + ' at time '+ time.ctime(modtime.st_mtime)
                print(outstring)
        except Exception as e:
            if os.path.isfile(self.path):
                try:
                    # my guess is this causes problems
                    #os.unlink(self.path)
                    pass
                except Exception:
                    pass
            raise self.FileLockAcquisitionError(
              'Error acquiring lock: %s, reason %s' % (self.fddr(), e))
        return self
  

islocked()

python.SingleAppInstance.SingleAppInstance.islocked

(

self

)

Check if we already have a lock

Definition at line 111 of file SingleAppInstance.py.

    def islocked(self):
        '''Check if we already have a lock'''
        return self.locked
  

ownlock()

python.SingleAppInstance.SingleAppInstance.ownlock

(

self

)

Check if we own the lock

Definition at line 115 of file SingleAppInstance.py.

    def ownlock(self):
        '''Check if we own the lock'''
        return self.locked
  

release()

python.SingleAppInstance.SingleAppInstance.release

(

self

)

Release lock, returning self

Definition at line 78 of file SingleAppInstance.py.

    def release(self):
        '''Release lock, returning self'''
        if self.ownlock():
            try:
                fh = self.lockfile
                fcntl.lockf(fh, fcntl.LOCK_UN)
                self.locked = False
                self.lockfile.close()
                self.lockfile = None
                if not self.blocking:
                    # some space for a small race here unfortunately
                    os.unlink(self.path)
                if self.debug:
                    outstring  = 'Released lock: ' + self.fddr() +' at time ' +  time.ctime()
                    print(outstring)
            except Exception as e:
                print(e)
                raise self.FileLockReleaseError(
                  'Error releasing lock: %s, reason %s' % (self.fddr(), e))
        return self
  

Member Data Documentation

addr

str python.SingleAppInstance.SingleAppInstance.addr = lambda self: '%d@%s' % (self.pid, self.host)

static

Definition at line 22 of file SingleAppInstance.py.

blocking

python.SingleAppInstance.SingleAppInstance.blocking = blocking

Definition at line 34 of file SingleAppInstance.py.

debug

python.SingleAppInstance.SingleAppInstance.debug = debug

Definition at line 31 of file SingleAppInstance.py.

fddr

str python.SingleAppInstance.SingleAppInstance.fddr = lambda self: '<%s %s>' % (self.path, self.addr())

static

Definition at line 23 of file SingleAppInstance.py.

host

python.SingleAppInstance.SingleAppInstance.host = socket.gethostname()

Definition at line 29 of file SingleAppInstance.py.

locked

bool python.SingleAppInstance.SingleAppInstance.locked = False

Definition at line 32 of file SingleAppInstance.py.

lockfile

python.SingleAppInstance.SingleAppInstance.lockfile = None

Definition at line 33 of file SingleAppInstance.py.

path

python.SingleAppInstance.SingleAppInstance.path = path

Definition at line 30 of file SingleAppInstance.py.

pddr

str python.SingleAppInstance.SingleAppInstance.pddr

static

Initial value:

=  lambda self, lock: '<%s %s@%s>' %\
           (self.path, lock['pid'], lock['host'])

Definition at line 24 of file SingleAppInstance.py.

pid

python.SingleAppInstance.SingleAppInstance.pid = os.getpid()

Definition at line 28 of file SingleAppInstance.py.

---

The documentation for this class was generated from the following file:

• SingleAppInstance.py