From 2841d59fb031bd223e8d6aaff2ffa1b282bdb1db Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Tue, 18 Mar 2014 23:45:02 -0700 Subject: [PATCH] randomize the file size a little bit --- go/weed/benchmark.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/go/weed/benchmark.go b/go/weed/benchmark.go index 600ca781a..173900c4f 100644 --- a/go/weed/benchmark.go +++ b/go/weed/benchmark.go @@ -161,7 +161,8 @@ func writeFiles(idChan chan int, fileIdLineChan chan string, s *stats) { for { if id, ok := <-idChan; ok { start := time.Now() - fp := &operation.FilePart{Reader: &FakeReader{id: uint64(id), size: int64(*b.fileSize)}, FileSize: int64(*b.fileSize)} + fileSize := int64(*b.fileSize + rand.Intn(64)) + fp := &operation.FilePart{Reader: &FakeReader{id: uint64(id), size: fileSize}, FileSize: fileSize} if assignResult, err := operation.Assign(*b.server, 1, "", *b.collection); err == nil { fp.Server, fp.Fid, fp.Collection = assignResult.PublicUrl, assignResult.Fid, *b.collection if _, ok := serverLimitChan[fp.Server]; !ok { @@ -171,7 +172,7 @@ func writeFiles(idChan chan int, fileIdLineChan chan string, s *stats) { if _, err := fp.Upload(0, *b.server); err == nil { fileIdLineChan <- fp.Fid s.completed++ - s.transferred += int64(*b.fileSize) + s.transferred += fileSize } else { s.failed++ }