Remove bolt bench -stat.

pull/34/head
Ben Johnson 2014-04-30 11:55:08 -06:00
parent d9e7e0257b
commit 6854ca415f
2 changed files with 1 additions and 26 deletions

View File

@ -7,7 +7,6 @@ import (
"io/ioutil" "io/ioutil"
"math/rand" "math/rand"
"os" "os"
"reflect"
"runtime" "runtime"
"runtime/pprof" "runtime/pprof"
"time" "time"
@ -70,19 +69,6 @@ func Bench(options *BenchOptions) {
fmt.Printf("# Write\t%v\t(%v/op)\t(%v op/sec)\n", results.WriteDuration, results.WriteOpDuration(), results.WriteOpsPerSecond()) fmt.Printf("# Write\t%v\t(%v/op)\t(%v op/sec)\n", results.WriteDuration, results.WriteOpDuration(), results.WriteOpsPerSecond())
fmt.Printf("# Read\t%v\t(%v/op)\t(%v op/sec)\n", results.ReadDuration, results.ReadOpDuration(), results.ReadOpsPerSecond()) fmt.Printf("# Read\t%v\t(%v/op)\t(%v op/sec)\n", results.ReadDuration, results.ReadOpDuration(), results.ReadOpsPerSecond())
fmt.Println("") fmt.Println("")
if options.Stats {
fmt.Println("Transaction Stats")
printStruct(db.Stats().TxStats)
fmt.Println("")
db.View(func(tx *bolt.Tx) error {
b := tx.Bucket(benchBucketName)
fmt.Println("Storage Stats")
printStruct(b.Stats())
fmt.Println("")
return nil
})
}
} }
// Writes to the database. // Writes to the database.
@ -110,7 +96,7 @@ func benchWriteSequential(db *bolt.DB, options *BenchOptions, results *BenchResu
} }
func benchWriteRandom(db *bolt.DB, options *BenchOptions, results *BenchResults) error { func benchWriteRandom(db *bolt.DB, options *BenchOptions, results *BenchResults) error {
r := rand.New(rand.NewSource(42)) r := rand.New(rand.NewSource(time.Now().UnixNano()))
return benchWriteWithSource(db, options, results, func() uint32 { return r.Uint32() }) return benchWriteWithSource(db, options, results, func() uint32 { return r.Uint32() })
} }
@ -249,7 +235,6 @@ type BenchOptions struct {
KeySize int KeySize int
ValueSize int ValueSize int
BatchSize int BatchSize int
Stats bool
CPUProfile string CPUProfile string
MemProfile string MemProfile string
BlockProfile string BlockProfile string
@ -304,11 +289,3 @@ func tempfile() string {
os.Remove(f.Name()) os.Remove(f.Name())
return f.Name() return f.Name()
} }
func printStruct(s interface{}) {
v := reflect.ValueOf(s)
t := reflect.TypeOf(s)
for i := 0; i < v.NumField(); i++ {
fmt.Printf(" %s: %v\n", t.Field(i).Name, v.Field(i).Interface())
}
}

View File

@ -104,7 +104,6 @@ func NewApp() *cli.App {
&cli.StringFlag{Name: "cpuprofile", Usage: "CPU profile output path"}, &cli.StringFlag{Name: "cpuprofile", Usage: "CPU profile output path"},
&cli.StringFlag{Name: "memprofile", Usage: "Memory profile output path"}, &cli.StringFlag{Name: "memprofile", Usage: "Memory profile output path"},
&cli.StringFlag{Name: "blockprofile", Usage: "Block profile output path"}, &cli.StringFlag{Name: "blockprofile", Usage: "Block profile output path"},
&cli.BoolFlag{Name: "stats", Usage: "Output storage and transaction stats"},
}, },
Action: func(c *cli.Context) { Action: func(c *cli.Context) {
bs := c.Int("batch-size") bs := c.Int("batch-size")
@ -122,7 +121,6 @@ func NewApp() *cli.App {
CPUProfile: c.String("cpuprofile"), CPUProfile: c.String("cpuprofile"),
MemProfile: c.String("memprofile"), MemProfile: c.String("memprofile"),
BlockProfile: c.String("blockprofile"), BlockProfile: c.String("blockprofile"),
Stats: c.Bool("stats"),
}) })
}, },
}} }}