aboutsummaryrefslogtreecommitdiff
path: root/weed/command/benchmark.go
diff options
context:
space:
mode:
authorbingoohuang <bingoo.huang@gmail.com>2019-01-17 09:17:19 +0800
committerbingoohuang <bingoo.huang@gmail.com>2019-01-17 09:17:19 +0800
commitab6be025d76748388ad3eea6fe6ca000db1c2435 (patch)
tree1be9b1b5e7f91693f4cabe3ae0d114cb7f7dced6 /weed/command/benchmark.go
parent6ddfaf33cba953b92a5e3383a15bf26ab1845dbc (diff)
downloadseaweedfs-ab6be025d76748388ad3eea6fe6ca000db1c2435.tar.xz
seaweedfs-ab6be025d76748388ad3eea6fe6ca000db1c2435.zip
go fmt and fix some typo
Diffstat (limited to 'weed/command/benchmark.go')
-rw-r--r--weed/command/benchmark.go12
1 files changed, 6 insertions, 6 deletions
diff --git a/weed/command/benchmark.go b/weed/command/benchmark.go
index d0a1a587a..60fd88ccd 100644
--- a/weed/command/benchmark.go
+++ b/weed/command/benchmark.go
@@ -45,7 +45,7 @@ var (
)
func init() {
- cmdBenchmark.Run = runbenchmark // break init cycle
+ cmdBenchmark.Run = runBenchmark // break init cycle
cmdBenchmark.IsDebug = cmdBenchmark.Flag.Bool("debug", false, "verbose debug information")
b.masters = cmdBenchmark.Flag.String("master", "localhost:9333", "SeaweedFS master location")
b.concurrency = cmdBenchmark.Flag.Int("c", 16, "number of concurrent write or read processes")
@@ -101,7 +101,7 @@ var (
readStats *stats
)
-func runbenchmark(cmd *Command, args []string) bool {
+func runBenchmark(cmd *Command, args []string) bool {
fmt.Printf("This is SeaweedFS version %s %s %s\n", util.VERSION, runtime.GOOS, runtime.GOARCH)
if *b.maxCpu < 1 {
*b.maxCpu = runtime.NumCPU()
@@ -121,17 +121,17 @@ func runbenchmark(cmd *Command, args []string) bool {
masterClient.WaitUntilConnected()
if *b.write {
- bench_write()
+ benchWrite()
}
if *b.read {
- bench_read()
+ benchRead()
}
return true
}
-func bench_write() {
+func benchWrite() {
fileIdLineChan := make(chan string)
finishChan := make(chan bool)
writeStats = newStats(*b.concurrency)
@@ -158,7 +158,7 @@ func bench_write() {
writeStats.printStats()
}
-func bench_read() {
+func benchRead() {
fileIdLineChan := make(chan string)
finishChan := make(chan bool)
readStats = newStats(*b.concurrency)