ReImplement DialTLS fix from apns2 (#509)
This commit is contained in:
parent
20a9d18ce6
commit
b35a831a41
|
@ -5,6 +5,7 @@ import (
|
||||||
"crypto/tls"
|
"crypto/tls"
|
||||||
"encoding/base64"
|
"encoding/base64"
|
||||||
"errors"
|
"errors"
|
||||||
|
"net"
|
||||||
"net/http"
|
"net/http"
|
||||||
"path/filepath"
|
"path/filepath"
|
||||||
"sync"
|
"sync"
|
||||||
|
@ -19,7 +20,23 @@ import (
|
||||||
"golang.org/x/net/http2"
|
"golang.org/x/net/http2"
|
||||||
)
|
)
|
||||||
|
|
||||||
var idleConnTimeout = 90 * time.Second
|
var (
|
||||||
|
idleConnTimeout = 90 * time.Second
|
||||||
|
tlsDialTimeout = 20 * time.Second
|
||||||
|
tcpKeepAlive = 60 * time.Second
|
||||||
|
)
|
||||||
|
|
||||||
|
// DialTLS is the default dial function for creating TLS connections for
|
||||||
|
// non-proxied HTTPS requests.
|
||||||
|
var DialTLS = func(cfg *tls.Config) func(network, addr string) (net.Conn, error) {
|
||||||
|
return func(network, addr string) (net.Conn, error) {
|
||||||
|
dialer := &net.Dialer{
|
||||||
|
Timeout: tlsDialTimeout,
|
||||||
|
KeepAlive: tcpKeepAlive,
|
||||||
|
}
|
||||||
|
return tls.DialWithDialer(dialer, network, addr, cfg)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// Sound sets the aps sound on the payload.
|
// Sound sets the aps sound on the payload.
|
||||||
type Sound struct {
|
type Sound struct {
|
||||||
|
@ -128,6 +145,7 @@ func newApnsClient(certificate tls.Certificate) (*apns2.Client, error) {
|
||||||
|
|
||||||
transport := &http.Transport{
|
transport := &http.Transport{
|
||||||
TLSClientConfig: tlsConfig,
|
TLSClientConfig: tlsConfig,
|
||||||
|
DialTLS: DialTLS(tlsConfig),
|
||||||
Proxy: http.DefaultTransport.(*http.Transport).Proxy,
|
Proxy: http.DefaultTransport.(*http.Transport).Proxy,
|
||||||
IdleConnTimeout: idleConnTimeout,
|
IdleConnTimeout: idleConnTimeout,
|
||||||
}
|
}
|
||||||
|
@ -156,6 +174,7 @@ func newApnsTokenClient(token *token.Token) (*apns2.Client, error) {
|
||||||
}
|
}
|
||||||
|
|
||||||
transport := &http.Transport{
|
transport := &http.Transport{
|
||||||
|
DialTLS: DialTLS(nil),
|
||||||
Proxy: http.DefaultTransport.(*http.Transport).Proxy,
|
Proxy: http.DefaultTransport.(*http.Transport).Proxy,
|
||||||
IdleConnTimeout: idleConnTimeout,
|
IdleConnTimeout: idleConnTimeout,
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue