etcdserver: watch stream got closed once one request is not permitted (…

…#11708)
etcd-io · Apr 6, 2020 · 3fde9e7 · 3fde9e7
1 parent c623f79
commit 3fde9e7
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/etcdserver/api/v3rpc/watch.go b/etcdserver/api/v3rpc/watch.go
@@ -223,6 +223,7 @@ func (sws *serverWatchStream) recvLoop() error {
 			return err
 		}
 
+	requestHandler:
 		switch uv := req.RequestUnion.(type) {
 		case *pb.WatchRequest_CreateRequest:
 			if uv.CreateRequest == nil {
@@ -255,9 +256,10 @@ func (sws *serverWatchStream) recvLoop() error {
 
 				select {
 				case sws.ctrlStream <- wr:
+					break requestHandler
 				case <-sws.closec:
+					return nil
 				}
-				return nil
 			}
 
 			filters := FiltersFromRequest(creq)