Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/gabime/spdlog.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorgabime <gmelman1@gmail.com>2018-05-20 18:01:47 +0300
committergabime <gmelman1@gmail.com>2018-05-20 18:17:34 +0300
commitb94b9a8341150aff1816658d547c7e0bb843fb29 (patch)
tree6a05942f93d0bbc92e0bd5058c4cfb9aceac8c19
parent6a93f98a1f479affc26784c84234139e3d5e58f3 (diff)
format
-rw-r--r--example/bench.cpp2
-rw-r--r--example/example.cpp2
-rw-r--r--tests/test_async.cpp44
3 files changed, 21 insertions, 27 deletions
diff --git a/example/bench.cpp b/example/bench.cpp
index ebb70db0..64095378 100644
--- a/example/bench.cpp
+++ b/example/bench.cpp
@@ -45,7 +45,7 @@ int main(int argc, char *argv[])
threads = atoi(argv[2]);
if (argc > 3)
queue_size = atoi(argv[3]);
-
+
cout << "*******************************************************************************\n";
cout << "Single thread, " << format(howmany) << " iterations" << endl;
cout << "*******************************************************************************\n";
diff --git a/example/example.cpp b/example/example.cpp
index 227eac75..1113431e 100644
--- a/example/example.cpp
+++ b/example/example.cpp
@@ -105,7 +105,7 @@ int main(int, char *[])
void async_example()
{
- size_t q_size = 4096;
+ size_t q_size = 4096;
spdlog::set_async_mode(q_size);
auto async_file = spd::daily_logger_st("async_file_logger", "logs/async_log.txt");
for (int i = 0; i < 100; ++i)
diff --git a/tests/test_async.cpp b/tests/test_async.cpp
index 2bb2305b..0f5d84ea 100644
--- a/tests/test_async.cpp
+++ b/tests/test_async.cpp
@@ -39,7 +39,7 @@ TEST_CASE("discard policy ", "[async]")
auto test_sink = std::make_shared<spdlog::sinks::test_sink_mt>();
size_t queue_size = 2;
size_t messages = 1024;
- spdlog::drop("as");
+ spdlog::drop("as");
auto logger = spdlog::create_async("as", test_sink, queue_size, spdlog::async_overflow_policy::discard_log_msg);
for (size_t i = 0; i < messages; i++)
{
@@ -53,28 +53,25 @@ TEST_CASE("discard policy ", "[async]")
REQUIRE(test_sink->flushed_msg_counter() < messages);
}
-
TEST_CASE("flush", "[async]")
{
auto test_sink = std::make_shared<spdlog::sinks::test_sink_mt>();
size_t queue_size = 256;
size_t messages = 256;
- spdlog::drop("as");
- auto logger = std::make_shared<spdlog::async_logger>("as", test_sink, queue_size);
+ spdlog::drop("as");
+ auto logger = std::make_shared<spdlog::async_logger>("as", test_sink, queue_size);
for (size_t i = 0; i < messages; i++)
{
logger->info("Hello message #{}", i);
}
// the dtor wait for all messages in the queue to get processed
- logger->flush();
- std::this_thread::sleep_for(std::chrono::milliseconds(250));
+ logger->flush();
+ std::this_thread::sleep_for(std::chrono::milliseconds(250));
REQUIRE(test_sink->msg_counter() == messages);
REQUIRE(test_sink->flushed_msg_counter() == messages);
-
-
- REQUIRE(test_sink->flushed_msg_counter() == messages);
-
+
+ REQUIRE(test_sink->flushed_msg_counter() == messages);
}
TEST_CASE("multi threads", "[async]")
@@ -82,8 +79,8 @@ TEST_CASE("multi threads", "[async]")
auto test_sink = std::make_shared<spdlog::sinks::test_sink_mt>();
size_t queue_size = 128;
size_t messages = 256;
- size_t n_threads = 10;
- auto logger = std::make_shared<spdlog::async_logger>("as", test_sink, queue_size);
+ size_t n_threads = 10;
+ auto logger = std::make_shared<spdlog::async_logger>("as", test_sink, queue_size);
std::vector<std::thread> threads;
for (size_t i = 0; i < n_threads; i++)
@@ -102,22 +99,21 @@ TEST_CASE("multi threads", "[async]")
}
// the dtor wait for all messages in the queue to get processed
- logger.reset();
+ logger.reset();
REQUIRE(test_sink->msg_counter() == messages * n_threads);
REQUIRE(test_sink->flushed_msg_counter() == messages * n_threads);
}
-
TEST_CASE("to_file", "[async]")
{
-
- prepare_logdir();
+
+ prepare_logdir();
size_t queue_size = 512;
size_t messages = 512;
- size_t n_threads = 4;
- auto file_sink = std::make_shared<spdlog::sinks::simple_file_sink_mt>("logs/async_test.log", true);
- auto logger = spdlog::create_async("as", file_sink, queue_size);
- std::vector<std::thread> threads;
+ size_t n_threads = 4;
+ auto file_sink = std::make_shared<spdlog::sinks::simple_file_sink_mt>("logs/async_test.log", true);
+ auto logger = spdlog::create_async("as", file_sink, queue_size);
+ std::vector<std::thread> threads;
for (size_t i = 0; i < n_threads; i++)
{
threads.emplace_back([logger, messages] {
@@ -132,9 +128,7 @@ TEST_CASE("to_file", "[async]")
{
t.join();
}
- logger.reset();
- spdlog::drop("as");
- REQUIRE(count_lines("logs/async_test.log") == messages * n_threads);
+ logger.reset();
+ spdlog::drop("as");
+ REQUIRE(count_lines("logs/async_test.log") == messages * n_threads);
}
-
-