diff options
| author | Kaifeng Wang <kaifeng.w@gmail.com> | 2019-08-10 10:08:33 +0800 |
|---|---|---|
| committer | Kaifeng Wang <kaifeng.w@gmail.com> | 2019-08-12 14:12:46 +0000 |
| commit | 55864ed2450dc8adb3ea77be0e2edba061b6c548 (patch) | |
| tree | 2559e32594e321b47e625c140a6f9db7bc8065d2 /tooz/drivers | |
| parent | a4f1288ee4234865a4db8b9c191ba275e2deef3d (diff) | |
| download | tooz-55864ed2450dc8adb3ea77be0e2edba061b6c548.tar.gz | |
Fix membership lease issue on the etcd3gw driver
The backend driver of etcd3gw doesn't update membership lease
on heartbeat, this patch aligns the implementation with etcd3
driver.
Change-Id: I2a6a11d59c4c82124f4d42391176031656e26528
Closes-Bug: #1839691
Diffstat (limited to 'tooz/drivers')
| -rw-r--r-- | tooz/drivers/etcd3gw.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/tooz/drivers/etcd3gw.py b/tooz/drivers/etcd3gw.py index eedaf6f..0c64e70 100644 --- a/tooz/drivers/etcd3gw.py +++ b/tooz/drivers/etcd3gw.py @@ -218,7 +218,9 @@ class Etcd3Driver(coordination.CoordinationDriverWithExecutor): # NOTE(jaypipes): Copying because set can mutate during iteration for lock in self._acquired_locks.copy(): lock.heartbeat() - return self.lock_timeout + # TODO(kaifeng) use the same lease for locks? + self._membership_lease.refresh() + return min(self.lock_timeout, self.membership_timeout) def watch_join_group(self, group_id, callback): raise tooz.NotImplemented |