diff options
Diffstat (limited to 'designate/coordination.py')
-rw-r--r-- | designate/coordination.py | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/designate/coordination.py b/designate/coordination.py index b813f455..e2e34f28 100644 --- a/designate/coordination.py +++ b/designate/coordination.py @@ -19,6 +19,7 @@ import math import time +from oslo_concurrency import lockutils from oslo_log import log import tenacity import tooz.coordination @@ -51,6 +52,14 @@ class Coordination(object): def started(self): return self._started + def get_lock(self, name): + if self._coordinator: + # NOTE(eandersson): Workaround until tooz handles the conversion. + if not isinstance(name, bytes): + name = name.encode('ascii') + return self._coordinator.get_lock(name) + return lockutils.lock(name) + def start(self): self.coordination_id = ":".join([CONF.host, generate_uuid()]) |