support linearizable renew lease

etcd-io · Feb 12, 2022 · a5ba619 · a5ba619
1 parent bba3937
commit a5ba619
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/server/etcdserver/v3_server.go b/server/etcdserver/v3_server.go
@@ -279,6 +279,12 @@ func (s *EtcdServer) LeaseRevoke(ctx context.Context, r *pb.LeaseRevokeRequest)
 }
 
 func (s *EtcdServer) LeaseRenew(ctx context.Context, id lease.LeaseID) (int64, error) {
+	if s.isLeader() {
+		if err := s.LinearizableReadNotify(ctx); err != nil {
+			return 0, err
+		}
+	}
+
 	ttl, err := s.lessor.Renew(id)
 	if err == nil { // already requested to primary lessor(leader)
 		return ttl, nil