Skip to content
Snippets Groups Projects
Commit fc255f06 authored by Marcel Krüger's avatar Marcel Krüger
Browse files

refactor(nest-module): clean up logging

parent 344101f4
No related branches found
No related tags found
No related merge requests found
...@@ -101,7 +101,7 @@ HttpServer::HttpServer(std::string address, DataStorage* storage) ...@@ -101,7 +101,7 @@ HttpServer::HttpServer(std::string address, DataStorage* storage)
crow_server = app.port(18080 + nest::kernel().mpi_manager.get_rank()).multithreaded().run_async(); crow_server = app.port(18080 + nest::kernel().mpi_manager.get_rank()).multithreaded().run_async();
app.wait_for_server_start(); app.wait_for_server_start();
spdlog::info("[insite] http server is listening..."); SPDLOG_INFO("[insite] http server is listening...");
} }
void HttpServer::ClearSimulationHasEnded() { void HttpServer::ClearSimulationHasEnded() {
...@@ -248,7 +248,6 @@ crow::response HttpServer::GetSpikeRecordersV2( ...@@ -248,7 +248,6 @@ crow::response HttpServer::GetSpikeRecordersV2(
} }
crow::response HttpServer::GetSpikesFB(const crow::request& request) { crow::response HttpServer::GetSpikesFB(const crow::request& request) {
spdlog::stopwatch spikes_fb;
std::unordered_map<std::string, std::string> parameters; std::unordered_map<std::string, std::string> parameters;
const auto from_time_parameter = parameters.find("fromTime"); const auto from_time_parameter = parameters.find("fromTime");
...@@ -316,12 +315,9 @@ crow::response HttpServer::GetSpikesFB(const crow::request& request) { ...@@ -316,12 +315,9 @@ crow::response HttpServer::GetSpikesFB(const crow::request& request) {
} }
bool last_frame = simulation_end_time_ != -1 && (to_time >= simulation_end_time_); bool last_frame = simulation_end_time_ != -1 && (to_time >= simulation_end_time_);
spdlog::stopwatch fb_building;
flatbuffers::FlatBufferBuilder fbb(40000000 * 16); flatbuffers::FlatBufferBuilder fbb(40000000 * 16);
auto fb_spikes = fbb.CreateVectorOfNativeStructs<Test::Foo::Spikes>(spikes, flatbuffers::Pack); auto fb_spikes = fbb.CreateVectorOfNativeStructs<Test::Foo::Spikes>(spikes, flatbuffers::Pack);
auto fb_spike_table = Test::Foo::CreateSpikyTable(fbb, fb_spikes); auto fb_spike_table = Test::Foo::CreateSpikyTable(fbb, fb_spikes);
spdlog::info("Fb building: {}", fb_building.elapsed());
spdlog::info("Get Spikes: {}", spikes_fb.elapsed());
fbb.Finish(fb_spike_table); fbb.Finish(fb_spike_table);
return crow::response(std::string((const char*)fbb.GetBufferPointer(), fbb.GetSize())); return crow::response(std::string((const char*)fbb.GetBufferPointer(), fbb.GetSize()));
} }
...@@ -360,12 +356,11 @@ crow::response HttpServer::GetSpikesSendWS(const crow::request& request) { ...@@ -360,12 +356,11 @@ crow::response HttpServer::GetSpikesSendWS(const crow::request& request) {
return crow::response("InvalidSpikeDetectorId"); return crow::response("InvalidSpikeDetectorId");
} }
spdlog::info("[insite] Querying spikes: [time: ( %d - %) ] [nodes: (%i - %i)] spikedetector = %i", params.from_time.value(), params.to_time.value(), from_node_id, to_node_id, params.spike_detector_id.value()); SPDLOG_TRACE("[insite] Querying spikes: [time: ( {} - {}) ] [nodes: ({} - {})] spikedetector = %i", params.from_time.value(), params.to_time.value(), from_node_id, to_node_id, params.spike_detector_id.value());
spike_detector->ExtractSpikes(&spikes, params.from_time.value(), params.to_time.value(), from_node_id, spike_detector->ExtractSpikes(&spikes, params.from_time.value(), params.to_time.value(), from_node_id,
to_node_id, &params.node_gids); to_node_id, &params.node_gids);
} else { } else {
spdlog::info("[insite] Querying spikes: [time: ( %d - %) ] [nodes: (%i - %i)]", params.from_time.value(), params.to_time.value(), from_node_id, to_node_id); SPDLOG_TRACE("[insite] Querying spikes: [time: ( {} - {}) ] [nodes: ({} - {})]", params.from_time.value(), params.to_time.value(), from_node_id, to_node_id);
std::unordered_map<std::uint64_t, std::shared_ptr<SpikedetectorStorage>> spike_detectors = storage_->GetSpikeDetectors(); std::unordered_map<std::uint64_t, std::shared_ptr<SpikedetectorStorage>> spike_detectors = storage_->GetSpikeDetectors();
for (const auto& spike_detector_id_storage : spike_detectors) { for (const auto& spike_detector_id_storage : spike_detectors) {
spike_detector_id_storage.second->ExtractSpikes(&spikes, params.from_time.value(), params.to_time.value(), from_node_id, to_node_id, &params.node_gids); spike_detector_id_storage.second->ExtractSpikes(&spikes, params.from_time.value(), params.to_time.value(), from_node_id, to_node_id, &params.node_gids);
...@@ -419,12 +414,12 @@ crow::response HttpServer::GetSpikesV2(const crow::request& request) { ...@@ -419,12 +414,12 @@ crow::response HttpServer::GetSpikesV2(const crow::request& request) {
return crow::response("InvalidSpikeDetectorId"); return crow::response("InvalidSpikeDetectorId");
} }
spdlog::info("[insite] Querying spikes: [time: ( %d - %) ] [nodes: (%i - %i)] spikedetector = %i", params.from_time.value(), params.to_time.value(), from_node_id, to_node_id, params.spike_detector_id.value()); SPDLOG_TRACE("[insite] Querying spikes: [time: ( {} - {}) ] [nodes: ({} - {})] spikedetector = %i", params.from_time.value(), params.to_time.value(), from_node_id, to_node_id, params.spike_detector_id.value());
spike_detector->ExtractSpikes(&spikes, params.from_time.value(), params.to_time.value(), from_node_id, spike_detector->ExtractSpikes(&spikes, params.from_time.value(), params.to_time.value(), from_node_id,
to_node_id, &params.node_gids); to_node_id, &params.node_gids);
} else { } else {
spdlog::info("[insite] Querying spikes: [time: ( %d - %) ] [nodes: (%i - %i)]", params.from_time.value(), params.to_time.value(), from_node_id, to_node_id); SPDLOG_TRACE("[insite] Querying spikes: [time: ( {} - {}) ] [nodes: ({} - {})]", params.from_time.value(), params.to_time.value(), from_node_id, to_node_id);
std::unordered_map<std::uint64_t, std::shared_ptr<SpikedetectorStorage>> spike_detectors = storage_->GetSpikeDetectors(); std::unordered_map<std::uint64_t, std::shared_ptr<SpikedetectorStorage>> spike_detectors = storage_->GetSpikeDetectors();
for (const auto& spike_detector_id_storage : spike_detectors) { for (const auto& spike_detector_id_storage : spike_detectors) {
spike_detector_id_storage.second->ExtractSpikes(&spikes, params.from_time.value(), params.to_time.value(), from_node_id, to_node_id, &params.node_gids); spike_detector_id_storage.second->ExtractSpikes(&spikes, params.from_time.value(), params.to_time.value(), from_node_id, to_node_id, &params.node_gids);
...@@ -476,12 +471,12 @@ crow::response HttpServer::GetSpikes(const crow::request& request) { ...@@ -476,12 +471,12 @@ crow::response HttpServer::GetSpikes(const crow::request& request) {
return crow::response("InvalidSpikeDetectorId"); return crow::response("InvalidSpikeDetectorId");
} }
spdlog::info("[insite] Querying spikes: [time: ( {} - {}) ] [nodes: ({} - {})] spikedetector = %i", params.from_time.value(), params.to_time.value(), from_node_id, to_node_id, params.spike_detector_id.value()); SPDLOG_TRACE("[insite] Querying spikes: [time: ( {} - {}) ] [nodes: ({} - {})] spikedetector = %i", params.from_time.value(), params.to_time.value(), from_node_id, to_node_id, params.spike_detector_id.value());
spike_detector->ExtractSpikes(&spikes, params.from_time.value(), params.to_time.value(), from_node_id, spike_detector->ExtractSpikes(&spikes, params.from_time.value(), params.to_time.value(), from_node_id,
to_node_id, &params.node_gids); to_node_id, &params.node_gids);
} else { } else {
spdlog::info("[insite] Querying spikes: [time: ( {} - {}) ] [nodes: ({} - {})]", params.from_time.value(), params.to_time.value(), from_node_id, to_node_id); SPDLOG_TRACE("[insite] Querying spikes: [time: ( {} - {}) ] [nodes: ({} - {})]", params.from_time.value(), params.to_time.value(), from_node_id, to_node_id);
std::unordered_map<std::uint64_t, std::shared_ptr<SpikedetectorStorage>> spike_detectors = storage_->GetSpikeDetectors(); std::unordered_map<std::uint64_t, std::shared_ptr<SpikedetectorStorage>> spike_detectors = storage_->GetSpikeDetectors();
for (const auto& spike_detector_id_storage : spike_detectors) { for (const auto& spike_detector_id_storage : spike_detectors) {
spike_detector_id_storage.second->ExtractSpikes(&spikes, params.from_time.value(), params.to_time.value(), from_node_id, to_node_id, &params.node_gids); spike_detector_id_storage.second->ExtractSpikes(&spikes, params.from_time.value(), params.to_time.value(), from_node_id, to_node_id, &params.node_gids);
...@@ -524,7 +519,7 @@ crow::response HttpServer::GetMultimeterMeasurement( ...@@ -524,7 +519,7 @@ crow::response HttpServer::GetMultimeterMeasurement(
const crow::request& request) { const crow::request& request) {
MultimeterParameter params(request.url_params); MultimeterParameter params(request.url_params);
spdlog::debug("filter nodes: {}", params.node_gids); SPDLOG_TRACE("filter nodes: {}", params.node_gids);
if (not params.attribute.has_value()) { if (not params.attribute.has_value()) {
return crow::response("The 'attributeName' parameter is missing from the request."); return crow::response("The 'attributeName' parameter is missing from the request.");
...@@ -543,7 +538,7 @@ crow::response HttpServer::GetMultimeterMeasurement( ...@@ -543,7 +538,7 @@ crow::response HttpServer::GetMultimeterMeasurement(
rapidjson::StringBuffer s; rapidjson::StringBuffer s;
rapidjson::PrettyWriter<rapidjson::StringBuffer> writer(s); rapidjson::PrettyWriter<rapidjson::StringBuffer> writer(s);
spdlog::info("Getting MM Measurements {} for {} from {} to {}", params.attribute.value(), multimeter->second->id_, params.from_time.value(), params.to_time.value()); SPDLOG_TRACE("Getting MM Measurements {} for {} from {} to {}", params.attribute.value(), multimeter->second->id_, params.from_time.value(), params.to_time.value());
multimeter->second->ExtractMeasurements(writer, params.attribute.value(), params.node_gids, params.from_time.value(), params.to_time.value()); multimeter->second->ExtractMeasurements(writer, params.attribute.value(), params.node_gids, params.from_time.value(), params.to_time.value());
return crow::response(s.GetString()); return crow::response(s.GetString());
} }
...@@ -552,7 +547,7 @@ crow::response HttpServer::GetMultimeterMeasurementV2( ...@@ -552,7 +547,7 @@ crow::response HttpServer::GetMultimeterMeasurementV2(
const crow::request& request) { const crow::request& request) {
MultimeterParameter params(request.url_params); MultimeterParameter params(request.url_params);
spdlog::debug("filter nodes: {}", params.node_gids); SPDLOG_TRACE("filter nodes: {}", params.node_gids);
if (not params.attribute.has_value()) { if (not params.attribute.has_value()) {
return crow::response("The 'attributeName' parameter is missing from the request."); return crow::response("The 'attributeName' parameter is missing from the request.");
...@@ -571,7 +566,7 @@ crow::response HttpServer::GetMultimeterMeasurementV2( ...@@ -571,7 +566,7 @@ crow::response HttpServer::GetMultimeterMeasurementV2(
rapidjson::StringBuffer s; rapidjson::StringBuffer s;
rapidjson::PrettyWriter<rapidjson::StringBuffer> writer(s); rapidjson::PrettyWriter<rapidjson::StringBuffer> writer(s);
spdlog::info("Getting MM Measurements {} for {} from {} to {}", params.attribute.value(), multimeter->second->id_, params.from_time.value(), params.to_time.value()); SPDLOG_TRACE("Getting MM Measurements {} for {} from {} to {}", params.attribute.value(), multimeter->second->id_, params.from_time.value(), params.to_time.value());
multimeter->second->ExtractMeasurementsV2(writer, params.attribute.value(), params.node_gids, params.from_time.value(), params.to_time.value()); multimeter->second->ExtractMeasurementsV2(writer, params.attribute.value(), params.node_gids, params.from_time.value(), params.to_time.value());
return crow::response(s.GetString()); return crow::response(s.GetString());
} }
......
...@@ -12,9 +12,9 @@ void StopwatchHelper::reset() { ...@@ -12,9 +12,9 @@ void StopwatchHelper::reset() {
} }
void StopwatchHelper::print() { void StopwatchHelper::print() {
SPDLOG_INFO("Checkpoints: "); SPDLOG_TRACE("Checkpoints: ");
for (const auto& checkpoint : checkpoints) { for (const auto& checkpoint : checkpoints) {
SPDLOG_INFO("{} - {}", checkpoint.first, checkpoint.second); SPDLOG_TRACE("{} - {}", checkpoint.first, checkpoint.second);
} }
} }
} // namespace insite } // namespace insite
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment