Lines Matching refs:entries_per_batch_

2300   int64_t entries_per_batch_;  member in ROCKSDB_NAMESPACE::Benchmark
2650 entries_per_batch_(1), in Benchmark()
2871 entries_per_batch_ = FLAGS_batch_size; in Run()
2947 entries_per_batch_ = 1000; in Run()
2992 entries_per_batch_); in Run()
2999 entries_per_batch_); in Run()
4392 while (!duration.Done(entries_per_batch_)) { in DoWrite()
4409 for (int64_t j = 0; j < entries_per_batch_; j++) { in DoWrite()
4494 entries_per_batch_, kWrite); in DoWrite()
5052 if (entries_per_batch_ > 1 && FLAGS_multiread_stride) { in ReadRandom()
5053 if (++num_keys == entries_per_batch_) { in ReadRandom()
5056 if ((key_rand + (entries_per_batch_ - 1) * FLAGS_multiread_stride) >= in ReadRandom()
5058 key_rand = FLAGS_num - entries_per_batch_ * FLAGS_multiread_stride; in ReadRandom()
5116 std::vector<std::string> values(entries_per_batch_); in MultiReadRandom()
5117 PinnableSlice* pin_values = new PinnableSlice[entries_per_batch_]; in MultiReadRandom()
5119 std::vector<Status> stat_list(entries_per_batch_); in MultiReadRandom()
5120 while (static_cast<int64_t>(keys.size()) < entries_per_batch_) { in MultiReadRandom()
5130 if ((key + (entries_per_batch_ - 1) * FLAGS_multiread_stride) >= in MultiReadRandom()
5132 key = FLAGS_num - entries_per_batch_ * FLAGS_multiread_stride; in MultiReadRandom()
5134 for (int64_t i = 0; i < entries_per_batch_; ++i) { in MultiReadRandom()
5139 for (int64_t i = 0; i < entries_per_batch_; ++i) { in MultiReadRandom()
5145 assert(static_cast<int64_t>(statuses.size()) == entries_per_batch_); in MultiReadRandom()
5147 read += entries_per_batch_; in MultiReadRandom()
5149 for (int64_t i = 0; i < entries_per_batch_; ++i) { in MultiReadRandom()
5162 read += entries_per_batch_; in MultiReadRandom()
5164 for (int64_t i = 0; i < entries_per_batch_; ++i) { in MultiReadRandom()
5179 256 * entries_per_batch_, Env::IO_HIGH, nullptr /* stats */, in MultiReadRandom()
5182 thread->stats.FinishedOps(nullptr, db, entries_per_batch_, kRead); in MultiReadRandom()
5766 while (!duration.Done(entries_per_batch_)) { in DoDelete()
5769 for (int64_t j = 0; j < entries_per_batch_; ++j) { in DoDelete()
5775 thread->stats.FinishedOps(nullptr, db, entries_per_batch_, kDelete); in DoDelete()
5780 i += entries_per_batch_; in DoDelete()