etcdserver: watch stream got closed once one request is not permitted (#11708)

This commit is contained in:
Changxin Miao 2020-04-06 13:43:37 +08:00
parent c623f798cb
commit 73b936b50a

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)