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

swarm/storage/localstore: fix TestSubscribePull to include MaxPO

Browse source
This commit is contained in:
Janos Guljas 2018-12-22 01:04:43 +01:00
parent 95726d73d6
commit c5dcae33e0
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
swarm/storage/localstore/subscriptions_test.go
View file

@ -249,7 +249,7 @@ func TestSubscribePull(t *testing.T) {
// to validate the number of addresses received by the subscription // to validate the number of addresses received by the subscription
errChan := make(chan error) errChan := make(chan error)
for bin := uint8(0); bin < uint8(storage.MaxPO); bin++ { for bin := uint8(0); bin <= uint8(storage.MaxPO); bin++ {
sub, err := db.SubscribePull(ctx, bin) sub, err := db.SubscribePull(ctx, bin)
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
@ -348,7 +348,7 @@ func TestSubscribePull_multiple(t *testing.T) {
// start a number of subscriptions // start a number of subscriptions
// that all of them will write every address error to errChan // that all of them will write every address error to errChan
for j := 0; j < subsCount; j++ { for j := 0; j < subsCount; j++ {
for bin := uint8(0); bin < uint8(storage.MaxPO); bin++ { for bin := uint8(0); bin <= uint8(storage.MaxPO); bin++ {
sub, err := db.SubscribePull(ctx, bin) sub, err := db.SubscribePull(ctx, bin)
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)