summaryrefslogtreecommitdiff
path: root/designate/coordination.py
diff options
context:
space:
mode:
Diffstat (limited to 'designate/coordination.py')
-rw-r--r--designate/coordination.py9
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()])