Set 10s TCP dial timeout on GorillaDialer via NetDialContext
This commit is contained in:
+5
-3
@@ -3,6 +3,7 @@ package transport
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"log/slog"
|
"log/slog"
|
||||||
|
"net"
|
||||||
"net/http"
|
"net/http"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
@@ -18,12 +19,13 @@ type GorillaDialer struct {
|
|||||||
*websocket.Dialer
|
*websocket.Dialer
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const dialTimeout = 10 * time.Second
|
||||||
|
|
||||||
func NewGorillaDialer() *GorillaDialer {
|
func NewGorillaDialer() *GorillaDialer {
|
||||||
|
netDialer := &net.Dialer{Timeout: dialTimeout}
|
||||||
return &GorillaDialer{
|
return &GorillaDialer{
|
||||||
Dialer: &websocket.Dialer{
|
Dialer: &websocket.Dialer{
|
||||||
HandshakeTimeout: 45 * time.Second,
|
NetDialContext: netDialer.DialContext,
|
||||||
ReadBufferSize: 1024,
|
|
||||||
WriteBufferSize: 1024,
|
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -27,9 +27,7 @@ func TestNewGorillaDialer(t *testing.T) {
|
|||||||
|
|
||||||
assert.NotNil(t, dialer)
|
assert.NotNil(t, dialer)
|
||||||
assert.NotNil(t, dialer.Dialer)
|
assert.NotNil(t, dialer.Dialer)
|
||||||
assert.Equal(t, 45*time.Second, dialer.Dialer.HandshakeTimeout)
|
assert.NotNil(t, dialer.Dialer.NetDialContext)
|
||||||
assert.Equal(t, 1024, dialer.Dialer.ReadBufferSize)
|
|
||||||
assert.Equal(t, 1024, dialer.Dialer.WriteBufferSize)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestAcquireSocket(t *testing.T) {
|
func TestAcquireSocket(t *testing.T) {
|
||||||
|
|||||||
Reference in New Issue
Block a user