Skip to content

Commit

Permalink
Add http2 timouts to close bad TCP connection (#216)
Browse files Browse the repository at this point in the history
* Add http2 timouts to close bad TCP connection

* Update comment
  • Loading branch information
wangzlei authored Feb 27, 2024
1 parent 99b1588 commit 02e41f3
Showing 1 changed file with 18 additions and 4 deletions.
22 changes: 18 additions & 4 deletions pkg/conn/conn.go
Original file line number Diff line number Diff line change
Expand Up @@ -11,13 +11,13 @@ package conn

import (
"crypto/tls"
"encoding/json"
"io/ioutil"
"net/http"
"net/url"
"os"
"time"
"encoding/json"
"io/ioutil"
"strings"
"time"

"github.com/aws/aws-sdk-go/aws/awserr"
"github.com/aws/aws-sdk-go/aws/credentials"
Expand Down Expand Up @@ -63,12 +63,26 @@ func getNewHTTPClient(maxIdle int, requestTimeout int, noVerify bool, proxyAddre
transport := &http.Transport{
MaxIdleConnsPerHost: maxIdle,
TLSClientConfig: tls,
IdleConnTimeout: 90 * time.Second, // Should be longer than PutTelemetryRecords call frequency: 60 seconds
Proxy: http.ProxyURL(proxyURL),
}

// is not enabled by default as we configure TLSClientConfig for supporting SSL to data plane.
// http2.ConfigureTransport will setup transport layer to use HTTP2
http2.ConfigureTransport(transport)
h2transport, err := http2.ConfigureTransports(transport)
if err != nil {
log.Warnf("Failed to configure HTTP2 transport: %v", err)
} else {
// Adding timeout settings to the http2 transport to prevent bad tcp connection hanging the requests for too long
// See: https://t.corp.amazon.com/P104567981
// Doc: https://pkg.go.dev/golang.org/x/net/http2#Transport
// - ReadIdleTimeout is the time before a ping is sent when no frame has been received from a connection
// - PingTimeout is the time before the TCP connection being closed if a Ping response is not received
// So in total, if a TCP connection goes bad, it would take the combined time before the TCP connection is closed
h2transport.ReadIdleTimeout = 1 * time.Second
h2transport.PingTimeout = 2 * time.Second
}

http := &http.Client{
Transport: transport,
Timeout: time.Second * time.Duration(requestTimeout),
Expand Down

0 comments on commit 02e41f3

Please sign in to comment.