We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0ee5a11 commit ac8f7b3Copy full SHA for ac8f7b3
1 file changed
internal/xds/server_stream.go
@@ -374,6 +374,11 @@ func (s *Server) recvInitialRequest(
374
375
resultCh := make(chan initialDiscoveryRequestResult, 1)
376
go func() {
377
+ // stream.Recv() blocks until the initial request arrives or the
378
+ // stream context is cancelled. When shutdownCh fires first, the
379
+ // goroutine remains blocked until StreamConfiguration returns and
380
+ // the gRPC framework cancels the stream context, which unblocks
381
+ // Recv() and allows the goroutine to exit.
382
req, err := stream.Recv()
383
resultCh <- initialDiscoveryRequestResult{req: req, err: err}
384
}()
0 commit comments