cancel if error

2 years ago · d416fd9ff5
parent 66f3c58c39
commit d416fd9ff5
1 changed files with 1 additions and 0 deletions
--- a/agent/proxycfg/connect_proxy.go
+++ b/agent/proxycfg/connect_proxy.go
@ -460,6 +460,7 @@ func (s *handlerConnectProxy) handleUpdate(ctx context.Context, u UpdateEvent, s
 				EnterpriseMeta: *structs.DefaultEnterpriseMetaInPartition(s.proxyID.PartitionOrDefault()),
 			}, DestinationConfigEntryID+":"+NewUpstreamIDFromServiceName(svc).String(), s.ch)
 			if err != nil {
+				cancel()
 				return err
 			}