gaspersic/go-ethereum
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

cmd/swarm-smoke: fix what we wanted to avoid (#1486)

Browse Source
This commit is contained in:
acud
2019-06-14 14:49:21 +02:00
committed by Anton Evangelatov
parent fce3e45f2b
commit 8b37def961
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
cmd/swarm-smoke/upload_and_sync.go
View File

@ -39,8 +39,6 @@ import (
cli "gopkg.in/urfave/cli.v1" cli "gopkg.in/urfave/cli.v1"
) )
const trackChunksPageSize = 7500
func uploadAndSyncCmd(ctx *cli.Context) error { func uploadAndSyncCmd(ctx *cli.Context) error {
// use input seed if it has been set // use input seed if it has been set
if inputSeed != 0 { if inputSeed != 0 {
@ -180,13 +178,14 @@ func trackChunks(testData []byte, submitMetrics bool) error {
// getChunksBitVectorFromHost returns a bit vector of presence for a given slice of chunks from a given host // getChunksBitVectorFromHost returns a bit vector of presence for a given slice of chunks from a given host
func getChunksBitVectorFromHost(client *rpc.Client, addrs []storage.Address) (string, error) { func getChunksBitVectorFromHost(client *rpc.Client, addrs []storage.Address) (string, error) {
var hostChunks string var hostChunks string
const trackChunksPageSize = 7500
for len(addrs) > 0 { for len(addrs) > 0 {
var pageChunks string var pageChunks string
// get current page size, so that we avoid a slice out of bounds on the last page // get current page size, so that we avoid a slice out of bounds on the last page
pagesize := trackChunksPageSize pagesize := trackChunksPageSize
if cap(addrs) < trackChunksPageSize { if len(addrs) < trackChunksPageSize {
pagesize = cap(addrs) pagesize = len(addrs)
} }
err := client.Call(&pageChunks, "bzz_has", addrs[:pagesize]) err := client.Call(&pageChunks, "bzz_has", addrs[:pagesize])