commit 5d41c674f0fef708e187311ca2c3a6deba2d6cf2 Author: Yawning Angel yawning@schwanenlied.me Date: Sat Jan 26 15:13:06 2019 +0000
transports/meeklite: Apply http.DefaultTransport timeouts etc --- transports/meeklite/transport.go | 19 +++++++++++++++++-- 1 file changed, 17 insertions(+), 2 deletions(-)
diff --git a/transports/meeklite/transport.go b/transports/meeklite/transport.go index 59000a3..a6e1734 100644 --- a/transports/meeklite/transport.go +++ b/transports/meeklite/transport.go @@ -83,7 +83,7 @@ func (rt *roundTripper) RoundTrip(req *http.Request) (*http.Response, error) { func (rt *roundTripper) getTransport(req *http.Request) error { switch strings.ToLower(req.URL.Scheme) { case "http": - rt.transport = &http.Transport{Dial: rt.dialFn} + rt.transport = newHTTPTransport(rt.dialFn, nil) return nil case "https": default: @@ -145,7 +145,7 @@ func (rt *roundTripper) dialTLS(network, addr string) (net.Conn, error) { rt.transport = &http2.Transport{DialTLS: rt.dialTLSHTTP2} default: // Assume the remote peer is speaking HTTP 1.x + TLS. - rt.transport = &http.Transport{DialTLS: rt.dialTLS} + rt.transport = newHTTPTransport(nil, rt.dialTLS) }
// Stash the connection just established for use servicing the @@ -190,6 +190,21 @@ func parseClientHelloID(s string) (*utls.ClientHelloID, error) { return nil, fmt.Errorf("invalid ClientHelloID: '%v'", s) }
+func newHTTPTransport(dialFn, dialTLSFn base.DialFunc) *http.Transport { + base := (http.DefaultTransport).(*http.Transport) + + return &http.Transport{ + Dial: dialFn, + DialTLS: dialTLSFn, + + // Use default configuration values, taken from the runtime. + MaxIdleConns: base.MaxIdleConns, + IdleConnTimeout: base.IdleConnTimeout, + TLSHandshakeTimeout: base.TLSHandshakeTimeout, + ExpectContinueTimeout: base.ExpectContinueTimeout, + } +} + func init() { // Attempt to increase compatibility, there's an encrypted link // underneath, and this doesn't (shouldn't) affect the external