Merge pull request #11754 from polyrabbit/unpermitted-watch

etcdserver: watch stream got closed if one watch request is not permitted
This commit is contained in:
Jingyi Hu
2020-04-06 21:56:05 +08:00
committed by GitHub

View File

@@ -255,9 +255,10 @@ func (sws *serverWatchStream) recvLoop() error {
select {
case sws.ctrlStream <- wr:
continue
case <-sws.closec:
return nil
}
return nil
}
filters := FiltersFromRequest(creq)