Add more logging
This commit is contained in:
@@ -20,7 +20,8 @@ class LockManager(models.Manager):
|
||||
lock.save(force_insert=True)
|
||||
logger.debug('acquired lock: %s' % name)
|
||||
return lock
|
||||
except IntegrityError:
|
||||
except IntegrityError, msg:
|
||||
logger.debug('IntegrityError: %s', msg)
|
||||
# There is already an existing lock
|
||||
# Check it's expiration date and if expired, reset it
|
||||
try:
|
||||
@@ -32,9 +33,10 @@ class LockManager(models.Manager):
|
||||
|
||||
if datetime.datetime.now() > lock.creation_datetime + datetime.timedelta(seconds=lock.timeout):
|
||||
logger.debug('reseting deleting stale lock: %s' % name)
|
||||
lock.timeout=timeout
|
||||
logger.debug('try to reacquire stale lock: %s' % name)
|
||||
lock.timeout = timeout
|
||||
logger.debug('trying to reacquire stale lock: %s' % name)
|
||||
lock.save()
|
||||
logger.debug('reacquired stale lock: %s' % name)
|
||||
return lock
|
||||
else:
|
||||
logger.debug('unable to acquire lock: %s' % name)
|
||||
|
||||
Reference in New Issue
Block a user