mirror of
https://github.com/kubenetworks/kubevpn.git
synced 2025-12-24 11:51:13 +08:00
chore: upgrade go mod library
This commit is contained in:
24
vendor/github.com/envoyproxy/go-control-plane/pkg/server/delta/v3/server.go
generated
vendored
24
vendor/github.com/envoyproxy/go-control-plane/pkg/server/delta/v3/server.go
generated
vendored
@@ -107,7 +107,7 @@ func (s *server) processDelta(str stream.DeltaStream, reqCh <-chan *discovery.De
|
||||
process := func(resp cache.DeltaResponse) error {
|
||||
typ := resp.GetDeltaRequest().GetTypeUrl()
|
||||
if resp == deltaErrorResponse {
|
||||
return status.Errorf(codes.Unavailable, typ+" watch failed")
|
||||
return status.Errorf(codes.Unavailable, "%s watch failed", typ)
|
||||
}
|
||||
|
||||
nonce, err := send(resp)
|
||||
@@ -230,23 +230,21 @@ func (s *server) DeltaStreamHandler(str stream.DeltaStream, typeURL string) erro
|
||||
|
||||
// we need to concurrently handle incoming requests since we kick off processDelta as a return
|
||||
go func() {
|
||||
defer close(reqCh)
|
||||
for {
|
||||
select {
|
||||
case <-str.Context().Done():
|
||||
close(reqCh)
|
||||
req, err := str.Recv()
|
||||
if err != nil {
|
||||
return
|
||||
}
|
||||
select {
|
||||
case reqCh <- req:
|
||||
case <-str.Context().Done():
|
||||
return
|
||||
case <-s.ctx.Done():
|
||||
return
|
||||
default:
|
||||
req, err := str.Recv()
|
||||
if err != nil {
|
||||
close(reqCh)
|
||||
return
|
||||
}
|
||||
|
||||
reqCh <- req
|
||||
}
|
||||
}
|
||||
}()
|
||||
|
||||
return s.processDelta(str, reqCh, typeURL)
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user