tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Print and save response latencies

Browse Source
This commit is contained in:
János Benjamin Antal 2023-03-02 11:22:36 +01:00
parent 53cd5592e0
commit ab52d325e0
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/manual/query_performance.cpp
View File

@ -74,6 +74,7 @@
#include <istream> #include <istream>
#include <thread> #include <thread>
#include <fmt/core.h>
#include <gflags/gflags.h> #include <gflags/gflags.h>
#include <spdlog/cfg/env.h> #include <spdlog/cfg/env.h>
#include <spdlog/spdlog.h> #include <spdlog/spdlog.h>
@ -320,6 +321,8 @@ void RunV3() {
std::chrono::duration_cast<std::chrono::milliseconds>(benchmark_end - benchmark_start).count()); std::chrono::duration_cast<std::chrono::milliseconds>(benchmark_end - benchmark_start).count());
ls.ShutDown(); ls.ShutDown();
auto latency_histograms = nlohmann::json::parse(fmt::format("{}", io.ResponseLatencies()));
spdlog::warn(latency_histograms.dump(4));
if (!FLAGS_export_json_results.empty()) { if (!FLAGS_export_json_results.empty()) {
nlohmann::json results; nlohmann::json results;
@ -329,6 +332,7 @@ void RunV3() {
PutResult(benchmark_results_json, name, duration); PutResult(benchmark_results_json, name, duration);
} }
results["benchmarks"] = std::move(benchmark_results_json); results["benchmarks"] = std::move(benchmark_results_json);
results["latencies"] = std::move(latency_histograms);
std::ofstream results_file{FLAGS_export_json_results}; std::ofstream results_file{FLAGS_export_json_results};
results_file << results.dump(); results_file << results.dump();
} }