diff options
| author | 霍晓栋 <huoxd@jiedaibao.com> | 2016-06-26 10:50:18 +0800 |
|---|---|---|
| committer | 霍晓栋 <huoxd@jiedaibao.com> | 2016-06-26 10:50:18 +0800 |
| commit | 1f630945422953429eff852a6b6a03b9c004e9ca (patch) | |
| tree | e966a0a726f77ab52c8c25c4bba4252368abb913 /weed/command/benchmark.go | |
| parent | c601ef03b15d30e726ea86c070a2cb79035c37c9 (diff) | |
| download | seaweedfs-1f630945422953429eff852a6b6a03b9c004e9ca.tar.xz seaweedfs-1f630945422953429eff852a6b6a03b9c004e9ca.zip | |
refactor Volume Assign function
Diffstat (limited to 'weed/command/benchmark.go')
| -rw-r--r-- | weed/command/benchmark.go | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/weed/command/benchmark.go b/weed/command/benchmark.go index 7e0802e30..7bbb82319 100644 --- a/weed/command/benchmark.go +++ b/weed/command/benchmark.go @@ -205,7 +205,11 @@ func writeFiles(idChan chan int, fileIdLineChan chan string, s *stat) { start := time.Now() 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 { + ar := &operation.VolumeAssignRequest{ + Count: 1, + Collection: *b.collection, + } + if assignResult, err := operation.Assign(*b.server, ar); err == nil { fp.Server, fp.Fid, fp.Collection = assignResult.Url, assignResult.Fid, *b.collection if _, err := fp.Upload(0, *b.server, secret); err == nil { if rand.Intn(100) < *b.deletePercentage { |