From 993fd76b19b519738e087abb43ff6bed55c9d4e5 Mon Sep 17 00:00:00 2001 From: Anthony Romano Date: Wed, 24 Feb 2016 22:30:12 -0800 Subject: [PATCH] clientv3: respect first stream error in lease recv loop Fixes #4622 --- clientv3/lease.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/clientv3/lease.go b/clientv3/lease.go index 1b896218a..af0894e30 100644 --- a/clientv3/lease.go +++ b/clientv3/lease.go @@ -258,15 +258,13 @@ func (l *lessor) recvKeepAliveLoop() { }() stream, serr := l.resetRecv() - for { + for serr == nil { resp, err := stream.Recv() if err != nil { if isRPCError(err) { return } - if stream, serr = l.resetRecv(); serr != nil { - return - } + stream, serr = l.resetRecv() continue } l.recvKeepAlive(resp)