Function runReads

cmd/bbolt/command/command_bench.go:396–437

(cmd *cobra.Command, db *bolt.DB, options *benchOptions, results *benchResults, keys []nestedKey)

}

func runReads(cmd *cobra.Command, db *bolt.DB, options *benchOptions, results *benchResults, keys []nestedKey) error {
	// Start profiling for reads.
	if options.profileMode == "r" {
		startProfiling(cmd, options)
	}

	finishChan := make(chan interface{})
	go checkProgress(results, finishChan, cmd.ErrOrStderr())
	defer close(finishChan)

	t := time.Now()

	var err error
	switch options.readMode {
	case "seq":
		switch options.writeMode {
		case "seq-nest", "rnd-nest":
			err = runReadsSequentialNested(cmd, db, options, results)
		default:
			err = runReadsSequential(cmd, db, options, results)
		}
	case "rnd":
		switch options.writeMode {
		case "seq-nest", "rnd-nest":
			err = runReadsRandomNested(cmd, db, options, keys, results)
		default:
			err = runReadsRandom(cmd, db, options, keys, results)
		}
	default:
		return fmt.Errorf("invalid read mode: %s", options.readMode)
	}

	// Save read time.
	results.setDuration(time.Since(t))

	// Stop profiling for reads.
	if options.profileMode == "rw" || options.profileMode == "r" {
		stopProfiling(cmd)
	}

	return err
}

type nestedKey struct{ bucket, key []byte }