leveldb::anonymous_namespace{db_bench.cc}::Stats Class Reference

Collaboration diagram for leveldb::anonymous_namespace{db_bench.cc}::Stats:

Public Member Functions
	Stats ()
void	Start ()
void	Merge (const Stats &other)
void	Stop ()
void	AddMessage (Slice msg)
void	FinishedSingleOp ()
void	AddBytes (int64_t n)
void	Report (const Slice &name)

Private Attributes
double	start_
double	finish_
double	seconds_
int	done_
int	next_report_
int64_t	bytes_
double	last_op_finish_
Histogram	hist_
std::string	message_

Detailed Description

Definition at line 176 of file db_bench.cc.

Constructor & Destructor Documentation

Stats()

leveldb::anonymous_namespace{db_bench.cc}::Stats::Stats ( )

inline

Definition at line 189 of file db_bench.cc.

{ Start(); }

Member Function Documentation

AddBytes()

void leveldb::anonymous_namespace{db_bench.cc}::Stats::AddBytes ( int64_t  n )

inline

Definition at line 250 of file db_bench.cc.

                           {
    bytes_ += n;
  }

AddMessage()

void leveldb::anonymous_namespace{db_bench.cc}::Stats::AddMessage ( Slice  msg )

inline

Definition at line 220 of file db_bench.cc.

                             {
    AppendWithSpace(&message_, msg);
  }

Here is the call graph for this function:

FinishedSingleOp()

void leveldb::anonymous_namespace{db_bench.cc}::Stats::FinishedSingleOp ( )

inline

Definition at line 224 of file db_bench.cc.

                          {
    if (FLAGS_histogram) {
      double now = g_env->NowMicros();
      double micros = now - last_op_finish_;
      hist_.Add(micros);
      if (micros > 20000) {
        fprintf(stderr, "long op: %.1f micros%30s\r", micros, "");
        fflush(stderr);
      }
      last_op_finish_ = now;
    }

    done_++;
    if (done_ >= next_report_) {
      if      (next_report_ < 1000)   next_report_ += 100;
      else if (next_report_ < 5000)   next_report_ += 500;
      else if (next_report_ < 10000)  next_report_ += 1000;
      else if (next_report_ < 50000)  next_report_ += 5000;
      else if (next_report_ < 100000) next_report_ += 10000;
      else if (next_report_ < 500000) next_report_ += 50000;
      else                            next_report_ += 100000;
      fprintf(stderr, "... finished %d ops%30s\r", done_, "");
      fflush(stderr);
    }
  }

Here is the call graph for this function:

Merge()

void leveldb::anonymous_namespace{db_bench.cc}::Stats::Merge ( const Stats &  other )

inline

Definition at line 203 of file db_bench.cc.

                                 {
    hist_.Merge(other.hist_);
    done_ += other.done_;
    bytes_ += other.bytes_;
    seconds_ += other.seconds_;
    if (other.start_ < start_) start_ = other.start_;
    if (other.finish_ > finish_) finish_ = other.finish_;

    // Just keep the messages from one thread
    if (message_.empty()) message_ = other.message_;
  }

Here is the call graph for this function:

Report()

void leveldb::anonymous_namespace{db_bench.cc}::Stats::Report ( const Slice &  name )

inline

Definition at line 254 of file db_bench.cc.

                                 {
    // Pretend at least one op was done in case we are running a benchmark
    // that does not call FinishedSingleOp().
    if (done_ < 1) done_ = 1;

    std::string extra;
    if (bytes_ > 0) {
      // Rate is computed on actual elapsed time, not the sum of per-thread
      // elapsed times.
      double elapsed = (finish_ - start_) * 1e-6;
      char rate[100];
      snprintf(rate, sizeof(rate), "%6.1f MB/s",
               (bytes_ / 1048576.0) / elapsed);
      extra = rate;
    }
    AppendWithSpace(&extra, message_);

    fprintf(stdout, "%-12s : %11.3f micros/op;%s%s\n",
            name.ToString().c_str(),
            seconds_ * 1e6 / done_,
            (extra.empty() ? "" : " "),
            extra.c_str());
    if (FLAGS_histogram) {
      fprintf(stdout, "Microseconds per op:\n%s\n", hist_.ToString().c_str());
    }
    fflush(stdout);
  }

Here is the call graph for this function:

Start()

void leveldb::anonymous_namespace{db_bench.cc}::Stats::Start ( )

inline

Definition at line 191 of file db_bench.cc.

               {
    next_report_ = 100;
    last_op_finish_ = start_;
    hist_.Clear();
    done_ = 0;
    bytes_ = 0;
    seconds_ = 0;
    start_ = g_env->NowMicros();
    finish_ = start_;
    message_.clear();
  }

Here is the call graph for this function:

Stop()

void leveldb::anonymous_namespace{db_bench.cc}::Stats::Stop ( )

inline

Definition at line 215 of file db_bench.cc.

              {
    finish_ = g_env->NowMicros();
    seconds_ = (finish_ - start_) * 1e-6;
  }

Here is the call graph for this function:

Member Data Documentation

bytes_

int64_t leveldb::anonymous_namespace{db_bench.cc}::Stats::bytes_

private

Definition at line 183 of file db_bench.cc.

done_

int leveldb::anonymous_namespace{db_bench.cc}::Stats::done_

private

Definition at line 181 of file db_bench.cc.

finish_

double leveldb::anonymous_namespace{db_bench.cc}::Stats::finish_

private

Definition at line 179 of file db_bench.cc.

hist_

Histogram leveldb::anonymous_namespace{db_bench.cc}::Stats::hist_

private

Definition at line 185 of file db_bench.cc.

last_op_finish_

double leveldb::anonymous_namespace{db_bench.cc}::Stats::last_op_finish_

private

Definition at line 184 of file db_bench.cc.

message_

std::string leveldb::anonymous_namespace{db_bench.cc}::Stats::message_

private

Definition at line 186 of file db_bench.cc.

next_report_

int leveldb::anonymous_namespace{db_bench.cc}::Stats::next_report_

private

Definition at line 182 of file db_bench.cc.

seconds_

double leveldb::anonymous_namespace{db_bench.cc}::Stats::seconds_

private

Definition at line 180 of file db_bench.cc.

start_

double leveldb::anonymous_namespace{db_bench.cc}::Stats::start_

private

Definition at line 178 of file db_bench.cc.

---

The documentation for this class was generated from the following file:

• db/db_bench.cc