|
|
import os, time
|
|
|
import sys
|
|
|
from warnings import warn
|
|
|
|
|
|
class LockHeld(Exception):pass
|
|
|
|
|
|
|
|
|
class DaemonLock(object):
|
|
|
"""daemon locking
|
|
|
USAGE:
|
|
|
try:
|
|
|
l = lock()
|
|
|
main()
|
|
|
l.release()
|
|
|
except LockHeld:
|
|
|
sys.exit(1)
|
|
|
"""
|
|
|
|
|
|
def __init__(self, file=None, callbackfn=None,
|
|
|
desc='daemon lock', debug=False):
|
|
|
|
|
|
self.pidfile = file if file else os.path.join(os.path.dirname(__file__),
|
|
|
'running.lock')
|
|
|
self.callbackfn = callbackfn
|
|
|
self.desc = desc
|
|
|
self.debug = debug
|
|
|
self.held = False
|
|
|
#run the lock automatically !
|
|
|
self.lock()
|
|
|
|
|
|
def __del__(self):
|
|
|
if self.held:
|
|
|
|
|
|
# warn("use lock.release instead of del lock",
|
|
|
# category = DeprecationWarning,
|
|
|
# stacklevel = 2)
|
|
|
|
|
|
# ensure the lock will be removed
|
|
|
self.release()
|
|
|
|
|
|
|
|
|
def lock(self):
|
|
|
"""
|
|
|
locking function, if lock is present it will raise LockHeld exception
|
|
|
"""
|
|
|
lockname = '%s' % (os.getpid())
|
|
|
|
|
|
self.trylock()
|
|
|
self.makelock(lockname, self.pidfile)
|
|
|
return True
|
|
|
|
|
|
def trylock(self):
|
|
|
running_pid = False
|
|
|
try:
|
|
|
pidfile = open(self.pidfile, "r")
|
|
|
pidfile.seek(0)
|
|
|
running_pid = pidfile.readline()
|
|
|
if self.debug:
|
|
|
print 'lock file present running_pid: %s, checking for execution'\
|
|
|
% running_pid
|
|
|
# Now we check the PID from lock file matches to the current
|
|
|
# process PID
|
|
|
if running_pid:
|
|
|
if os.path.exists("/proc/%s" % running_pid):
|
|
|
print "You already have an instance of the program running"
|
|
|
print "It is running as process %s" % running_pid
|
|
|
raise LockHeld
|
|
|
else:
|
|
|
print "Lock File is there but the program is not running"
|
|
|
print "Removing lock file for the: %s" % running_pid
|
|
|
self.release()
|
|
|
except IOError, e:
|
|
|
if e.errno != 2:
|
|
|
raise
|
|
|
|
|
|
|
|
|
def release(self):
|
|
|
"""
|
|
|
releases the pid by removing the pidfile
|
|
|
"""
|
|
|
if self.callbackfn:
|
|
|
#execute callback function on release
|
|
|
if self.debug:
|
|
|
print 'executing callback function %s' % self.callbackfn
|
|
|
self.callbackfn()
|
|
|
try:
|
|
|
if self.debug:
|
|
|
print 'removing pidfile %s' % self.pidfile
|
|
|
os.remove(self.pidfile)
|
|
|
self.held = False
|
|
|
except OSError, e:
|
|
|
if self.debug:
|
|
|
print 'removing pidfile failed %s' % e
|
|
|
pass
|
|
|
|
|
|
def makelock(self, lockname, pidfile):
|
|
|
"""
|
|
|
this function will make an actual lock
|
|
|
@param lockname: acctual pid of file
|
|
|
@param pidfile: the file to write the pid in
|
|
|
"""
|
|
|
if self.debug:
|
|
|
print 'creating a file %s and pid: %s' % (pidfile, lockname)
|
|
|
pidfile = open(self.pidfile, "wb")
|
|
|
pidfile.write(lockname)
|
|
|
pidfile.close
|
|
|
self.held = True
|
|
|
|
|
|
|
|
|
def main():
|
|
|
print 'func is running'
|
|
|
cnt = 20
|
|
|
while 1:
|
|
|
print cnt
|
|
|
if cnt == 0:
|
|
|
break
|
|
|
time.sleep(1)
|
|
|
cnt -= 1
|
|
|
|
|
|
|
|
|
if __name__ == "__main__":
|
|
|
try:
|
|
|
l = DaemonLock(desc='test lock')
|
|
|
main()
|
|
|
l.release()
|
|
|
except LockHeld:
|
|
|
sys.exit(1)
|
|
|
|
