From e8a60d735f2b4a8b2a6774cbae0ca4546e5a82f5 Mon Sep 17 00:00:00 2001 From: lzhfromustc Date: Mon, 14 Oct 2019 21:44:07 -0400 Subject: [PATCH] grpcproxy: Add an Unlock before continue to prevent double lock --- proxy/grpcproxy/watch.go | 1 + 1 file changed, 1 insertion(+) diff --git a/proxy/grpcproxy/watch.go b/proxy/grpcproxy/watch.go index eae98e3b2..179859a84 100644 --- a/proxy/grpcproxy/watch.go +++ b/proxy/grpcproxy/watch.go @@ -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++