diff options
| author | Zuul <zuul@review.openstack.org> | 2018-10-08 12:03:09 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2018-10-08 12:03:09 +0000 |
| commit | fa152a1606caf845890412931c6c4319d30d2612 (patch) | |
| tree | 1cbf034ddc4f4cf22ce96fc7f3141ce610872482 | |
| parent | ae54cf2f540a61bc94131776a5b08d7f4853b3f3 (diff) | |
| parent | b5ebc60660f24e462ad5ee4aeb7028276f47d449 (diff) | |
| download | tooz-1.63.0.tar.gz | |
Merge "Ensure consistent encoding of strings for ID"1.63.0
| -rw-r--r-- | tooz/drivers/etcd3.py | 4 | ||||
| -rw-r--r-- | tooz/drivers/memcached.py | 6 |
2 files changed, 5 insertions, 5 deletions
diff --git a/tooz/drivers/etcd3.py b/tooz/drivers/etcd3.py index fc4290f..619f60a 100644 --- a/tooz/drivers/etcd3.py +++ b/tooz/drivers/etcd3.py @@ -160,10 +160,10 @@ class Etcd3Driver(coordination.CoordinationDriverCachedRunWatchers, GROUP_PREFIX = b"tooz/groups/" def _encode_group_id(self, group_id): - return self.GROUP_PREFIX + group_id + b"/" + return self.GROUP_PREFIX + utils.to_binary(group_id) + b"/" def _encode_group_member_id(self, group_id, member_id): - return self._encode_group_id(group_id) + member_id + return self._encode_group_id(group_id) + utils.to_binary(member_id) def create_group(self, group_id): encoded_group = self._encode_group_id(group_id) diff --git a/tooz/drivers/memcached.py b/tooz/drivers/memcached.py index 99fbcd4..3892e22 100644 --- a/tooz/drivers/memcached.py +++ b/tooz/drivers/memcached.py @@ -285,13 +285,13 @@ class MemcachedDriver(coordination.CoordinationDriverCachedRunWatchers, self.client.close() def _encode_group_id(self, group_id): - return self.GROUP_PREFIX + group_id + return self.GROUP_PREFIX + utils.to_binary(group_id) def _encode_member_id(self, member_id): - return self.MEMBER_PREFIX + member_id + return self.MEMBER_PREFIX + utils.to_binary(member_id) def _encode_group_leader(self, group_id): - return self.GROUP_LEADER_PREFIX + group_id + return self.GROUP_LEADER_PREFIX + utils.to_binary(group_id) @_retry.retry() def _add_group_to_group_list(self, group_id): |