denshooter/genode
1
0
Fork 0
mirror of https://github.com/mmueller41/genode.git synced 2026-01-21 12:32:56 +01:00
Code Issues Packages Projects Releases Wiki Activity

blinktree: Removed stdc++ I/O functions because they cannot be called from within a worker thread.

Browse Source
This commit is contained in:
Michael Mueller
2022-08-10 16:29:54 +02:00
parent a8f6fc42cc
commit 84a79c2168
1 changed files with 9 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
repos/mml/src/app/blinktree/blinktree_benchmark/benchmark.cpp
View File

@@ -1,9 +1,11 @@
#include "benchmark.h"
#include <cstdlib>
#include <iostream>
#include <sstream>
#include <json.hpp>
#include <memory>
#include <mx/memory/global_heap.h>
#include <base/log.h>
using namespace application::blinktree_benchmark;
@@ -71,10 +73,8 @@ void Benchmark::start()
{
mx::tasking::runtime::profile(this->profile_file_name());
}
#ifdef PERF_SUPPORT
this->_chronometer.start(static_cast<std::uint16_t>(static_cast<benchmark::phase>(this->_workload)),
this->_current_iteration + 1, this->_cores.current());
#endif
}
const mx::util::core_set &Benchmark::core_set()
@@ -113,15 +113,15 @@ void Benchmark::requests_finished()
if (open_requests == 0U) // All request schedulers are done.
{
// Stop and print time (and performance counter).
//const auto result = this->_chronometer.stop(this->_workload.size());
const auto result = this->_chronometer.stop(this->_workload.size());
mx::tasking::runtime::stop();
//std::cout << result << std::endl;
Genode::log(result.core_count(), "\t", result.iteration(), "\t", result.phase(), "\t", result.time().count(), " ms\t", result.throughput(), " op/s");
// Dump results to file.
if (this->_result_file_name.empty() == false)
/*if (this->_result_file_name.empty() == false)
{
std::ofstream result_file_stream(this->_result_file_name, std::ofstream::app);
//result_file_stream << result.to_json().dump() << std::endl;
result_file_stream << result.to_json().dump() << std::endl;
}
// Dump statistics to file.
@@ -131,11 +131,9 @@ void Benchmark::requests_finished()
{
std::ofstream statistic_file_stream(this->_statistic_file_name, std::ofstream::app);
nlohmann::json statistic_json;
#ifdef PERF_SUPPORT
statistic_json["iteration"] = result.iteration();
statistic_json["cores"] = result.core_count();
statistic_json["phase"] = result.phase();
#endif
statistic_json["scheduled"] = nlohmann::json();
statistic_json["scheduled-on-channel"] = nlohmann::json();
statistic_json["scheduled-off-channel"] = nlohmann::json();
@@ -147,7 +145,6 @@ void Benchmark::requests_finished()
{
const auto core_id = std::int32_t{this->_cores.current()[i]};
const auto core_id_string = std::to_string(core_id);
#ifdef PERF_SUPPORT
statistic_json["scheduled"][core_id_string] =
result.scheduled_tasks(core_id) / double(result.operation_count());
statistic_json["scheduled-on-core"][core_id_string] =
@@ -162,12 +159,11 @@ void Benchmark::requests_finished()
result.executed_writer_tasks(core_id) / double(result.operation_count());
statistic_json["fill"][core_id_string] =
result.worker_fills(core_id) / double(result.operation_count());
#endif
}
statistic_file_stream << statistic_json.dump(2) << std::endl;
}
}
}*/
// Check and print the tree.
if (this->_check_tree)
@@ -184,11 +180,11 @@ void Benchmark::requests_finished()
this->_workload == benchmark::phase::MIXED || this->_workload.empty(benchmark::phase::MIXED);
// Dump the tree.
if (this->_tree_file_name.empty() == false && is_last_phase)
/*if (this->_tree_file_name.empty() == false && is_last_phase)
{
std::ofstream tree_file_stream(this->_tree_file_name);
tree_file_stream << static_cast<nlohmann::json>(*(this->_tree)).dump() << std::endl;
}
}*/
// Delete the tree to free the hole memory.
if (is_last_phase)