grpcproxy: Add an Unlock before continue to prevent double lock

This commit is contained in:
lzhfromustc
2019-10-14 21:44:07 -04:00
parent bcc147127d
commit e8a60d735f

View File

@@ -254,6 +254,7 @@ func (wps *watchProxyStream) recvLoop() error {
}
if !w.wr.valid() {
w.post(&pb.WatchResponse{WatchId: -1, Created: true, Canceled: true})
wps.mu.Unlock()
continue
}
wps.nextWatcherID++