forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 10:52:25 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

swarm/pss: test case updated

Browse source
This commit is contained in:
Vlad 2019-03-01 19:46:36 +04:00
parent 0f4db1c632
commit 1c9450442f
1 changed files with 4 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
swarm/pss/snapshot_test.go
View file

@ -120,6 +120,7 @@ func initTestVariables(sim *simulation.Simulation, msgCount int) {
for i := 0; i < int(msgCount); i++ { for i := 0; i < int(msgCount); i++ {
msgAddr := pot.RandomAddress() // we choose message addresses randomly msgAddr := pot.RandomAddress() // we choose message addresses randomly
msgAddr[0] = byte(0x24)
msgs = append(msgs, msgAddr.Bytes()) msgs = append(msgs, msgAddr.Bytes())
smallestPo := 256 smallestPo := 256
@ -179,9 +180,9 @@ func testProxNetwork(t *testing.T) {
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
ctx, cancel := context.WithTimeout(context.Background(), time.Second*16) ctx, cancel := context.WithTimeout(context.Background(), time.Second*4)
defer cancel() defer cancel()
waitTillSerenity(t, snap, sim, 4000) waitTillSerenity(t, snap, sim, 1000)
initTestVariables(sim, msgCount) initTestVariables(sim, msgCount)
result := sim.Run(ctx, runFunc) result := sim.Run(ctx, runFunc)
if result.Error != nil { if result.Error != nil {
@ -202,6 +203,7 @@ func waitTillSerenity(t *testing.T, snap simulations.Snapshot, sim *simulation.S
time.Sleep(time.Millisecond * time.Duration(interval)) time.Sleep(time.Millisecond * time.Duration(interval))
} }
} }
time.Sleep(time.Millisecond * 10) // todo: remove this later
} }
func listSnapConnections(conns []simulations.Conn) (res []uint64) { func listSnapConnections(conns []simulations.Conn) (res []uint64) {