From 8781e1d44c6245c16a2efcfc06b933308b9a2529 Mon Sep 17 00:00:00 2001 From: Changxin Miao Date: Mon, 6 Apr 2020 13:43:37 +0800 Subject: [PATCH] etcdserver: watch stream got closed once one request is not permitted (#11708) --- etcdserver/api/v3rpc/watch.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/etcdserver/api/v3rpc/watch.go b/etcdserver/api/v3rpc/watch.go index 9b46b0d7597..303b3e45d36 100644 --- a/etcdserver/api/v3rpc/watch.go +++ b/etcdserver/api/v3rpc/watch.go @@ -230,9 +230,10 @@ func (sws *serverWatchStream) recvLoop() error { select { case sws.ctrlStream <- wr: + continue case <-sws.closec: + return nil } - return nil } filters := FiltersFromRequest(creq)