status-im
/
go-libp2p-pubsub
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

increase travis friendliness for new tests

This commit is contained in:
vyzo 2020-04-23 16:48:54 +03:00
parent 741b7e9b41
commit 8d89949131
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
floodsub_test.go
View File

@ -1057,7 +1057,7 @@ func TestPubsubWithAssortedOptions(t *testing.T) {
hosts := getNetHosts(t, ctx, 2)
psubs := getPubsubs(ctx, hosts,
WithMessageIdFn(hashMsgID),
WithPeerOutboundQueueSize(1),
WithPeerOutboundQueueSize(10),
WithMessageAuthor(""),
WithBlacklist(NewMapBlacklist()))
@ -1072,7 +1072,7 @@ func TestPubsubWithAssortedOptions(t *testing.T) {
subs = append(subs, sub)
}
time.Sleep(100 * time.Millisecond)
time.Sleep(time.Second)
for i := 0; i < 2; i++ {
msg := []byte(fmt.Sprintf("message %d", i))

10
validation_test.go
View File

@ -214,9 +214,9 @@ func TestValidateAssortedOptions(t *testing.T) {
hosts := getNetHosts(t, ctx, 10)
psubs := getPubsubs(ctx, hosts,
WithValidateQueueSize(1),
WithValidateThrottle(1),
WithValidateWorkers(1))
WithValidateQueueSize(10),
WithValidateThrottle(10),
WithValidateWorkers(10))
sparseConnect(t, hosts)
@ -255,7 +255,7 @@ func TestValidateAssortedOptions(t *testing.T) {
subs2 = append(subs2, sub)
}
time.Sleep(100 * time.Millisecond)
time.Sleep(time.Second)
for i := 0; i < 10; i++ {
msg := []byte(fmt.Sprintf("message %d", i))
@ -328,7 +328,7 @@ func TestValidateMultitopic(t *testing.T) {
subs3 = append(subs2, sub)
}
time.Sleep(100 * time.Millisecond)
time.Sleep(time.Second)
msg1 := "i am a walrus"