From 9c8554573f3053e1a63a351f379a5c63033f5304 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 f41cb6c0569..dcc4cc63700 100644 --- a/etcdserver/api/v3rpc/watch.go +++ b/etcdserver/api/v3rpc/watch.go @@ -259,9 +259,10 @@ func (sws *serverWatchStream) recvLoop() error { select { case sws.ctrlStream <- wr: + continue case <-sws.closec: + return nil } - return nil } filters := FiltersFromRequest(creq)