From 6e6eb962ee4f38190bafd451e40a4b51ce8783e6 Mon Sep 17 00:00:00 2001
From: Antonio Navarro Perez <antnavper@gmail.com>
Date: Tue, 23 Mar 2021 14:20:14 +0100
Subject: [PATCH] Call cancel when we try to renew the lease after an error.

Signed-off-by: Antonio Navarro Perez <antnavper@gmail.com>
---
 etcd/leasedkv.go | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/etcd/leasedkv.go b/etcd/leasedkv.go
index 858c000d8..17a35ed0b 100644
--- a/etcd/leasedkv.go
+++ b/etcd/leasedkv.go
@@ -66,6 +66,11 @@ func (l *leasedKV) Start(initValue string) error {
 
 func (l *leasedKV) create(initValue string) (<-chan *clientv3.LeaseKeepAliveResponse, error) {
 	ctx, cancel := context.WithCancel(context.Background())
+
+	if l.cancel != nil {
+		l.cancel()
+	}
+
 	l.cancel = cancel
 
 	leaseResp, err := l.cli.Grant(ctx, l.ttlSeconds)