소스 검색

clientv3: respect first stream error in lease recv loop

Fixes #4622
Anthony Romano 10 년 전
부모
커밋
993fd76b19
1개의 변경된 파일2개의 추가작업 그리고 4개의 파일을 삭제
  1. 2 4
      clientv3/lease.go

+ 2 - 4
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)