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()