diff options
author | Paul "LeoNerd" Evans <paul@matrix.org> | 2014-08-14 16:06:02 +0100 |
---|---|---|
committer | Paul "LeoNerd" Evans <paul@matrix.org> | 2014-08-14 16:06:05 +0100 |
commit | 657ab9ba9d0b1afda959267d05479983ce8bfaa4 (patch) | |
tree | 81462b8e908ca0d3ce6f3590074780b2f4d07c67 /synapse/util/lockutils.py | |
parent | Be more helpful when failing to register/login, stating why (communication er... (diff) | |
download | synapse-657ab9ba9d0b1afda959267d05479983ce8bfaa4.tar.xz |
Put some DEBUG logging in lockutils.py so we can debug roomlocks
Diffstat (limited to '')
-rw-r--r-- | synapse/util/lockutils.py | 12 |
1 files changed, 9 insertions, 3 deletions
diff --git a/synapse/util/lockutils.py b/synapse/util/lockutils.py index 758be0b901..d0bb50d035 100644 --- a/synapse/util/lockutils.py +++ b/synapse/util/lockutils.py @@ -24,9 +24,10 @@ logger = logging.getLogger(__name__) class Lock(object): - def __init__(self, deferred): + def __init__(self, deferred, key): self._deferred = deferred self.released = False + self.key = key def release(self): self.released = True @@ -38,9 +39,10 @@ class Lock(object): self.release() def __enter__(self): - return self + return self def __exit__(self, type, value, traceback): + logger.debug("Releasing lock for key=%r", self.key) self.release() @@ -63,6 +65,10 @@ class LockManager(object): self._lock_deferreds[key] = new_deferred if old_deferred: + logger.debug("Queueing on lock for key=%r", key) yield old_deferred + logger.debug("Obtained lock for key=%r", key) + else: + logger.debug("Entering uncontended lock for key=%r", key) - defer.returnValue(Lock(new_deferred)) + defer.returnValue(Lock(new_deferred, key)) |