Searched refs:done_ (Results 1 – 4 of 4) sorted by relevance
| /rocksdb-6.9/db_stress_tool/ |
| D | db_stress_stat.h | 33 long done_; variable
58 done_ = 0; in Start()
81 done_ += other.done_; in Merge()
117 done_++; in FinishedSingleOp()
119 if (done_ >= next_report_) { in FinishedSingleOp()
134 fprintf(stdout, "... finished %ld ops%30s\r", done_, ""); in FinishedSingleOp()
172 if (bytes_ < 1 || done_ < 1) { in Report()
180 double throughput = (double)done_ / elapsed; in Report()
183 fprintf(stdout, "%.3f micros/op %ld ops/sec\n", seconds_ * 1e6 / done_, in Report()
186 "", bytes_mb, rate, (100 * writes_) / done_, done_); in Report()
|
| /rocksdb-6.9/db/ |
| D | forward_iterator_bench.cc | 101 if (done_.load()) { in run()
186 done_.store(true); in ~Reader()
200 std::atomic<bool> done_{false}; member
278 while (!done_.load()) { in run()
306 done_.store(true); in ~StatsThread()
317 std::atomic<bool> done_{false}; member
|
| /rocksdb-6.9/java/benchmark/src/main/java/org/rocksdb/benchmark/ |
| D | DbBenchmark.java | 55 long done_; field in Stats
70 done_ = 0; in Stats()
86 done_ += other.done_; in merge()
115 done_++; in finishedSingleOp()
118 if (done_ >= nextReport_) { in finishedSingleOp()
134 System.err.printf("... Task %s finished %d ops%30s\r", id_, done_, ""); in finishedSingleOp()
141 if (done_ < 1) done_ = 1; in report()
152 double throughput = (double) done_ / (elapsed * 1e-9); in report()
155 name, (elapsed * 1e-6) / done_, in report()
806 extra = String.format(" %d ops done; ", stats.done_); in stop()
[all …]
|
| /rocksdb-6.9/tools/ |
| D | db_bench_tool.cc | 1847 uint64_t done_; member in ROCKSDB_NAMESPACE::Stats
1872 done_ = 0; in Start()
1898 done_ += other.done_; in Merge()
1990 done_ += num_ops; in FinishedOps()
1991 if (done_ >= next_report_) { in FinishedOps()
2020 done_ - last_report_done_, done_, in FinishedOps()
2071 last_report_done_ = done_; in FinishedOps()
2088 if (done_ < 1) done_ = 1; in Report()
2102 double throughput = (double)done_/elapsed; in Report()
2106 seconds_ * 1e6 / done_, in Report()
[all …]
|