mirror/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2024-12-18 12:47:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

randomize benchmark content

Browse Source 
fix https://github.com/chrislusf/seaweedfs/issues/1294
This commit is contained in:
Chris Lu 2020-04-28 01:50:56 -07:00
parent fb81f12686
commit eab4c9219c
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
weed/command/benchmark.go
View File

@ -227,7 +227,7 @@ func writeFiles(idChan chan int, fileIdLineChan chan string, s *stat) {
start := time.Now() start := time.Now()
fileSize := int64(*b.fileSize + random.Intn(64)) fileSize := int64(*b.fileSize + random.Intn(64))
fp := &operation.FilePart{ fp := &operation.FilePart{
Reader: &FakeReader{id: uint64(id), size: fileSize}, Reader: &FakeReader{id: uint64(id), size: fileSize, random: random},
FileSize: fileSize, FileSize: fileSize,
MimeType: "image/bench", // prevent gzip benchmark content MimeType: "image/bench", // prevent gzip benchmark content
} }
@ -550,8 +550,9 @@ func (s *stats) printStats() {
// a fake reader to generate content to upload // a fake reader to generate content to upload
type FakeReader struct { type FakeReader struct {
id uint64 // an id number id uint64 // an id number
size int64 // max bytes size int64 // max bytes
random *rand.Rand
} }
func (l *FakeReader) Read(p []byte) (n int, err error) { func (l *FakeReader) Read(p []byte) (n int, err error) {
@ -567,6 +568,7 @@ func (l *FakeReader) Read(p []byte) (n int, err error) {
for i := 0; i < 8; i++ { for i := 0; i < 8; i++ {
p[i] = byte(l.id >> uint(i*8)) p[i] = byte(l.id >> uint(i*8))
} }
l.random.Read(p[8:])
} }
l.size -= int64(n) l.size -= int64(n)
return return