From 8d29a3255ff3f39f96f25585a93792998fb4f9f3 Mon Sep 17 00:00:00 2001
From: Juan Batiz-Benet <juan@benet.ai>
Date: Sun, 21 Sep 2014 19:17:32 -0700
Subject: [PATCH] core bugfix -- connect ctx
---
core/core.go | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/core/core.go b/core/core.go
index 8fc36a57..bed95aae 100644
--- a/core/core.go
+++ b/core/core.go
@@ -121,7 +121,7 @@ func NewIpfsNode(cfg *config.Config, online bool) (*IpfsNode, error) {
exchangeSession = bitswap.NetMessageSession(ctx, exchangeService, local, d, route)
// TODO(brian): pass a context to initConnections
- go initConnections(cfg, peerstore, route)
+ go initConnections(ctx, cfg, peerstore, route)
}
// TODO(brian): when offline instantiate the BlockService with a bitswap
@@ -184,7 +184,7 @@ func initIdentity(cfg *config.Config) (*peer.Peer, error) {
}, nil
}
-func initConnections(cfg *config.Config, pstore peer.Peerstore, route *dht.IpfsDHT) {
+func initConnections(ctx context.Context, cfg *config.Config, pstore peer.Peerstore, route *dht.IpfsDHT) {
for _, p := range cfg.Peers {
if p.PeerID == "" {
u.PErr("error: peer does not include PeerID. %v\n", p)
@@ -205,7 +205,7 @@ func initConnections(cfg *config.Config, pstore peer.Peerstore, route *dht.IpfsD
continue
}
- if _, err = route.Connect(npeer); err != nil {
+ if _, err = route.Connect(ctx, npeer); err != nil {
u.PErr("Bootstrapping error: %v\n", err)
}
}
--
GitLab