提交 193004a0 作者: Brian Tiger Chow

refac(bs/test) provide a shared net delay constant

License: MIT
Signed-off-by: 's avatarBrian Tiger Chow <brian@perfmode.com>
上级 3c44ad1f
...@@ -15,10 +15,12 @@ import ( ...@@ -15,10 +15,12 @@ import (
testutil "github.com/jbenet/go-ipfs/util/testutil" testutil "github.com/jbenet/go-ipfs/util/testutil"
) )
const kNetworkDelay = 0 * time.Millisecond
func TestClose(t *testing.T) { func TestClose(t *testing.T) {
// TODO // TODO
t.Skip("TODO Bitswap's Close implementation is a WIP") t.Skip("TODO Bitswap's Close implementation is a WIP")
vnet := tn.VirtualNetwork(delay.Fixed(0)) vnet := tn.VirtualNetwork(delay.Fixed(kNetworkDelay))
rout := mock.VirtualRoutingServer() rout := mock.VirtualRoutingServer()
sesgen := NewSessionGenerator(vnet, rout) sesgen := NewSessionGenerator(vnet, rout)
bgen := blocksutil.NewBlockGenerator() bgen := blocksutil.NewBlockGenerator()
...@@ -32,7 +34,7 @@ func TestClose(t *testing.T) { ...@@ -32,7 +34,7 @@ func TestClose(t *testing.T) {
func TestGetBlockTimeout(t *testing.T) { func TestGetBlockTimeout(t *testing.T) {
net := tn.VirtualNetwork(delay.Fixed(0)) net := tn.VirtualNetwork(delay.Fixed(kNetworkDelay))
rs := mock.VirtualRoutingServer() rs := mock.VirtualRoutingServer()
g := NewSessionGenerator(net, rs) g := NewSessionGenerator(net, rs)
...@@ -49,7 +51,7 @@ func TestGetBlockTimeout(t *testing.T) { ...@@ -49,7 +51,7 @@ func TestGetBlockTimeout(t *testing.T) {
func TestProviderForKeyButNetworkCannotFind(t *testing.T) { func TestProviderForKeyButNetworkCannotFind(t *testing.T) {
net := tn.VirtualNetwork(delay.Fixed(0)) net := tn.VirtualNetwork(delay.Fixed(kNetworkDelay))
rs := mock.VirtualRoutingServer() rs := mock.VirtualRoutingServer()
g := NewSessionGenerator(net, rs) g := NewSessionGenerator(net, rs)
...@@ -70,7 +72,7 @@ func TestProviderForKeyButNetworkCannotFind(t *testing.T) { ...@@ -70,7 +72,7 @@ func TestProviderForKeyButNetworkCannotFind(t *testing.T) {
func TestGetBlockFromPeerAfterPeerAnnounces(t *testing.T) { func TestGetBlockFromPeerAfterPeerAnnounces(t *testing.T) {
net := tn.VirtualNetwork(delay.Fixed(0)) net := tn.VirtualNetwork(delay.Fixed(kNetworkDelay))
rs := mock.VirtualRoutingServer() rs := mock.VirtualRoutingServer()
block := blocks.NewBlock([]byte("block")) block := blocks.NewBlock([]byte("block"))
g := NewSessionGenerator(net, rs) g := NewSessionGenerator(net, rs)
...@@ -122,7 +124,7 @@ func PerformDistributionTest(t *testing.T, numInstances, numBlocks int) { ...@@ -122,7 +124,7 @@ func PerformDistributionTest(t *testing.T, numInstances, numBlocks int) {
if testing.Short() { if testing.Short() {
t.SkipNow() t.SkipNow()
} }
net := tn.VirtualNetwork(delay.Fixed(0)) net := tn.VirtualNetwork(delay.Fixed(kNetworkDelay))
rs := mock.VirtualRoutingServer() rs := mock.VirtualRoutingServer()
sg := NewSessionGenerator(net, rs) sg := NewSessionGenerator(net, rs)
bg := blocksutil.NewBlockGenerator() bg := blocksutil.NewBlockGenerator()
...@@ -182,7 +184,7 @@ func TestSendToWantingPeer(t *testing.T) { ...@@ -182,7 +184,7 @@ func TestSendToWantingPeer(t *testing.T) {
t.SkipNow() t.SkipNow()
} }
net := tn.VirtualNetwork(delay.Fixed(0)) net := tn.VirtualNetwork(delay.Fixed(kNetworkDelay))
rs := mock.VirtualRoutingServer() rs := mock.VirtualRoutingServer()
sg := NewSessionGenerator(net, rs) sg := NewSessionGenerator(net, rs)
bg := blocksutil.NewBlockGenerator() bg := blocksutil.NewBlockGenerator()
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论