Merge pull request #11257 from lzhfromustc/grpcproxy_mis_unlock

grpcproxy: Add an Unlock before continue to prevent double lock
This commit is contained in:
Jingyi Hu 2019-10-21 17:47:43 -07:00 committed by GitHub
commit 92f313811e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

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++