From 5b93739487409f14a0145ffe3fcc22ff89ce609a Mon Sep 17 00:00:00 2001 From: Sergey Cherepanov Date: Fri, 17 Feb 2023 00:19:05 +0300 Subject: [PATCH] dial timeout --- net/dialer/dialer.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/net/dialer/dialer.go b/net/dialer/dialer.go index 98ff9ce9..7252a4f3 100644 --- a/net/dialer/dialer.go +++ b/net/dialer/dialer.go @@ -74,6 +74,9 @@ func (d *dialer) SetPeerAddrs(peerId string, addrs []string) { } func (d *dialer) Dial(ctx context.Context, peerId string) (p peer.Peer, err error) { + var ctxCancel context.CancelFunc + ctx, ctxCancel = context.WithTimeout(ctx, time.Second*10) + defer ctxCancel() d.mu.RLock() defer d.mu.RUnlock()