diff --git a/proxy/proxy.go b/proxy/proxy.go index 5a3d2e62..9a4a91d9 100644 --- a/proxy/proxy.go +++ b/proxy/proxy.go @@ -33,6 +33,10 @@ const ( trailerHeaderName = "Trailer" ) +var ( + ErrRequestEndedAbruptly = errors.New("Incoming request ended abruptly") +) + // Proxy represents a means to Proxy between cloudflared and the origin services. type Proxy struct { ingressRules ingress.Ingress @@ -123,7 +127,11 @@ func (p *Proxy) ProxyHTTP( logFields, ); err != nil { rule, srv := ruleField(p.ingressRules, ruleNum) - p.logRequestError(err, cfRay, "", rule, srv) + if errors.Is(err, ErrRequestEndedAbruptly) { + p.log.Debug().Msg(err.Error()) + } else { + p.logRequestError(err, cfRay, "", rule, srv) + } return err } return nil @@ -225,7 +233,7 @@ func (p *Proxy) proxyHTTPRequest( if err != nil { tracing.EndWithErrorStatus(ttfbSpan, err) if err := roundTripReq.Context().Err(); err != nil { - return errors.Wrap(err, "Incoming request ended abruptly") + return ErrRequestEndedAbruptly } return errors.Wrap(err, "Unable to reach the origin service. The service may be down or it may not be responding to traffic from cloudflared") }