apple/foundationdb
1
0
Fork 0
mirror of https://github.com/apple/foundationdb.git synced 2025-05-14 18:02:31 +08:00
Code Issues Packages Projects Releases Wiki Activity

Bug fix in items processed count, changed delay/yield test to be a template.

Browse Source
This commit is contained in:
Steve Atherton 2022-10-31 12:49:38 -07:00
parent 34c61580a0
commit 70e078718c
1 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
flowbench/BenchNet2.actor.cpp
View File

@ -63,7 +63,11 @@ static void bench_net2(benchmark::State& benchState) {
BENCHMARK(bench_net2)->Range(1, 1 << 16)->ReportAggregatesOnly(true); BENCHMARK(bench_net2)->Range(1, 1 << 16)->ReportAggregatesOnly(true);
ACTOR static Future<Void> benchDelayActor(benchmark::State* benchState, bool useYield) { static constexpr bool DELAY = false;
static constexpr bool YIELD = true;
ACTOR template <bool useYield>
static Future<Void> benchDelay(benchmark::State* benchState) {
// Number of random delays to start to just to populate the run loop // Number of random delays to start to just to populate the run loop
// priority queue // priority queue
state int64_t timerCount = benchState->range(0); state int64_t timerCount = benchState->range(0);
@ -76,17 +80,14 @@ ACTOR static Future<Void> benchDelayActor(benchmark::State* benchState, bool use
while (benchState->KeepRunning()) { while (benchState->KeepRunning()) {
wait(useYield ? yield() : delay(0)); wait(useYield ? yield() : delay(0));
} }
benchState->SetItemsProcessed(static_cast<long>(benchState->iterations() + timerCount)); benchState->SetItemsProcessed(static_cast<long>(benchState->iterations()));
return Void(); return Void();
} }
template <bool useYield>
static void bench_delay(benchmark::State& benchState) { static void bench_delay(benchmark::State& benchState) {
onMainThread([&benchState] { return benchDelayActor(&benchState, false); }).blockUntilReady(); onMainThread([&benchState] { return benchDelay<useYield>(&benchState); }).blockUntilReady();
} }
static void bench_yield(benchmark::State& benchState) { BENCHMARK_TEMPLATE(bench_delay, DELAY)->Range(0, 1 << 16)->ReportAggregatesOnly(true);
onMainThread([&benchState] { return benchDelayActor(&benchState, true); }).blockUntilReady(); BENCHMARK_TEMPLATE(bench_delay, YIELD)->Range(0, 1 << 16)->ReportAggregatesOnly(true);
}
BENCHMARK(bench_delay)->Range(0, 1 << 16)->ReportAggregatesOnly(true);
BENCHMARK(bench_yield)->Range(0, 1 << 16)->ReportAggregatesOnly(true);