diff --git a/clientv3/lease.go b/clientv3/lease.go index f5937fd4d..f9c720f67 100644 --- a/clientv3/lease.go +++ b/clientv3/lease.go @@ -416,7 +416,7 @@ func (l *lessor) recvKeepAlive(resp *pb.LeaseKeepAliveResponse) { } // send update to all channels - nextKeepAlive := time.Now().Add(1 + time.Duration(karesp.TTL/3)*time.Second) + nextKeepAlive := time.Now().Add(time.Duration(karesp.TTL/3+1) * time.Second) ka.deadline = time.Now().Add(time.Duration(karesp.TTL) * time.Second) for _, ch := range ka.chs { select {