提交 237e594a 作者: Brian Tiger Chow

don't link when creating network client. rely on caller

上级 075841c1
...@@ -95,7 +95,8 @@ func AddCatBytes(data []byte, conf Config) error { ...@@ -95,7 +95,8 @@ func AddCatBytes(data []byte, conf Config) error {
// defer mn.Close() FIXME does mocknet require clean-up // defer mn.Close() FIXME does mocknet require clean-up
mn.SetLinkDefaults(mocknet.LinkOptions{ mn.SetLinkDefaults(mocknet.LinkOptions{
Latency: conf.NetworkLatency, Latency: conf.NetworkLatency,
Bandwidth: math.MaxInt32, // TODO add to conf // TODO add to conf. This is tricky because we want 0 values to be functional.
Bandwidth: math.MaxInt32,
}) })
dhtNetwork := mockrouting.NewDHTNetwork(mn) dhtNetwork := mockrouting.NewDHTNetwork(mn)
net, err := tn.StreamNet(ctx, mn, dhtNetwork) net, err := tn.StreamNet(ctx, mn, dhtNetwork)
......
...@@ -20,14 +20,10 @@ func StreamNet(ctx context.Context, net mockpeernet.Mocknet, rs mockrouting.Serv ...@@ -20,14 +20,10 @@ func StreamNet(ctx context.Context, net mockpeernet.Mocknet, rs mockrouting.Serv
} }
func (pn *peernet) Adapter(p testutil.Peer) bsnet.BitSwapNetwork { func (pn *peernet) Adapter(p testutil.Peer) bsnet.BitSwapNetwork {
peers := pn.Mocknet.Peers()
client, err := pn.Mocknet.AddPeer(p.PrivateKey(), p.Address()) client, err := pn.Mocknet.AddPeer(p.PrivateKey(), p.Address())
if err != nil { if err != nil {
panic(err.Error()) panic(err.Error())
} }
for _, other := range peers {
pn.Mocknet.LinkPeers(p.ID(), other)
}
routing := pn.routingserver.ClientWithDatastore(context.TODO(), p, ds.NewMapDatastore()) routing := pn.routingserver.ClientWithDatastore(context.TODO(), p, ds.NewMapDatastore())
return bsnet.NewFromIpfsNetwork(client, routing) return bsnet.NewFromIpfsNetwork(client, routing)
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论