opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-07-04 05:16:23 +08:00
Code Issues Projects Releases Wiki Activity

use testutil peer in sess

Browse Source
This commit is contained in:
Brian Tiger Chow
2014-12-23 15:10:45 -05:00
parent a85aa9b5da
commit b551e45ae9
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
exchange/bitswap/testutils.go
View File

@ -12,6 +12,7 @@ import (
peer "github.com/jbenet/go-ipfs/peer"
datastore2 "github.com/jbenet/go-ipfs/util/datastore2"
delay "github.com/jbenet/go-ipfs/util/delay"
testutil "github.com/jbenet/go-ipfs/util/testutil"
)
func NewSessionGenerator(
@ -40,7 +41,11 @@ func (g *SessionGenerator) Close() error {
func (g *SessionGenerator) Next() Instance {
g.seq++
return session(g.ctx, g.net, peer.ID(g.seq))
p, err := testutil.RandPeer()
if err != nil {
panic("FIXME") // TODO change signature
}
return session(g.ctx, g.net, p)
}
func (g *SessionGenerator) Instances(n int) []Instance {
@ -73,9 +78,9 @@ func (i *Instance) SetBlockstoreLatency(t time.Duration) time.Duration {
// NB: It's easy make mistakes by providing the same peer ID to two different
// sessions. To safeguard, use the SessionGenerator to generate sessions. It's
// just a much better idea.
func session(ctx context.Context, net tn.Network, p peer.ID) Instance {
func session(ctx context.Context, net tn.Network, p testutil.Peer) Instance {
adapter := net.Adapter(p)
adapter := net.Adapter(p.ID())
bsdelay := delay.Fixed(0)
const kWriteCacheElems = 100
@ -87,10 +92,10 @@ func session(ctx context.Context, net tn.Network, p peer.ID) Instance {
const alwaysSendToPeer = true
bs := New(ctx, p, adapter, bstore, alwaysSendToPeer)
bs := New(ctx, p.ID(), adapter, bstore, alwaysSendToPeer)
return Instance{
Peer: p,
Peer: p.ID(),
Exchange: bs,
blockstore: bstore,
blockstoreDelay: bsdelay,