dial timeout
This commit is contained in:
parent
38a74fd195
commit
5b93739487
@ -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) {
|
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()
|
d.mu.RLock()
|
||||||
defer d.mu.RUnlock()
|
defer d.mu.RUnlock()
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user