xds/client: send connection errors to all watchers (grpc#5054)

easwars · Dec 14, 2021 · 2232c6f · 2232c6f
1 parent 46e883a
commit 2232c6f
Showing 1 changed file with 15 additions and 0 deletions.
diff --git a/xds/internal/xdsclient/pubsub/update.go b/xds/internal/xdsclient/pubsub/update.go
@@ -295,6 +295,21 @@ func (pb *Pubsub) NewConnectionError(err error) {
 	pb.mu.Lock()
 	defer pb.mu.Unlock()
 
+	for _, s := range pb.ldsWatchers {
+		for wi := range s {
+			wi.newError(xdsresource.NewErrorf(xdsresource.ErrorTypeConnection, "xds: error received from xDS stream: %v", err))
+		}
+	}
+	for _, s := range pb.rdsWatchers {
+		for wi := range s {
+			wi.newError(xdsresource.NewErrorf(xdsresource.ErrorTypeConnection, "xds: error received from xDS stream: %v", err))
+		}
+	}
+	for _, s := range pb.cdsWatchers {
+		for wi := range s {
+			wi.newError(xdsresource.NewErrorf(xdsresource.ErrorTypeConnection, "xds: error received from xDS stream: %v", err))
+		}
+	}
 	for _, s := range pb.edsWatchers {
 		for wi := range s {
 			wi.newError(xdsresource.NewErrorf(xdsresource.ErrorTypeConnection, "xds: error received from xDS stream: %v", err))