Skip to content

M
mybee
Commit f3880753 authored by acud's avatar acud Committed by GitHub
Browse files
Options

kademlia: add timeout to connect (#332) 

* add timeout to connect
parent c3efa490
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 0 deletions
pkg/kademlia/kademlia.go
View file @ f3880753
...@@ -251,6 +251,8 @@ func (k *Kad) recalcDepth() uint8 { ...@@ -251,6 +251,8 @@ func (k *Kad) recalcDepth() uint8 {
// connect connects to a peer and gossips its address to our connected peers, // connect connects to a peer and gossips its address to our connected peers,
// as well as sends the peers we are connected to to the newly connected peer // as well as sends the peers we are connected to to the newly connected peer
func (k *Kad) connect(ctx context.Context, peer swarm.Address, ma ma.Multiaddr, po uint8) error { func (k *Kad) connect(ctx context.Context, peer swarm.Address, ma ma.Multiaddr, po uint8) error {
ctx, cancel := context.WithTimeout(ctx, 5*time.Second)
defer cancel()
_, err := k.p2p.Connect(ctx, ma) _, err := k.p2p.Connect(ctx, ma)
if err != nil { if err != nil {
if errors.Is(err, p2p.ErrAlreadyConnected) { if errors.Is(err, p2p.ErrAlreadyConnected) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment