gitops/patroni
1
0
Fork 0
mirror of https://github.com/outbackdingo/patroni.git synced 2026-08-25 14:53:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #187 from zalando/feature/zookeeper-rename-variable

Browse Source 
Rename me->member (variable name was too confusing)
This commit is contained in:
Alexander Kukushkin
2016-04-22 16:10:32 +02:00
parent dcdaabc747 a18c878a56
commit 0c6d259a0a
1 changed files with 7 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
patroni/zookeeper.py
+7 -8
View File
@@ -207,27 +207,26 @@ class ZooKeeper(AbstractDCS):
def touch_member(self, data, ttl=None):
cluster = self.cluster
me = cluster and ([m for m in cluster.members if m.name == self._name] or [None])[0]
member = cluster and ([m for m in cluster.members if m.name == self._name] or [None])[0]
path = self.member_path
data = data.encode('utf-8')
create = not me
if me and self._client.client_id is not None and me.session != self._client.client_id[0]:
if member and self._client.client_id is not None and member.session != self._client.client_id[0]:
try:
self._client.retry(self._client.delete, path)
except NoNodeError:
pass
except:
return False
create = True
member = None
if not create and data == self._my_member_data:
if member and data == self._my_member_data:
return True
try:
if create:
self._client.retry(self._client.create, path, data, makepath=True, ephemeral=True)
else:
if member:
self._client.retry(self._client.set, path, data)
else:
self._client.retry(self._client.create, path, data, makepath=True, ephemeral=True)
self._my_member_data = data
return True
except NodeExistsError: