diff --git a/common/cpp/src/logger/spd_logger.cpp b/common/cpp/src/logger/spd_logger.cpp index 5846f5c98564ec03dc6db3f4f080788ae9de1fca..885547740e699060f5752b3b2004a0b606a80327 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 cf60a5f017b5a829ae7e4e029fd82ca4e57c31c3..3e8530f4aa0d15c3321660a6d30975aa88ad9f26 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 5e4304a608abb98b302741461e513d3c6db8a0a1..a85cbe6c4e84d0197c3df9518e549ad393973de6 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)"