From 974c4f89b3a806d13f9cea75bdf90d0f0e51fc93 Mon Sep 17 00:00:00 2001
From: Sergey Yakubov <sergey.yakubov@desy.de>
Date: Fri, 4 May 2018 13:24:56 +0200
Subject: [PATCH] async log
---
common/cpp/src/logger/spd_logger.cpp | 3 +--
receiver/src/statistics_sender_influx_db.cpp | 1 +
tests/automatic/full_chain/simple_chain/check_linux.sh | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/common/cpp/src/logger/spd_logger.cpp b/common/cpp/src/logger/spd_logger.cpp
index 5846f5c98..885547740 100644
--- a/common/cpp/src/logger/spd_logger.cpp
+++ b/common/cpp/src/logger/spd_logger.cpp
@@ -46,8 +46,7 @@ void SpdLogger::UpdateLoggerSinks() {
if (centralized_log_) {
sinks_.push_back(std::shared_ptr<FluentdSink> {new FluentdSink(endpoint_uri_)});
}
-
- log__ = std::unique_ptr<spdlog::logger> {new spdlog::logger(name_, std::begin(sinks_), std::end(sinks_))};
+ log__ = std::unique_ptr<spdlog::logger> {new spdlog::async_logger(name_, std::begin(sinks_), std::end(sinks_), 1024)};
}
SpdLogger::SpdLogger(const std::string& name, const std::string& endpoint_uri): name_{name}, endpoint_uri_{endpoint_uri} {
diff --git a/receiver/src/statistics_sender_influx_db.cpp b/receiver/src/statistics_sender_influx_db.cpp
index cf60a5f01..3e8530f4a 100644
--- a/receiver/src/statistics_sender_influx_db.cpp
+++ b/receiver/src/statistics_sender_influx_db.cpp
@@ -18,6 +18,7 @@ std::string string_format( const std::string& format, Args ... args ) {
void StatisticsSenderInfluxDb::SendStatistics(const StatisticsToSend& statistic) const noexcept {
+ //todo: send statistics async
HttpCode code;
Error err;
auto responce = httpclient__->Post(GetReceiverConfig()->monitor_db_uri + "/write?db=" +
diff --git a/tests/automatic/full_chain/simple_chain/check_linux.sh b/tests/automatic/full_chain/simple_chain/check_linux.sh
index 5e4304a60..a85cbe6c4 100644
--- a/tests/automatic/full_chain/simple_chain/check_linux.sh
+++ b/tests/automatic/full_chain/simple_chain/check_linux.sh
@@ -36,6 +36,6 @@ brokerid=`echo $!`
mkdir files
$1 localhost:4200 100 100 &
#producerrid=`echo $!`
-sleep 0.3
+sleep 0.1
$4 ${broker_address} ${broker_database_name} 2 | grep "Processed 100 file(s)"
--
GitLab