From 89519abbfe1834bd4e813f3831bb2ed6fe91de86 Mon Sep 17 00:00:00 2001 From: Andrei Gavrilov Date: Wed, 10 Dec 2025 11:55:52 +0300 Subject: [PATCH 1/2] add timeout for streamer connect (for working multiadress setup) --- pkg/streamer/streamer.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pkg/streamer/streamer.go b/pkg/streamer/streamer.go index 145820e..533088a 100644 --- a/pkg/streamer/streamer.go +++ b/pkg/streamer/streamer.go @@ -139,6 +139,8 @@ func NewReadResImpl(before, after []byte, matchedGroups map[string][]byte, match // TCPDialCtx net.Dial version with context arg func TCPDialCtx(ctx context.Context, network, addr string) (net.Conn, error) { d := net.Dialer{} + ctx, cancel := context.WithTimeout(ctx, time.Second*5) + defer cancel() conn, err := d.DialContext(ctx, network, addr) if err != nil { return nil, err From 54278c2aff2684aad9ee7ca0f7dac9886b9db527 Mon Sep 17 00:00:00 2001 From: Andrei Gavrilov Date: Wed, 10 Dec 2025 11:57:01 +0300 Subject: [PATCH 2/2] add default timeout for connect --- pkg/streamer/streamer.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/streamer/streamer.go b/pkg/streamer/streamer.go index 533088a..7123b15 100644 --- a/pkg/streamer/streamer.go +++ b/pkg/streamer/streamer.go @@ -139,7 +139,7 @@ func NewReadResImpl(before, after []byte, matchedGroups map[string][]byte, match // TCPDialCtx net.Dial version with context arg func TCPDialCtx(ctx context.Context, network, addr string) (net.Conn, error) { d := net.Dialer{} - ctx, cancel := context.WithTimeout(ctx, time.Second*5) + ctx, cancel := context.WithTimeout(ctx, 5*time.Second) defer cancel() conn, err := d.DialContext(ctx, network, addr) if err != nil {