aboutsummaryrefslogtreecommitdiff
path: root/go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2014-03-18 23:45:02 -0700
committerChris Lu <chris.lu@gmail.com>2014-03-18 23:45:02 -0700
commit2841d59fb031bd223e8d6aaff2ffa1b282bdb1db (patch)
tree749c85b850c07765082bf49d5af1cf0978f871e1 /go
parent3fec41b9115dc10bc9624c634826b5973aab6c63 (diff)
downloadseaweedfs-2841d59fb031bd223e8d6aaff2ffa1b282bdb1db.tar.xz
seaweedfs-2841d59fb031bd223e8d6aaff2ffa1b282bdb1db.zip
randomize the file size a little bit
Diffstat (limited to 'go')
-rw-r--r--go/weed/benchmark.go5
1 files 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++
}