diff --git a/README.md b/README.md
index fa4cfd00..15643950 100644
--- a/README.md
+++ b/README.md
@@ -2,11 +2,9 @@
Very fast, header only, C++ logging library.
-
## Install
Just copy the files to your build tree and use a C++11 compiler
-
## Tested on:
* gcc 4.8.1 and above
* clang 3.5
@@ -14,11 +12,13 @@ Just copy the files to your build tree and use a C++11 compiler
* mingw with g++ 4.9.x
##Features
-* Very fast - performance is the primary goal (see becnhmarks below).
+* Very fast - performance is the primary goal (see [becnhmarks](#benchmarks) below).
* Headers only.
-* No dependencies.
+* No dependencies - just copy and use.
* Cross platform - Linux / Windows on 32/64 bits.
-* Variadic-template/stream call styles: ```logger.info("variadic", x, y) << "or stream" << z;```
+* **new!** Feature rich [call style](#usage-example) using the excellent [cppformat](http://cppformat.github.io/) library.
+* ostream call style is supported too.
+* Extremely fast asynchronous mode (optional) - use of lockfree queues and other tricks to reach millions of calls per second from multiple threads.
* [Custom](https://github.com/gabime/spdlog/wiki/Custom-formatting) formatting.
* Multi/Single threaded loggers.
* Various log targets:
@@ -27,22 +27,18 @@ Just copy the files to your build tree and use a C++11 compiler
* Console logging.
* Linux syslog.
* Easily extendable with custom log targets (just implement a single function in the [sink](include/spdlog/sinks/sink.h) interface).
-* Optional async logging .
-* Log levels.
-
+* Severity based filtering - threshold levels can be modified in runtime.
## Benchmarks
-Below are some [benchmarks](bench) comparing the time needed to log 1,000,000 lines to file under Ubuntu 64 bit, Intel i7-4770 CPU @ 3.40GHz:
+Below are some [benchmarks](bench) comparing the time needed to log 1,000,000 lines to file under Ubuntu 64 bit, Intel i7-4770 CPU @ 3.40GHz (the best of 3 runs for each logger):
-|threads|boost log|glog|g2log|spdlog|spdlog async mode|
+|threads|boost log|glog|g2log async mode|spdlog|spdlog async mode|
|-------|:-------:|:-----:|------:|------:|------:|
-|1|4.779s|1.109s|3.155s|0.947s|1.455s
-|10|15.151ss|3.546s|3.500s|1.549s|2.040s|
-
-
+|1|4.779s|1.109s|3.155s|0.319s|0.212s
+|10|15.151ss|3.546s|3.500s|0.641s|0.199s|
## Usage Example
@@ -53,37 +49,61 @@ Below are some [benchmarks](bench) comparing the time needed to log 1,000,000 li
int main(int, char* [])
{
namespace spd = spdlog;
-
try
{
- std::string filename = "spdlog_example";
+ // Set log level to all loggers to DEBUG and above
+ spd::set_level(spd::level::DEBUG);
+
+ //Create console, multithreaded logger
auto console = spd::stdout_logger_mt("console");
console->info("Welcome to spdlog!") ;
- console->info() << "Creating file " << filename << "..";
+ console->info("An info message example {}..", 1);
+ console->info() << "Streams are supported too " << 1;
- auto file_logger = spd::rotating_logger_mt("file_logger", filename, 1024 * 1024 * 5, 3);
- file_logger->info("Log file message number", 1);
+ console->info("Easy padding in numbers like {:08d}", 12);
+ console->info("Support for int: {0:d}; hex: {0:x}; oct: {0:o}; bin: {0:b}", 42);
+ console->info("Support for floats {:03.2f}", 1.23456);
+ console->info("Positional args are {1} {0}..", "too", "supported");
- for (int i = 0; i < 100; ++i)
- {
- auto square = i*i;
- file_logger->info() << i << '*' << i << '=' << square << " (" << "0x" << std::hex << square << ")";
- }
+ console->info("{:<30}", "left aligned");
+ console->info("{:>30}", "right aligned");
+ console->info("{:^30}", "centered");
+
+ //Create a file rotating logger with 5mb size max and 3 rotated files
+ auto file_logger = spd::rotating_logger_mt("file_logger", "logs/mylogfile", 1048576 * 5, 3);
+ file_logger->set_level(spd::level::INFO);
+ for(int i = 0; i < 10; ++i)
+ file_logger->info("{} * {} equals {:>10}", i, i, i*i);
- // Change log level to all loggers to warning and above
- spd::set_level(spd::level::WARN);
- console->info("This should not be displayed");
- console->warn("This should!");
- spd::set_level(spd::level::INFO);
+ //Customize msg format for all messages
+ spd::set_pattern("*** [%H:%M:%S %z] [thread %t] %v ***");
+ file_logger->info("This is another message with custom format");
- // Change format pattern to all loggers
- spd::set_pattern(" **** %Y-%m-%d %H:%M:%S.%e %l **** %v");
- spd::get("console")->info("This is another message with different format");
+ spd::get("console")->info("loggers can be retrieved from a global registry using the spdlog::get(logger_name) function");
+
+ SPDLOG_TRACE(file_logger, "This is a trace message (only #ifdef _DEBUG)", 123);
+
+ //
+ // Asynchronous logging is very fast..
+ // Just call spdlog::set_async_mode(q_size) and all created loggers from now on will be asynchronous..
+ //
+ size_t q_size = 1048576; //queue size must be power of 2
+ spdlog::set_async_mode(q_size);
+ auto async_file= spd::daily_logger_st("async_file_logger", "logs/async_log.txt");
+ async_file->info() << "This is async log.." << "Should be very fast!";
+
+ //
+ // syslog example
+ //
+#ifdef __linux__
+ auto syslog_logger = spd::syslog_logger("syslog");
+ syslog_logger->warn("This is warning that will end up in syslog. This is Linux only!");
+#endif
}
catch (const spd::spdlog_ex& ex)
{
std::cout << "Log failed: " << ex.what() << std::endl;
}
- return 0;
}
+
```
diff --git a/bench/Makefile b/bench/Makefile
index 8bbdbd70..6a1e93ca 100644
--- a/bench/Makefile
+++ b/bench/Makefile
@@ -1,5 +1,5 @@
CXX = g++
-CXXFLAGS = -g -march=native -Wall -Wextra -Wshadow -pedantic -std=c++11 -pthread -Wl,--no-as-needed -I../include
+CXXFLAGS = -march=native -Wall -Wshadow -Wextra -pedantic -std=c++11 -pthread -Wl,--no-as-needed -I../include
CXX_RELEASE_FLAGS = -O3 -flto
diff --git a/bench/g2log-bench-mt.cpp b/bench/g2log-bench-mt.cpp
index 60660ecf..9e32c3f4 100644
--- a/bench/g2log-bench-mt.cpp
+++ b/bench/g2log-bench-mt.cpp
@@ -19,7 +19,7 @@ int main(int argc, char* argv[])
g2LogWorker g2log(argv[0], "logs");
g2::initializeLogging(&g2log);
-
+
std::atomic msg_counter {0};
vector threads;
diff --git a/bench/g2log-bench.cpp b/bench/g2log-bench.cpp
index d06131b8..f716940a 100644
--- a/bench/g2log-bench.cpp
+++ b/bench/g2log-bench.cpp
@@ -5,10 +5,10 @@
int main(int, char* argv[])
{
int howmany = 1000000;
-
- g2LogWorker g2log(argv[0], "logs");
+
+ g2LogWorker g2log(argv[0], "logs");
g2::initializeLogging(&g2log);
-
+
for(int i = 0 ; i < howmany; ++i)
LOG(INFO) << "g2log message # " << i << ": This is some text for your pleasure";
diff --git a/bench/results.txt b/bench/results.txt
deleted file mode 100644
index df7f94e3..00000000
--- a/bench/results.txt
+++ /dev/null
@@ -1,80 +0,0 @@
-Running benchmakrs (all with 1000,000 writes to the logs folder
-
-boost-bench (single thread)..
-
-real 0m4.779s
-user 0m4.256s
-sys 0m0.044s
-
-
-glog-bench (single thread)..
-
-real 0m1.109s
-user 0m0.967s
-sys 0m0.140s
-
-
-g2log-bench (single thread)..
-
-Exiting, log location: logs/g2log-bench.g2log.20141124-233419.log
-
-real 0m3.155s
-user 0m4.255s
-sys 0m0.874s
-
-
-spdlog-bench (single thread)
-
-real 0m0.947s
-user 0m0.914s
-sys 0m0.032s
-
-
-------------------------------------
-Multithreaded benchmarks..
-------------------------------------
-boost-bench-mt (10 threads, single logger)..
-
-real 0m15.151s
-user 0m35.555s
-sys 0m7.453s
-
-
-glog-bench-mt (10 threads, single logger)..
-
-real 0m3.546s
-user 0m9.836s
-sys 0m10.985s
-
-
-g2log-bench-mt (10 threads, single logger)..
-
-Exiting, log location: logs/g2log-bench-mt.g2log.20141124-233502.log
-
-real 0m3.500s
-user 0m7.671s
-sys 0m1.646s
-
-
-spdlog-bench-mt (10 threads, single logger)..
-
-real 0m1.549s
-user 0m6.994s
-sys 0m2.969s
-
-
-------------------------------------
-Async benchmarks..
-------------------------------------
-spdlog-bench-async (single thread)..
-
-real 0m1.455s
-user 0m2.381s
-sys 0m0.417s
-
-
-spdlog-bench-mt-async (10 threads, single logger)..
-
-real 0m2.040s
-user 0m4.076s
-sys 0m2.822s
diff --git a/bench/run_all.sh b/bench/run_all.sh
index 4a437ece..4e0eb531 100755
--- a/bench/run_all.sh
+++ b/bench/run_all.sh
@@ -2,29 +2,29 @@
echo "Running benchmakrs (all with 1000,000 writes to the logs folder)"
echo
echo "boost-bench (single thread).."
-time ./boost-bench
-rm logs/*
+for i in {1..3}; do time ./boost-bench; done
+rm -f logs/*
echo
echo
sleep 5
echo "glog-bench (single thread).."
-time ./glog-bench
-rm logs/*
+for i in {1..3}; do time ./glog-bench; done
+rm -f logs/*
echo
echo
sleep 5
echo "g2log-bench (single thread).."
-time ./g2log-bench
-rm logs/*
+for i in {1..3}; do time ./g2log-bench; done
+rm -f logs/*
echo
echo
sleep 5
echo "spdlog-bench (single thread)"
-time ./spdlog-bench
-rm logs/*
+for i in {1..3}; do time ./spdlog-bench; done
+rm -f logs/*
echo
echo
sleep 5
@@ -32,29 +32,29 @@ echo "------------------------------------"
echo "Multithreaded benchmarks.."
echo "------------------------------------"
echo "boost-bench-mt (10 threads, single logger)"..
-time ./boost-bench-mt
-rm logs/*
+for i in {1..3}; do ./boost-bench-mt; done
+rm -f logs/*
echo
echo
sleep 5
echo "glog-bench-mt (10 threads, single logger)"..
-time ./glog-bench-mt
-rm logs/*
+for i in {1..3}; do time ./glog-bench-mt; done
+rm -f logs/*
echo
echo
sleep 5
echo "g2log-bench-mt (10 threads, single logger)"..
-time ./g2log-bench-mt
-rm logs/*
+for i in {1..3}; do time ./g2log-bench-mt; done
+rm -f logs/*
echo
echo
sleep 5
echo "spdlog-bench-mt (10 threads, single logger)"..
-time ./spdlog-bench-mt
-rm logs/*
+for i in {1..3}; do time ./spdlog-bench-mt; done
+rm -f logs/*
echo
echo
sleep 5
@@ -64,14 +64,14 @@ echo "Async benchmarks.."
echo "------------------------------------"
echo "spdlog-bench-async (single thread)"..
-time ./spdlog-bench-async
-rm logs/*
+for i in {1..3}; do time ./spdlog-bench-async; done
+rm -f logs/*
echo
echo
sleep 5
echo "spdlog-bench-mt-async (10 threads, single logger)"..
-time ./spdlog-bench-mt-async
+for i in {1..3}; do time ./spdlog-bench-mt-async; done
diff --git a/bench/spdlog-bench-async.cpp b/bench/spdlog-bench-async.cpp
index 9054cb6e..d30e8677 100644
--- a/bench/spdlog-bench-async.cpp
+++ b/bench/spdlog-bench-async.cpp
@@ -4,15 +4,19 @@
int main(int, char* [])
{
- int howmany = 1000000;
+ int howmany = 1048576;
namespace spd = spdlog;
- spd::set_async_mode(2500, std::chrono::seconds(0));
+ spd::set_async_mode(howmany);
///Create a file rotating logger with 5mb size max and 3 rotated files
auto logger = spd::rotating_logger_mt("file_logger", "logs/spd-sample", 10 *1024 * 1024 , 5);
logger->set_pattern("[%Y-%b-%d %T.%e]: %v");
for(int i = 0 ; i < howmany; ++i)
logger->info() << "spdlog message #" << i << ": This is some text for your pleasure";
- spd::stop();
+
+
+ //because spdlog async logger waits for the back thread logger to finish all messages upon destrcuting,
+ //and we want to measure only the time it took to push those messages to the backthread..
+ abort();
return 0;
}
diff --git a/bench/spdlog-bench-mt-async.cpp b/bench/spdlog-bench-mt-async.cpp
index 17c72a8c..f7d424a1 100644
--- a/bench/spdlog-bench-mt-async.cpp
+++ b/bench/spdlog-bench-mt-async.cpp
@@ -14,10 +14,10 @@ int main(int argc, char* argv[])
if(argc > 1)
thread_count = atoi(argv[1]);
- int howmany = 1000000;
+ int howmany = 1048576;
namespace spd = spdlog;
- spd::set_async_mode(2500, std::chrono::seconds(0));
+ spd::set_async_mode(howmany);
///Create a file rotating logger with 5mb size max and 3 rotated files
auto logger = spd::rotating_logger_mt("file_logger", "logs/spd-sample", 10 *1024 * 1024 , 5);
@@ -45,6 +45,7 @@ int main(int argc, char* argv[])
t.join();
};
- spd::stop();
- return 0;
+ //because spdlog async logger waits for the back thread logger to finish all messages upon destrcuting,
+ //and we want to measure only the time it took to push those messages to the backthread..
+ abort();
}
diff --git a/bench/spdlog-bench-mt.cpp b/bench/spdlog-bench-mt.cpp
index 93a3cca0..778c7745 100644
--- a/bench/spdlog-bench-mt.cpp
+++ b/bench/spdlog-bench-mt.cpp
@@ -17,8 +17,8 @@ int main(int argc, char* argv[])
int howmany = 1000000;
namespace spd = spdlog;
- ///Create a file rotating logger with 5mb size max and 5 rotated files
- auto logger = spd::rotating_logger_mt("file_logger", "logs/spd-sample", 10 *1024 * 1024 , 5);
+ ///Create a file rotating logger with 10mb size max and 5 rotated files
+ auto logger = spd::rotating_logger_mt("file_logger", "logs/spd-sample", 10 *1024 * 1024 , 5, false);
logger->set_pattern("[%Y-%b-%d %T.%e]: %v");
diff --git a/example/Makefile b/example/Makefile
index b576fa7b..4208786a 100644
--- a/example/Makefile
+++ b/example/Makefile
@@ -1,5 +1,5 @@
CXX = g++
-CXXFLAGS = -march=native -Wall -Wextra -Wshadow -pedantic -std=c++11 -pthread -Wl,--no-as-needed -I../include
+CXXFLAGS = -march=native -Wall -Wshadow -Wextra -pedantic -std=c++11 -pthread -Wl,--no-as-needed -I../include
CXX_RELEASE_FLAGS = -O3 -flto
CXX_DEBUG_FLAGS= -g
diff --git a/example/bench.cpp b/example/bench.cpp
index 87cf4946..c06c71e3 100644
--- a/example/bench.cpp
+++ b/example/bench.cpp
@@ -50,9 +50,9 @@ void bench_mt(int howmany, std::shared_ptr log, int thread_count
int main(int argc, char* argv[])
{
- int howmany = 1000000;
+ int howmany = 1048576;
int threads = 10;
- bool auto_flush = true;
+ bool auto_flush = false;
int file_size = 30 * 1024 * 1024;
int rotating_files = 5;
@@ -64,6 +64,7 @@ int main(int argc, char* argv[])
if (argc > 2)
threads = atoi(argv[2]);
+
cout << "*******************************************************************************\n";
cout << "Single thread, " << format(howmany) << " iterations, auto flush=" << auto_flush << endl;
cout << "*******************************************************************************\n";
@@ -85,18 +86,20 @@ int main(int argc, char* argv[])
auto daily_mt = spdlog::daily_logger_mt("daily_mt", "logs/daily_mt", auto_flush);
bench_mt(howmany, daily_mt, threads);
bench(howmany, spdlog::create("null_mt"));
-
+
cout << "\n*******************************************************************************\n";
cout << "async logging.. " << threads << " threads sharing same logger, " << format(howmany) << " iterations, auto_flush=" << auto_flush << endl;
- cout << "*******************************************************************************\n";
+ cout << "*******************************************************************************\n";
-
- spdlog::set_async_mode(2500);
- auto daily_st_async = spdlog::daily_logger_st("daily_async", "logs/daily_async", auto_flush);
- bench_mt(howmany, daily_st_async, threads);
-
- spdlog::stop();
+ spdlog::set_async_mode(howmany);
+
+ for(int i = 0; i < 5; ++i)
+ {
+ auto as = spdlog::daily_logger_st("as", "logs/daily_async", auto_flush);
+ bench_mt(howmany, as, threads);
+ spdlog::drop("as");
+ }
}
catch (std::exception &ex)
{
@@ -113,7 +116,7 @@ void bench(int howmany, std::shared_ptr log)
auto start = system_clock::now();
for (auto i = 0; i < howmany; ++i)
{
- log->info("Hello logger: msg number ", i);
+ log->info("Hello logger: msg number {}", i);
}
@@ -138,7 +141,7 @@ void bench_mt(int howmany, std::shared_ptr log, int thread_count
{
int counter = ++msg_counter;
if (counter > howmany) break;
- log->info("Hello logger: msg number ") << counter;
+ log->info("Hello logger: msg number {}", counter);
}
}));
}
@@ -154,4 +157,3 @@ void bench_mt(int howmany, std::shared_ptr log, int thread_count
auto delta_d = duration_cast> (delta).count();
cout << format(int(howmany / delta_d)) << "/sec" << endl;
}
-
diff --git a/example/example.cpp b/example/example.cpp
index 889d96bc..0cfa326f 100644
--- a/example/example.cpp
+++ b/example/example.cpp
@@ -44,17 +44,25 @@ int main(int, char* [])
//Create console, multithreaded logger
auto console = spd::stdout_logger_mt("console");
console->info("Welcome to spdlog!") ;
- console->info("An info message example", "...", 1, 2, 3.5);
- console->info() << "Streams are supported too " << std::setw(5) << std::setfill('0') << 1;
+ console->info("An info message example {}..", 1);
+ console->info() << "Streams are supported too " << 1;
+
+
+ console->info("Easy padding in numbers like {:08d}", 12);
+ console->info("Support for int: {0:d}; hex: {0:08x}; oct: {0:o}; bin: {0:b}", 42);
+ console->info("Support for floats {:03.2f}", 1.23456);
+ console->info("Positional args are {1} {0}..", "too", "supported");
+
+ console->info("{:<30}", "left aligned");
+ console->info("{:>30}", "right aligned");
+ console->info("{:^30}", "centered");
//Create a file rotating logger with 5mb size max and 3 rotated files
auto file_logger = spd::rotating_logger_mt("file_logger", filename, 1024 * 1024 * 5, 3);
- file_logger->info("Log file message number", 1);
- for (int i = 0; i < 100; ++i)
- {
- file_logger->info(i, "in hex is", "0x") << std::hex << std::uppercase << i;
- }
+ file_logger->info("Log file message number", 1);
+ for(int i = 0; i < 10; ++i)
+ file_logger->info("{} * {} equals {:>10}", i, i, i*i);
spd::set_pattern("*** [%H:%M:%S %z] [thread %t] %v ***");
file_logger->info("This is another message with custom format");
@@ -65,12 +73,12 @@ int main(int, char* [])
//
// Asynchronous logging is easy..
- // Just call spdlog::set_async_mode(max_q_size) and all created loggers from now on will be asynchronous..
+ // Just call spdlog::set_async_mode(q_size) and all created loggers from now on will be asynchronous..
+ // Note: queue size must be power of 2!
//
-
- size_t max_q_size = 100000;
+ size_t max_q_size = 1048576;
spdlog::set_async_mode(max_q_size);
- auto async_file= spd::daily_logger_st("async_file_logger", "async_" + filename);
+ auto async_file= spd::daily_logger_st("async_file_logger", "logs/async_log.txt");
async_file->info() << "This is async log.." << "Should be very fast!";
//
diff --git a/example/utils.h b/example/utils.h
index 25b0cb45..95dd9257 100644
--- a/example/utils.h
+++ b/example/utils.h
@@ -24,7 +24,6 @@
#pragma once
-#include
#include
#include
#include
diff --git a/include/spdlog/async_logger.h b/include/spdlog/async_logger.h
index d2302c23..518e61cf 100644
--- a/include/spdlog/async_logger.h
+++ b/include/spdlog/async_logger.h
@@ -24,10 +24,15 @@
#pragma once
-// Async logger
+// Very fast asynchronous logger (millions of logs per second on an average desktop)
+// Uses pre allocated lockfree queue for maximum throughput even under large number of threads.
+// Creates a single back thread to pop messages from the queue and log them.
+//
// Upon each log write the logger:
-// 1. Checks if its log level is enough to log the message
-// 2. Push a new copy of the message to a queue (uses sinks::async_sink for this)
+// 1. Checks if its log level is enough to log the message
+// 2. Push a new copy of the message to a queue (or block the caller until space is available in the queue)
+// 3. will throw spdlog_ex upon log exceptions
+// Upong destruction, logs all remaining messages in the queue before destructing..
#include
#include "common.h"
@@ -37,18 +42,18 @@
namespace spdlog
{
-namespace sinks
+namespace details
{
-class async_sink;
+class async_log_helper;
}
class async_logger :public logger
{
public:
template
- async_logger(const std::string& name, const It& begin, const It& end, size_t queue_size, const log_clock::duration& shutdown_duration);
- async_logger(const std::string& logger_name, sinks_init_list sinks, size_t queue_size, const log_clock::duration& shutdown_duration);
- async_logger(const std::string& logger_name, sink_ptr single_sink, size_t queue_size, const log_clock::duration& shutdown_duration);
+ async_logger(const std::string& name, const It& begin, const It& end, size_t queue_size);
+ async_logger(const std::string& logger_name, sinks_init_list sinks, size_t queue_size);
+ async_logger(const std::string& logger_name, sink_ptr single_sink, size_t queue_size);
protected:
@@ -58,8 +63,7 @@ protected:
void _stop() override;
private:
- log_clock::duration _shutdown_duration;
- std::unique_ptr _as;
+ std::unique_ptr _async_log_helper;
};
}
diff --git a/include/spdlog/details/async_log_helper.h b/include/spdlog/details/async_log_helper.h
new file mode 100644
index 00000000..af6efa26
--- /dev/null
+++ b/include/spdlog/details/async_log_helper.h
@@ -0,0 +1,289 @@
+/*************************************************************************/
+/* spdlog - an extremely fast and easy to use c++11 logging library. */
+/* Copyright (c) 2014 Gabi Melman. */
+/* */
+/* Permission is hereby granted, free of charge, to any person obtaining */
+/* a copy of this software and associated documentation files (the */
+/* "Software"), to deal in the Software without restriction, including */
+/* without limitation the rights to use, copy, modify, merge, publish, */
+/* distribute, sublicense, and/or sell copies of the Software, and to */
+/* permit persons to whom the Software is furnished to do so, subject to */
+/* the following conditions: */
+/* */
+/* The above copyright notice and this permission notice shall be */
+/* included in all copies or substantial portions of the Software. */
+/* */
+/* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, */
+/* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF */
+/* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.*/
+/* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY */
+/* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, */
+/* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */
+/* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */
+/*************************************************************************/
+
+// async log helper :
+// Process logs asynchronously using a back thread.
+//
+// If the internal queue of log messages reaches its max size,
+// then the client call will block until there is more room.
+//
+// If the back thread throws during logging, a spdlog::spdlog_ex exception
+// will be thrown in client's thread when tries to log the next message
+
+#pragma once
+
+#include
+#include
+#include
+
+#include "../common.h"
+#include "../sinks/sink.h"
+#include "./mpmc_bounded_q.h"
+#include "./log_msg.h"
+#include "./format.h"
+
+
+namespace spdlog
+{
+namespace details
+{
+
+
+class async_log_helper
+{
+ // Async msg to move to/from the queue
+ // Movable only. should never be copied
+ struct async_msg
+ {
+ std::string logger_name;
+ level::level_enum level;
+ log_clock::time_point time;
+ std::string txt;
+
+ async_msg() = default;
+ ~async_msg() = default;
+
+ async_msg(const async_msg&) = delete;
+ async_msg& operator=(async_msg& other) = delete;
+
+ async_msg(const details::log_msg& m) :
+ logger_name(m.logger_name),
+ level(m.level),
+ time(m.time),
+ txt(m.raw.data(), m.raw.size())
+ {}
+
+ async_msg(async_msg&& other) :
+ logger_name(std::move(other.logger_name)),
+ level(std::move(other.level)),
+ time(std::move(other.time)),
+ txt(std::move(other.txt))
+ {}
+
+ async_msg& operator=(async_msg&& other)
+ {
+ logger_name = std::move(other.logger_name);
+ level = other.level;
+ time = std::move(other.time);
+ txt = std::move(other.txt);
+ return *this;
+ }
+
+
+ void fill_log_msg(log_msg &msg)
+ {
+ msg.clear();
+ msg.logger_name = logger_name;
+ msg.level = level;
+ msg.time = time;
+ msg.raw << txt;
+ }
+ };
+
+public:
+
+ using item_type = async_msg;
+ using q_type = details::mpmc_bounded_queue;
+
+ using clock = std::chrono::steady_clock;
+
+
+ async_log_helper(formatter_ptr formatter, const std::vector& sinks, size_t queue_size);
+ void log(const details::log_msg& msg);
+
+ //Stop logging and join the back thread
+ ~async_log_helper();
+ void set_formatter(formatter_ptr);
+
+
+private:
+ std::atomic _active;
+ formatter_ptr _formatter;
+ std::vector> _sinks;
+ q_type _q;
+ std::thread _worker_thread;
+
+ // last exception thrown from the worker thread
+ std::shared_ptr _last_workerthread_ex;
+
+
+ // throw last worker thread exception or if worker thread is not active
+ void throw_if_bad_worker();
+
+ // worker thread main loop
+ void worker_loop();
+
+ //pop next message from the queue and process it
+ //return true if a message was available (queue was not empty), will set the last_pop to the pop time
+ bool process_next_msg(clock::time_point& last_pop);
+
+ // guess how much to sleep if queue is empty/full using last succesful op time as hint
+ static void sleep_or_yield(const clock::time_point& last_op_time);
+
+
+ // clear all remaining messages(if any), stop the _worker_thread and join it
+ void join_worker();
+
+};
+}
+}
+
+///////////////////////////////////////////////////////////////////////////////
+// async_sink class implementation
+///////////////////////////////////////////////////////////////////////////////
+inline spdlog::details::async_log_helper::async_log_helper(formatter_ptr formatter, const std::vector& sinks, size_t queue_size):
+ _active(true),
+ _formatter(formatter),
+ _sinks(sinks),
+ _q(queue_size),
+ _worker_thread(&async_log_helper::worker_loop, this)
+{}
+
+inline spdlog::details::async_log_helper::~async_log_helper()
+{
+ join_worker();
+}
+
+
+//Try to push and block until succeeded
+inline void spdlog::details::async_log_helper::log(const details::log_msg& msg)
+{
+ throw_if_bad_worker();
+ async_msg new_msg(msg);
+ if (!_q.enqueue(std::move(new_msg)))
+ {
+ auto last_op_time = clock::now();
+ do
+ {
+ sleep_or_yield(last_op_time);
+ }
+ while (!_q.enqueue(std::move(new_msg)));
+ }
+
+}
+
+inline void spdlog::details::async_log_helper::worker_loop()
+{
+ clock::time_point last_pop = clock::now();
+ while (_active)
+ {
+ //Dont die if there are still messages in the q to process
+ while(process_next_msg(last_pop));
+ }
+}
+
+
+inline bool spdlog::details::async_log_helper::process_next_msg(clock::time_point& last_pop)
+{
+
+ async_msg incoming_async_msg;
+ log_msg incoming_log_msg;
+
+ if (_q.dequeue(incoming_async_msg))
+ {
+ last_pop = clock::now();
+ try
+ {
+ incoming_async_msg.fill_log_msg(incoming_log_msg);
+ _formatter->format(incoming_log_msg);
+ for (auto &s : _sinks)
+ s->log(incoming_log_msg);
+ }
+ catch (const std::exception& ex)
+ {
+ _last_workerthread_ex = std::make_shared(std::string("async_logger worker thread exception: ") + ex.what());
+ }
+ catch (...)
+ {
+ _last_workerthread_ex = std::make_shared("async_logger worker thread exception");
+ }
+ return true;
+ }
+ // sleep or yield if queue is empty.
+ else
+ {
+ sleep_or_yield(last_pop);
+ return false;
+ }
+}
+
+inline void spdlog::details::async_log_helper::set_formatter(formatter_ptr msg_formatter)
+{
+ _formatter = msg_formatter;
+}
+
+
+// Sleep,yield or return immediatly using the time passed since last message as a hint
+inline void spdlog::details::async_log_helper::sleep_or_yield(const clock::time_point& last_op_time)
+{
+ using std::chrono::milliseconds;
+ using namespace std::this_thread;
+
+ auto time_since_op = clock::now() - last_op_time;
+
+ //spin upto 1 ms
+ if (time_since_op <= milliseconds(1))
+ return;
+
+ // yield upto 10ms
+ if (time_since_op <= milliseconds(10))
+ return yield();
+
+
+ // sleep for half of duration since last op
+ if (time_since_op <= milliseconds(100))
+ return sleep_for(time_since_op / 2);
+
+ return sleep_for(milliseconds(100));
+}
+
+//throw if the worker thread threw an exception or not active
+inline void spdlog::details::async_log_helper::throw_if_bad_worker()
+{
+ if (_last_workerthread_ex)
+ {
+ auto ex = std::move(_last_workerthread_ex);
+ _last_workerthread_ex.reset();
+ throw *ex;
+ }
+ if (!_active)
+ throw(spdlog_ex("async logger is not active"));
+}
+
+
+inline void spdlog::details::async_log_helper::join_worker()
+{
+ _active = false;
+
+ try
+ {
+ _worker_thread.join();
+ }
+ catch (const std::system_error&) //Dont crash if thread not joinable
+ {}
+}
+
+
+
+
diff --git a/include/spdlog/details/async_logger_impl.h b/include/spdlog/details/async_logger_impl.h
index e84f897d..0b3022ec 100644
--- a/include/spdlog/details/async_logger_impl.h
+++ b/include/spdlog/details/async_logger_impl.h
@@ -25,8 +25,7 @@
#pragma once
-#include
-#include "../sinks/async_sink.h"
+#include "./async_log_helper.h"
//
// Async Logger implementation
@@ -35,38 +34,29 @@
template
-inline spdlog::async_logger::async_logger(const std::string& logger_name, const It& begin, const It& end, size_t queue_size, const log_clock::duration& shutdown_duration) :
+inline spdlog::async_logger::async_logger(const std::string& logger_name, const It& begin, const It& end, size_t queue_size) :
logger(logger_name, begin, end),
- _shutdown_duration(shutdown_duration),
- _as(std::unique_ptr(new sinks::async_sink(queue_size)))
+ _async_log_helper(new details::async_log_helper(_formatter, _sinks, queue_size))
{
- _as->set_formatter(_formatter);
- for (auto &s : _sinks)
- _as->add_sink(s);
}
-inline spdlog::async_logger::async_logger(const std::string& logger_name, sinks_init_list sinks, size_t queue_size, const log_clock::duration& shutdown_duration) :
- async_logger(logger_name, sinks.begin(), sinks.end(), queue_size, shutdown_duration) {}
+inline spdlog::async_logger::async_logger(const std::string& logger_name, sinks_init_list sinks, size_t queue_size) :
+ async_logger(logger_name, sinks.begin(), sinks.end(), queue_size) {}
-inline spdlog::async_logger::async_logger(const std::string& logger_name, sink_ptr single_sink, size_t queue_size, const log_clock::duration& shutdown_duration) :
- async_logger(logger_name, { single_sink }, queue_size, shutdown_duration) {}
+inline spdlog::async_logger::async_logger(const std::string& logger_name, sink_ptr single_sink, size_t queue_size) :
+ async_logger(logger_name, { single_sink }, queue_size) {}
-inline void spdlog::async_logger::_log_msg(details::log_msg& msg)
-{
- _as->log(msg);
-}
-
inline void spdlog::async_logger::_set_formatter(spdlog::formatter_ptr msg_formatter)
{
_formatter = msg_formatter;
- _as->set_formatter(_formatter);
+ _async_log_helper->set_formatter(_formatter);
}
inline void spdlog::async_logger::_set_pattern(const std::string& pattern)
{
_formatter = std::make_shared(pattern);
- _as->set_formatter(_formatter);
+ _async_log_helper->set_formatter(_formatter);
}
@@ -74,5 +64,9 @@ inline void spdlog::async_logger::_set_pattern(const std::string& pattern)
inline void spdlog::async_logger::_stop()
{
set_level(level::OFF);
- _as->shutdown(_shutdown_duration);
+}
+
+inline void spdlog::async_logger::_log_msg(details::log_msg& msg)
+{
+ _async_log_helper->log(msg);
}
diff --git a/include/spdlog/details/blocking_queue.h b/include/spdlog/details/blocking_queue.h
deleted file mode 100644
index 8fe01998..00000000
--- a/include/spdlog/details/blocking_queue.h
+++ /dev/null
@@ -1,155 +0,0 @@
-/*************************************************************************/
-/* spdlog - an extremely fast and easy to use c++11 logging library. */
-/* Copyright (c) 2014 Gabi Melman. */
-/* */
-/* Permission is hereby granted, free of charge, to any person obtaining */
-/* a copy of this software and associated documentation files (the */
-/* "Software"), to deal in the Software without restriction, including */
-/* without limitation the rights to use, copy, modify, merge, publish, */
-/* distribute, sublicense, and/or sell copies of the Software, and to */
-/* permit persons to whom the Software is furnished to do so, subject to */
-/* the following conditions: */
-/* */
-/* The above copyright notice and this permission notice shall be */
-/* included in all copies or substantial portions of the Software. */
-/* */
-/* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, */
-/* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF */
-/* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.*/
-/* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY */
-/* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, */
-/* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */
-/* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */
-/*************************************************************************/
-
-#pragma once
-
-// A blocking multi-consumer/multi-producer thread safe queue.
-// Has max capacity and supports timeout on push or pop operations.
-
-#include
-#include
-#include
-#include
-#include
-
-namespace spdlog
-{
-namespace details
-{
-
-template
-class blocking_queue
-{
-public:
- using queue_type = std::queue;
- using item_type = T;
- using size_type = typename queue_type::size_type;
- using clock = std::chrono::system_clock;
-
- explicit blocking_queue(size_type max_size) :
- _max_size(max_size),
- _q(),
- _mutex()
- {
- }
- blocking_queue(const blocking_queue&) = delete;
- blocking_queue& operator=(const blocking_queue&) = delete;
- ~blocking_queue() = default;
-
- size_type size()
- {
- std::lock_guard lock(_mutex);
- return _q.size();
- }
-
- // Push copy of item into the back of the queue.
- // If the queue is full, block the calling thread util there is room or timeout have passed.
- // Return: false on timeout, true on successful push.
- template
- bool push(TT&& item, const std::chrono::duration& timeout)
- {
- {
- std::unique_lock ul(_mutex);
- if (is_full())
- {
- if (!_item_popped_cond.wait_until(ul, clock::now() + timeout, [this]()
- {
- return !this->is_full();
- }))
- return false;
- }
- _q.push(std::forward(item));
- }
- _item_pushed_cond.notify_one();
- return true;
- }
-
-// Push copy of item into the back of the queue.
-// If the queue is full, block the calling thread until there is room.
- template
- void push(TT&& item)
- {
- while (!push(std::forward(item), std::chrono::seconds(60)));
- }
-
-// Pop a copy of the front item in the queue into the given item ref.
-// If the queue is empty, block the calling thread util there is item to pop or timeout have passed.
-// Return: false on timeout , true on successful pop/
- template
- bool pop(T& item, const std::chrono::duration& timeout)
- {
- {
- std::unique_lock ul(_mutex);
- if (is_empty())
- {
- if (!_item_pushed_cond.wait_until(ul, clock::now() + timeout, [this]()
- {
- return !this->is_empty();
- }))
- return false;
- }
- item = std::move(_q.front());
- _q.pop();
- }
- _item_popped_cond.notify_one();
- return true;
- }
-
-// Pop a copy of the front item in the queue into the given item ref.
-// If the queue is empty, block the calling thread util there is item to pop.
- void pop(T& item)
- {
- while (!pop(item, std::chrono::hours(1)));
- }
-
-// Clear the queue
- void clear()
- {
- {
- std::unique_lock ul(_mutex);
- queue_type().swap(_q);
- }
- _item_popped_cond.notify_all();
- }
-
-private:
- size_type _max_size;
- std::queue _q;
- std::mutex _mutex;
- std::condition_variable _item_pushed_cond;
- std::condition_variable _item_popped_cond;
-
- inline bool is_full()
- {
- return _q.size() >= _max_size;
- }
-
- inline bool is_empty()
- {
- return _q.size() == 0;
- }
-};
-
-}
-}
diff --git a/include/spdlog/details/fast_istostr.h b/include/spdlog/details/fast_istostr.h
deleted file mode 100644
index 55500955..00000000
--- a/include/spdlog/details/fast_istostr.h
+++ /dev/null
@@ -1,130 +0,0 @@
-/*************************************************************************/
-/* spdlog - an extremely fast and easy to use c++11 logging library. */
-/* Copyright (c) 2014 Gabi Melman. */
-/* */
-/* Permission is hereby granted, free of charge, to any person obtaining */
-/* a copy of this software and associated documentation files (the */
-/* "Software"), to deal in the Software without restriction, including */
-/* without limitation the rights to use, copy, modify, merge, publish, */
-/* distribute, sublicense, and/or sell copies of the Software, and to */
-/* permit persons to whom the Software is furnished to do so, subject to */
-/* the following conditions: */
-/* */
-/* The above copyright notice and this permission notice shall be */
-/* included in all copies or substantial portions of the Software. */
-/* */
-/* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, */
-/* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF */
-/* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.*/
-/* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY */
-/* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, */
-/* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */
-/* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */
-/*************************************************************************/
-
-#pragma once
-#include
-
-//Fast to int to string
-//Base on :http://stackoverflow.com/a/4351484/192001
-//Modified version to pad zeros according to padding arg
-
-namespace spdlog
-{
-namespace details
-{
-
-const char digit_pairs[201] =
-{
- "00010203040506070809"
- "10111213141516171819"
- "20212223242526272829"
- "30313233343536373839"
- "40414243444546474849"
- "50515253545556575859"
- "60616263646566676869"
- "70717273747576777879"
- "80818283848586878889"
- "90919293949596979899"
-};
-
-
-inline std::string& fast_itostr(int n, std::string& s, size_t padding)
-{
- if (n == 0)
- {
- s = std::string(padding, '0');
- return s;
- }
-
- int sign = -(n < 0);
- unsigned int val = static_cast((n^sign) - sign);
-
- size_t size;
- if (val >= 10000)
- {
- if (val >= 10000000)
- {
- if (val >= 1000000000)
- size = 10;
- else if (val >= 100000000)
- size = 9;
- else
- size = 8;
- }
- else
- {
- if (val >= 1000000)
- size = 7;
- else if (val >= 100000)
- size = 6;
- else
- size = 5;
- }
- }
- else
- {
- if (val >= 100)
- {
- if (val >= 1000)
- size = 4;
- else
- size = 3;
- }
- else
- {
- if (val >= 10)
- size = 2;
- else
- size = 1;
- }
- }
- size -= sign;
- if (size < padding)
- size = padding;
-
- s.resize(size);
- char* c = &s[0];
- if (sign)
- *c = '-';
-
- c += size - 1;
- while (val >= 100)
- {
- size_t pos = val % 100;
- val /= 100;
- *(short*)(c - 1) = *(short*)(digit_pairs + 2 * pos);
- c -= 2;
- }
- while (val > 0)
- {
- *c-- = static_cast('0' + (val % 10));
- val /= 10;
- }
-
- while (c >= s.data())
- *c-- = '0';
- return s;
-}
-}
-}
diff --git a/include/spdlog/details/fast_oss.h b/include/spdlog/details/fast_oss.h
deleted file mode 100644
index 447c1783..00000000
--- a/include/spdlog/details/fast_oss.h
+++ /dev/null
@@ -1,189 +0,0 @@
-/*************************************************************************/
-/* spdlog - an extremely fast and easy to use c++11 logging library. */
-/* Copyright (c) 2014 Gabi Melman. */
-/* */
-/* Permission is hereby granted, free of charge, to any person obtaining */
-/* a copy of this software and associated documentation files (the */
-/* "Software"), to deal in the Software without restriction, including */
-/* without limitation the rights to use, copy, modify, merge, publish, */
-/* distribute, sublicense, and/or sell copies of the Software, and to */
-/* permit persons to whom the Software is furnished to do so, subject to */
-/* the following conditions: */
-/* */
-/* The above copyright notice and this permission notice shall be */
-/* included in all copies or substantial portions of the Software. */
-/* */
-/* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, */
-/* EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF */
-/* MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT.*/
-/* IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY */
-/* CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, */
-/* TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE */
-/* SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. */
-/*************************************************************************/
-
-#pragma once
-
-// A faster-than-ostringstream class
-// uses stack_buf as the underlying buffer (upto 256 bytes before using the heap)
-
-#include
-#include
-#include "fast_istostr.h"
-#include "stack_buf.h"
-#include
-
-namespace spdlog
-{
-namespace details
-{
-
-class stack_devicebuf :public std::streambuf
-{
-public:
- static const unsigned short stack_size = 256;
- using stackbuf_t = stack_buf;
-
- stack_devicebuf() = default;
- ~stack_devicebuf() = default;
-
- stack_devicebuf(const stack_devicebuf& other) :std::basic_streambuf(), _stackbuf(other._stackbuf)
- {}
-
- stack_devicebuf(stack_devicebuf&& other):
- std::basic_streambuf(),
- _stackbuf(std::move(other._stackbuf))
- {
- other.clear();
- }
-
- stack_devicebuf& operator=(stack_devicebuf other)
- {
- std::swap(_stackbuf, other._stackbuf);
- return *this;
- }
-
- const stackbuf_t& buf() const
- {
- return _stackbuf;
- }
- std::size_t size() const
- {
- return _stackbuf.size();
- }
-
- void clear()
- {
- _stackbuf.clear();
- }
-
-protected:
- // copy the give buffer into the accumulated fast buffer
- std::streamsize xsputn(const char_type* s, std::streamsize count) override
- {
- _stackbuf.append(s, static_cast(count));
- return count;
- }
-
- int_type overflow(int_type ch) override
- {
- if (traits_type::not_eof(ch))
- {
- char c = traits_type::to_char_type(ch);
- xsputn(&c, 1);
- }
- return ch;
- }
-private:
- stackbuf_t _stackbuf;
-};
-
-
-class fast_oss :public std::ostream
-{
-public:
- fast_oss() :std::ostream(&_dev) {}
- ~fast_oss() = default;
-
- fast_oss(const fast_oss& other) :std::basic_ios(), std::ostream(&_dev), _dev(other._dev)
- {}
-
- fast_oss(fast_oss&& other) :std::basic_ios(), std::ostream(&_dev), _dev(std::move(other._dev))
- {
- other.clear();
- }
-
-
- fast_oss& operator=(fast_oss other)
- {
- swap(*this, other);
- return *this;
- }
-
- void swap(fast_oss& first, fast_oss& second) // nothrow
- {
- using std::swap;
- swap(first._dev, second._dev);
- }
-
- std::string str() const
- {
- auto& buffer = _dev.buf();
- const char*data = buffer.data();
- return std::string(data, data+buffer.size());
- }
-
- const stack_devicebuf::stackbuf_t& buf() const
- {
- return _dev.buf();
- }
-
-
- std::size_t size() const
- {
- return _dev.size();
- }
-
- void clear()
- {
- _dev.clear();
- }
-
- //
- // The following were added because they significantly boost to perfromance
- //
- void putc(char c)
- {
- _dev.sputc(c);
- }
-
- // put int and pad with zeroes if smalled than min_width
- void put_int(int n, size_t padding)
- {
- std::string s;
- details::fast_itostr(n, s, padding);
- _dev.sputn(s.data(), s.size());
- }
-
- void put_data(const char* p, std::size_t data_size)
- {
- _dev.sputn(p, data_size);
- }
-
- void put_str(const std::string& s)
- {
- _dev.sputn(s.data(), s.size());
- }
-
- void put_fast_oss(const fast_oss& oss)
- {
- auto& buffer = oss.buf();
- _dev.sputn(buffer.data(), buffer.size());
- }
-
-
-private:
- stack_devicebuf _dev;
-};
-}
-}
diff --git a/include/spdlog/details/file_helper.h b/include/spdlog/details/file_helper.h
index db2c9da2..ac0ef948 100644
--- a/include/spdlog/details/file_helper.h
+++ b/include/spdlog/details/file_helper.h
@@ -52,7 +52,7 @@ public:
explicit file_helper(bool auto_flush):
_fd(nullptr),
_auto_flush(auto_flush)
- {};
+ {};
file_helper(const file_helper&) = delete;
file_helper& operator=(const file_helper&) = delete;
@@ -99,14 +99,15 @@ public:
void write(const log_msg& msg)
{
- auto& buf = msg.formatted.buf();
- size_t size = buf.size();
- if(std::fwrite(buf.data(), sizeof(char), size, _fd) != size)
+
+ size_t size = msg.formatted.size();
+ auto data = msg.formatted.data();
+ if(std::fwrite(data, 1, size, _fd) != size)
throw spdlog_ex("Failed writing to file " + _filename);
if(_auto_flush)
std::fflush(_fd);
-
+
}
const std::string& filename() const
diff --git a/include/spdlog/details/format.cc b/include/spdlog/details/format.cc
new file mode 100644
index 00000000..bb1c5abf
--- /dev/null
+++ b/include/spdlog/details/format.cc
@@ -0,0 +1,1168 @@
+/*
+
+Modified version of cppformat formatting library
+
+Orginal license:
+
+Copyright (c) 2012 - 2014, Victor Zverovich
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+1. Redistributions of source code must retain the above copyright notice, this
+list of conditions and the following disclaimer.
+2. Redistributions in binary form must reproduce the above copyright notice,
+this list of conditions and the following disclaimer in the documentation
+and/or other materials provided with the distribution.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+(INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+*/
+
+
+
+#include
+
+#include
+#include
+#include
+#include
+#include
+
+#ifdef _WIN32
+# define WIN32_LEAN_AND_MEAN
+# ifdef __MINGW32__
+# include
+# endif
+# include
+#endif
+
+using spdlog::details::fmt::LongLong;
+using spdlog::details::fmt::ULongLong;
+using spdlog::details::fmt::internal::Arg;
+
+// Check if exceptions are disabled.
+#if __GNUC__ && !__EXCEPTIONS
+# define FMT_EXCEPTIONS 0
+#endif
+#if _MSC_VER && !_HAS_EXCEPTIONS
+# define FMT_EXCEPTIONS 0
+#endif
+#ifndef FMT_EXCEPTIONS
+# define FMT_EXCEPTIONS 1
+#endif
+
+#if FMT_EXCEPTIONS
+# define FMT_TRY try
+# define FMT_CATCH(x) catch (x)
+#else
+# define FMT_TRY if (true)
+# define FMT_CATCH(x) if (false)
+#endif
+
+#ifndef FMT_THROW
+# if FMT_EXCEPTIONS
+# define FMT_THROW(x) throw x
+# else
+# define FMT_THROW(x) assert(false)
+# endif
+#endif
+
+#ifdef FMT_HEADER_ONLY
+# define FMT_FUNC inline
+#else
+# define FMT_FUNC
+#endif
+
+#if _MSC_VER
+# pragma warning(push)
+# pragma warning(disable: 4127) // conditional expression is constant
+#endif
+
+namespace {
+
+#ifndef _MSC_VER
+# define FMT_SNPRINTF snprintf
+#else // _MSC_VER
+inline int fmt_snprintf(char *buffer, size_t size, const char *format, ...) {
+ va_list args;
+ va_start(args, format);
+ int result = vsnprintf_s(buffer, size, _TRUNCATE, format, args);
+ va_end(args);
+ return result;
+}
+# define FMT_SNPRINTF fmt_snprintf
+#endif // _MSC_VER
+
+// Checks if a value fits in int - used to avoid warnings about comparing
+// signed and unsigned integers.
+template
+struct IntChecker {
+ template
+ static bool fits_in_int(T value) {
+ unsigned max = INT_MAX;
+ return value <= max;
+ }
+};
+
+template <>
+struct IntChecker {
+ template
+ static bool fits_in_int(T value) {
+ return value >= INT_MIN && value <= INT_MAX;
+ }
+};
+
+const char RESET_COLOR[] = "\x1b[0m";
+
+typedef void(*FormatFunc)(spdlog::details::fmt::Writer &, int, spdlog::details::fmt::StringRef);
+
+// Portable thread-safe version of strerror.
+// Sets buffer to point to a string describing the error code.
+// This can be either a pointer to a string stored in buffer,
+// or a pointer to some static immutable string.
+// Returns one of the following values:
+// 0 - success
+// ERANGE - buffer is not large enough to store the error message
+// other - failure
+// Buffer should be at least of size 1.
+FMT_FUNC int safe_strerror(
+ int error_code, char *&buffer, std::size_t buffer_size) FMT_NOEXCEPT(true) {
+ assert(buffer != 0 && buffer_size != 0);
+ int result = 0;
+#ifdef _GNU_SOURCE
+ char *message = strerror_r(error_code, buffer, buffer_size);
+ // If the buffer is full then the message is probably truncated.
+ if (message == buffer && strlen(buffer) == buffer_size - 1)
+ result = ERANGE;
+ buffer = message;
+#elif __MINGW32__
+ errno = 0;
+ (void)buffer_size;
+ buffer = strerror(error_code);
+ result = errno;
+#elif _WIN32
+ result = strerror_s(buffer, buffer_size, error_code);
+ // If the buffer is full then the message is probably truncated.
+ if (result == 0 && std::strlen(buffer) == buffer_size - 1)
+ result = ERANGE;
+#else
+ result = strerror_r(error_code, buffer, buffer_size);
+ if (result == -1)
+ result = errno; // glibc versions before 2.13 return result in errno.
+#endif
+ return result;
+}
+
+FMT_FUNC void format_error_code(spdlog::details::fmt::Writer &out, int error_code,
+ spdlog::details::fmt::StringRef message) FMT_NOEXCEPT(true) {
+ // Report error code making sure that the output fits into
+ // INLINE_BUFFER_SIZE to avoid dynamic memory allocation and potential
+ // bad_alloc.
+ out.clear();
+ static const char SEP[] = ": ";
+ static const char FMT_ERROR[] = "error ";
+ spdlog::details::fmt::internal::IntTraits::MainType ec_value = error_code;
+ // Subtract 2 to account for terminating null characters in SEP and FMT_ERROR.
+ std::size_t error_code_size =
+ sizeof(SEP) + sizeof(FMT_ERROR) + spdlog::details::fmt::internal::count_digits(ec_value) - 2;
+ if (message.size() <= spdlog::details::fmt::internal::INLINE_BUFFER_SIZE - error_code_size)
+ out << message << SEP;
+ out << FMT_ERROR << error_code;
+ assert(out.size() <= spdlog::details::fmt::internal::INLINE_BUFFER_SIZE);
+}
+
+FMT_FUNC void report_error(FormatFunc func,
+ int error_code, spdlog::details::fmt::StringRef message) FMT_NOEXCEPT(true) {
+ spdlog::details::fmt::MemoryWriter full_message;
+ func(full_message, error_code, message);
+ // Use Writer::data instead of Writer::c_str to avoid potential memory
+ // allocation.
+ std::fwrite(full_message.data(), full_message.size(), 1, stderr);
+ std::fputc('\n', stderr);
+}
+
+// IsZeroInt::visit(arg) returns true iff arg is a zero integer.
+class IsZeroInt : public spdlog::details::fmt::internal::ArgVisitor {
+public:
+ template
+ bool visit_any_int(T value) {
+ return value == 0;
+ }
+};
+
+// Parses an unsigned integer advancing s to the end of the parsed input.
+// This function assumes that the first character of s is a digit.
+template
+FMT_FUNC int parse_nonnegative_int(const Char *&s) {
+ assert('0' <= *s && *s <= '9');
+ unsigned value = 0;
+ do {
+ unsigned new_value = value * 10 + (*s++ - '0');
+ // Check if value wrapped around.
+ if (new_value < value) {
+ value = UINT_MAX;
+ break;
+ }
+ value = new_value;
+ } while ('0' <= *s && *s <= '9');
+ if (value > INT_MAX)
+ FMT_THROW(spdlog::details::fmt::FormatError("number is too big"));
+ return value;
+}
+
+inline void require_numeric_argument(const Arg &arg, char spec) {
+ if (arg.type > Arg::LAST_NUMERIC_TYPE) {
+ std::string message =
+ spdlog::details::fmt::format("format specifier '{}' requires numeric argument", spec);
+ FMT_THROW(spdlog::details::fmt::FormatError(message));
+ }
+}
+
+template
+FMT_FUNC void check_sign(const Char *&s, const Arg &arg) {
+ char sign = static_cast(*s);
+ require_numeric_argument(arg, sign);
+ if (arg.type == Arg::UINT || arg.type == Arg::ULONG_LONG) {
+ FMT_THROW(spdlog::details::fmt::FormatError(spdlog::details::fmt::format(
+ "format specifier '{}' requires signed argument", sign)));
+ }
+ ++s;
+}
+
+// Checks if an argument is a valid printf width specifier and sets
+// left alignment if it is negative.
+class WidthHandler : public spdlog::details::fmt::internal::ArgVisitor {
+private:
+ spdlog::details::fmt::FormatSpec &spec_;
+
+public:
+ explicit WidthHandler(spdlog::details::fmt::FormatSpec &spec) : spec_(spec) {}
+
+ unsigned visit_unhandled_arg() {
+ FMT_THROW(spdlog::details::fmt::FormatError("width is not integer"));
+ return 0;
+ }
+
+ template
+ unsigned visit_any_int(T value) {
+ typedef typename spdlog::details::fmt::internal::IntTraits::MainType UnsignedType;
+ UnsignedType width = value;
+ if (spdlog::details::fmt::internal::is_negative(value)) {
+ spec_.align_ = spdlog::details::fmt::ALIGN_LEFT;
+ width = 0 - width;
+ }
+ if (width > INT_MAX)
+ FMT_THROW(spdlog::details::fmt::FormatError("number is too big"));
+ return static_cast(width);
+ }
+};
+
+class PrecisionHandler :
+ public spdlog::details::fmt::internal::ArgVisitor {
+public:
+ unsigned visit_unhandled_arg() {
+ FMT_THROW(spdlog::details::fmt::FormatError("precision is not integer"));
+ return 0;
+ }
+
+ template
+ int visit_any_int(T value) {
+ if (!IntChecker::is_signed>::fits_in_int(value))
+ FMT_THROW(spdlog::details::fmt::FormatError("number is too big"));
+ return static_cast(value);
+ }
+};
+
+// Converts an integer argument to an integral type T for printf.
+template
+class ArgConverter : public spdlog::details::fmt::internal::ArgVisitor, void> {
+private:
+ spdlog::details::fmt::internal::Arg &arg_;
+ wchar_t type_;
+
+public:
+ ArgConverter(spdlog::details::fmt::internal::Arg &arg, wchar_t type)
+ : arg_(arg), type_(type) {}
+
+ template
+ void visit_any_int(U value) {
+ bool is_signed = type_ == 'd' || type_ == 'i';
+ using spdlog::details::fmt::internal::Arg;
+ if (sizeof(T) <= sizeof(int)) {
+ // Extra casts are used to silence warnings.
+ if (is_signed) {
+ arg_.type = Arg::INT;
+ arg_.int_value = static_cast(static_cast(value));
+ }
+ else {
+ arg_.type = Arg::UINT;
+ arg_.uint_value = static_cast(
+ static_cast::Type>(value));
+ }
+ }
+ else {
+ if (is_signed) {
+ arg_.type = Arg::LONG_LONG;
+ arg_.long_long_value =
+ static_cast::Type>(value);
+ }
+ else {
+ arg_.type = Arg::ULONG_LONG;
+ arg_.ulong_long_value =
+ static_cast::Type>(value);
+ }
+ }
+ }
+};
+
+// Converts an integer argument to char for printf.
+class CharConverter : public spdlog::details::fmt::internal::ArgVisitor {
+private:
+ spdlog::details::fmt::internal::Arg &arg_;
+
+public:
+ explicit CharConverter(spdlog::details::fmt::internal::Arg &arg) : arg_(arg) {}
+
+ template
+ void visit_any_int(T value) {
+ arg_.type = Arg::CHAR;
+ arg_.int_value = static_cast(value);
+ }
+};
+
+// This function template is used to prevent compile errors when handling
+// incompatible string arguments, e.g. handling a wide string in a narrow
+// string formatter.
+template
+Arg::StringValue ignore_incompatible_str(Arg::StringValue);
+
+template <>
+inline Arg::StringValue ignore_incompatible_str(
+ Arg::StringValue) {
+ return Arg::StringValue();
+}
+
+template <>
+inline Arg::StringValue ignore_incompatible_str(
+ Arg::StringValue s) {
+ return s;
+}
+} // namespace
+
+FMT_FUNC void spdlog::details::fmt::SystemError::init(
+ int error_code, StringRef format_str, ArgList args) {
+ error_code_ = error_code;
+ MemoryWriter w;
+ internal::format_system_error(w, error_code, format(format_str, args));
+ std::runtime_error &base = *this;
+ base = std::runtime_error(w.str());
+}
+
+template
+FMT_FUNC int spdlog::details::fmt::internal::CharTraits::format_float(
+ char *buffer, std::size_t size, const char *format,
+ unsigned width, int precision, T value) {
+ if (width == 0) {
+ return precision < 0 ?
+ FMT_SNPRINTF(buffer, size, format, value) :
+ FMT_SNPRINTF(buffer, size, format, precision, value);
+ }
+ return precision < 0 ?
+ FMT_SNPRINTF(buffer, size, format, width, value) :
+ FMT_SNPRINTF(buffer, size, format, width, precision, value);
+}
+
+template
+FMT_FUNC int spdlog::details::fmt::internal::CharTraits::format_float(
+ wchar_t *buffer, std::size_t size, const wchar_t *format,
+ unsigned width, int precision, T value) {
+ if (width == 0) {
+ return precision < 0 ?
+ swprintf(buffer, size, format, value) :
+ swprintf(buffer, size, format, precision, value);
+ }
+ return precision < 0 ?
+ swprintf(buffer, size, format, width, value) :
+ swprintf(buffer, size, format, width, precision, value);
+}
+
+template
+const char spdlog::details::fmt::internal::BasicData::DIGITS[] =
+ "0001020304050607080910111213141516171819"
+ "2021222324252627282930313233343536373839"
+ "4041424344454647484950515253545556575859"
+ "6061626364656667686970717273747576777879"
+ "8081828384858687888990919293949596979899";
+
+#define FMT_POWERS_OF_10(factor) \
+ factor * 10, \
+ factor * 100, \
+ factor * 1000, \
+ factor * 10000, \
+ factor * 100000, \
+ factor * 1000000, \
+ factor * 10000000, \
+ factor * 100000000, \
+ factor * 1000000000
+
+template
+const uint32_t spdlog::details::fmt::internal::BasicData::POWERS_OF_10_32[] = {
+ 0, FMT_POWERS_OF_10(1)
+};
+
+template
+const uint64_t spdlog::details::fmt::internal::BasicData::POWERS_OF_10_64[] = {
+ 0,
+ FMT_POWERS_OF_10(1),
+ FMT_POWERS_OF_10(ULongLong(1000000000)),
+ // Multiply several constants instead of using a single long long constant
+ // to avoid warnings about C++98 not supporting long long.
+ ULongLong(1000000000) * ULongLong(1000000000) * 10
+};
+
+FMT_FUNC void spdlog::details::fmt::internal::report_unknown_type(char code, const char *type) {
+ if (std::isprint(static_cast(code))) {
+ FMT_THROW(spdlog::details::fmt::FormatError(
+ spdlog::details::fmt::format("unknown format code '{}' for {}", code, type)));
+ }
+ FMT_THROW(spdlog::details::fmt::FormatError(
+ spdlog::details::fmt::format("unknown format code '\\x{:02x}' for {}",
+ static_cast(code), type)));
+}
+
+#ifdef _WIN32
+
+FMT_FUNC spdlog::details::fmt::internal::UTF8ToUTF16::UTF8ToUTF16(spdlog::details::fmt::StringRef s) {
+ int length = MultiByteToWideChar(
+ CP_UTF8, MB_ERR_INVALID_CHARS, s.c_str(), -1, 0, 0);
+ static const char FMT_ERROR[] = "cannot convert string from UTF-8 to UTF-16";
+ if (length == 0)
+ FMT_THROW(WindowsError(GetLastError(), FMT_ERROR));
+ buffer_.resize(length);
+ length = MultiByteToWideChar(
+ CP_UTF8, MB_ERR_INVALID_CHARS, s.c_str(), -1, &buffer_[0], length);
+ if (length == 0)
+ FMT_THROW(WindowsError(GetLastError(), FMT_ERROR));
+}
+
+FMT_FUNC spdlog::details::fmt::internal::UTF16ToUTF8::UTF16ToUTF8(spdlog::details::fmt::WStringRef s) {
+ if (int error_code = convert(s)) {
+ FMT_THROW(WindowsError(error_code,
+ "cannot convert string from UTF-16 to UTF-8"));
+ }
+}
+
+FMT_FUNC int spdlog::details::fmt::internal::UTF16ToUTF8::convert(spdlog::details::fmt::WStringRef s) {
+ int length = WideCharToMultiByte(CP_UTF8, 0, s.c_str(), -1, 0, 0, 0, 0);
+ if (length == 0)
+ return GetLastError();
+ buffer_.resize(length);
+ length = WideCharToMultiByte(
+ CP_UTF8, 0, s.c_str(), -1, &buffer_[0], length, 0, 0);
+ if (length == 0)
+ return GetLastError();
+ return 0;
+}
+
+FMT_FUNC void spdlog::details::fmt::WindowsError::init(
+ int error_code, StringRef format_str, ArgList args) {
+ error_code_ = error_code;
+ MemoryWriter w;
+ internal::format_windows_error(w, error_code, format(format_str, args));
+ std::runtime_error &base = *this;
+ base = std::runtime_error(w.str());
+}
+
+#endif
+
+FMT_FUNC void spdlog::details::fmt::internal::format_system_error(
+ spdlog::details::fmt::Writer &out, int error_code,
+ spdlog::details::fmt::StringRef message) FMT_NOEXCEPT(true) {
+ FMT_TRY {
+ MemoryBuffer buffer;
+ buffer.resize(INLINE_BUFFER_SIZE);
+ for (;;) {
+ char *system_message = &buffer[0];
+ int result = safe_strerror(error_code, system_message, buffer.size());
+ if (result == 0) {
+ out << message << ": " << system_message;
+ return;
+ }
+ if (result != ERANGE)
+ break; // Can't get error message, report error code instead.
+ buffer.resize(buffer.size() * 2);
+ }
+ } FMT_CATCH(...) {}
+ format_error_code(out, error_code, message);
+}
+
+#ifdef _WIN32
+FMT_FUNC void spdlog::details::fmt::internal::format_windows_error(
+ spdlog::details::fmt::Writer &out, int error_code,
+ spdlog::details::fmt::StringRef message) FMT_NOEXCEPT(true) {
+ class String {
+ private:
+ LPWSTR str_;
+
+ public:
+ String() : str_() {}
+ ~String() {
+ LocalFree(str_);
+ }
+ LPWSTR *ptr() {
+ return &str_;
+ }
+ LPCWSTR c_str() const {
+ return str_;
+ }
+ };
+ FMT_TRY {
+ String system_message;
+ if (FormatMessageW(FORMAT_MESSAGE_ALLOCATE_BUFFER |
+ FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_IGNORE_INSERTS, 0,
+ error_code, MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT),
+ reinterpret_cast(system_message.ptr()), 0, 0)) {
+ UTF16ToUTF8 utf8_message;
+ if (utf8_message.convert(system_message.c_str()) == ERROR_SUCCESS) {
+ out << message << ": " << utf8_message;
+ return;
+ }
+ }
+ } FMT_CATCH(...) {}
+ format_error_code(out, error_code, message);
+}
+#endif
+
+// An argument formatter.
+template
+class spdlog::details::fmt::internal::ArgFormatter :
+ public spdlog::details::fmt::internal::ArgVisitor, void> {
+private:
+ spdlog::details::fmt::BasicFormatter &formatter_;
+ spdlog::details::fmt::BasicWriter &writer_;
+ spdlog::details::fmt::FormatSpec &spec_;
+ const Char *format_;
+
+public:
+ ArgFormatter(
+ spdlog::details::fmt::BasicFormatter &f, spdlog::details::fmt::FormatSpec &s, const Char *fmt)
+ : formatter_(f), writer_(f.writer()), spec_(s), format_(fmt) {}
+
+ template
+ void visit_any_int(T value) {
+ writer_.write_int(value, spec_);
+ }
+
+ template
+ void visit_any_double(T value) {
+ writer_.write_double(value, spec_);
+ }
+
+ void visit_char(int value) {
+ if (spec_.type_ && spec_.type_ != 'c') {
+ spec_.flags_ |= CHAR_FLAG;
+ writer_.write_int(value, spec_);
+ return;
+ }
+ if (spec_.align_ == ALIGN_NUMERIC || spec_.flags_ != 0)
+ FMT_THROW(FormatError("invalid format specifier for char"));
+ typedef typename spdlog::details::fmt::BasicWriter::CharPtr CharPtr;
+ CharPtr out = CharPtr();
+ if (spec_.width_ > 1) {
+ Char fill = static_cast(spec_.fill());
+ out = writer_.grow_buffer(spec_.width_);
+ if (spec_.align_ == spdlog::details::fmt::ALIGN_RIGHT) {
+ std::fill_n(out, spec_.width_ - 1, fill);
+ out += spec_.width_ - 1;
+ }
+ else if (spec_.align_ == spdlog::details::fmt::ALIGN_CENTER) {
+ out = writer_.fill_padding(out, spec_.width_, 1, fill);
+ }
+ else {
+ std::fill_n(out + 1, spec_.width_ - 1, fill);
+ }
+ }
+ else {
+ out = writer_.grow_buffer(1);
+ }
+ *out = static_cast(value);
+ }
+
+ void visit_string(Arg::StringValue value) {
+ writer_.write_str(value, spec_);
+ }
+ void visit_wstring(Arg::StringValue value) {
+ writer_.write_str(ignore_incompatible_str(value), spec_);
+ }
+
+ void visit_pointer(const void *value) {
+ if (spec_.type_ && spec_.type_ != 'p')
+ spdlog::details::fmt::internal::report_unknown_type(spec_.type_, "pointer");
+ spec_.flags_ = spdlog::details::fmt::HASH_FLAG;
+ spec_.type_ = 'x';
+ writer_.write_int(reinterpret_cast(value), spec_);
+ }
+
+ void visit_custom(Arg::CustomValue c) {
+ c.format(&formatter_, c.value, &format_);
+ }
+};
+
+template
+template
+FMT_FUNC void spdlog::details::fmt::BasicWriter::write_str(
+ const Arg::StringValue &str, const FormatSpec &spec) {
+ // Check if StrChar is convertible to Char.
+ internal::CharTraits::convert(StrChar());
+ if (spec.type_ && spec.type_ != 's')
+ internal::report_unknown_type(spec.type_, "string");
+ const StrChar *s = str.value;
+ std::size_t size = str.size;
+ if (size == 0) {
+ if (!s)
+ FMT_THROW(FormatError("string pointer is null"));
+ if (*s)
+ size = std::char_traits::length(s);
+ }
+ write_str(s, size, spec);
+}
+
+template
+inline Arg spdlog::details::fmt::BasicFormatter::parse_arg_index(const Char *&s) {
+ const char *error = 0;
+ Arg arg = *s < '0' || *s > '9' ?
+ next_arg(error) : get_arg(parse_nonnegative_int(s), error);
+ if (error) {
+ FMT_THROW(FormatError(
+ *s != '}' && *s != ':' ? "invalid format string" : error));
+ }
+ return arg;
+}
+
+FMT_FUNC Arg spdlog::details::fmt::internal::FormatterBase::do_get_arg(
+ unsigned arg_index, const char *&error) {
+ Arg arg = args_[arg_index];
+ if (arg.type == Arg::NONE)
+ error = "argument index out of range";
+ return arg;
+}
+
+inline Arg spdlog::details::fmt::internal::FormatterBase::next_arg(const char *&error) {
+ if (next_arg_index_ >= 0)
+ return do_get_arg(next_arg_index_++, error);
+ error = "cannot switch from manual to automatic argument indexing";
+ return Arg();
+}
+
+inline Arg spdlog::details::fmt::internal::FormatterBase::get_arg(
+ unsigned arg_index, const char *&error) {
+ if (next_arg_index_ <= 0) {
+ next_arg_index_ = -1;
+ return do_get_arg(arg_index, error);
+ }
+ error = "cannot switch from automatic to manual argument indexing";
+ return Arg();
+}
+
+template
+FMT_FUNC void spdlog::details::fmt::internal::PrintfFormatter::parse_flags(
+ FormatSpec &spec, const Char *&s) {
+ for (;;) {
+ switch (*s++) {
+ case '-':
+ spec.align_ = ALIGN_LEFT;
+ break;
+ case '+':
+ spec.flags_ |= SIGN_FLAG | PLUS_FLAG;
+ break;
+ case '0':
+ spec.fill_ = '0';
+ break;
+ case ' ':
+ spec.flags_ |= SIGN_FLAG;
+ break;
+ case '#':
+ spec.flags_ |= HASH_FLAG;
+ break;
+ default:
+ --s;
+ return;
+ }
+ }
+}
+
+template
+FMT_FUNC Arg spdlog::details::fmt::internal::PrintfFormatter::get_arg(
+ const Char *s, unsigned arg_index) {
+ const char *error = 0;
+ Arg arg = arg_index == UINT_MAX ?
+ next_arg(error) : FormatterBase::get_arg(arg_index - 1, error);
+ if (error)
+ FMT_THROW(FormatError(!*s ? "invalid format string" : error));
+ return arg;
+}
+
+template
+FMT_FUNC unsigned spdlog::details::fmt::internal::PrintfFormatter::parse_header(
+ const Char *&s, FormatSpec &spec) {
+ unsigned arg_index = UINT_MAX;
+ Char c = *s;
+ if (c >= '0' && c <= '9') {
+ // Parse an argument index (if followed by '$') or a width possibly
+ // preceded with '0' flag(s).
+ unsigned value = parse_nonnegative_int(s);
+ if (*s == '$') { // value is an argument index
+ ++s;
+ arg_index = value;
+ }
+ else {
+ if (c == '0')
+ spec.fill_ = '0';
+ if (value != 0) {
+ // Nonzero value means that we parsed width and don't need to
+ // parse it or flags again, so return now.
+ spec.width_ = value;
+ return arg_index;
+ }
+ }
+ }
+ parse_flags(spec, s);
+ // Parse width.
+ if (*s >= '0' && *s <= '9') {
+ spec.width_ = parse_nonnegative_int(s);
+ }
+ else if (*s == '*') {
+ ++s;
+ spec.width_ = WidthHandler(spec).visit(get_arg(s));
+ }
+ return arg_index;
+}
+
+template
+FMT_FUNC void spdlog::details::fmt::internal::PrintfFormatter::format(
+ BasicWriter &writer, BasicStringRef format,
+ const ArgList &args) {
+ const Char *start = format.c_str();
+ set_args(args);
+ const Char *s = start;
+ while (*s) {
+ Char c = *s++;
+ if (c != '%') continue;
+ if (*s == c) {
+ write(writer, start, s);
+ start = ++s;
+ continue;
+ }
+ write(writer, start, s - 1);
+
+ FormatSpec spec;
+ spec.align_ = ALIGN_RIGHT;
+
+ // Parse argument index, flags and width.
+ unsigned arg_index = parse_header(s, spec);
+
+ // Parse precision.
+ if (*s == '.') {
+ ++s;
+ if ('0' <= *s && *s <= '9') {
+ spec.precision_ = parse_nonnegative_int(s);
+ }
+ else if (*s == '*') {
+ ++s;
+ spec.precision_ = PrecisionHandler().visit(get_arg(s));
+ }
+ }
+
+ Arg arg = get_arg(s, arg_index);
+ if (spec.flag(HASH_FLAG) && IsZeroInt().visit(arg))
+ spec.flags_ &= ~HASH_FLAG;
+ if (spec.fill_ == '0') {
+ if (arg.type <= Arg::LAST_NUMERIC_TYPE)
+ spec.align_ = ALIGN_NUMERIC;
+ else
+ spec.fill_ = ' '; // Ignore '0' flag for non-numeric types.
+ }
+
+ // Parse length and convert the argument to the required type.
+ switch (*s++) {
+ case 'h':
+ if (*s == 'h')
+ ArgConverter(arg, *++s).visit(arg);
+ else
+ ArgConverter(arg, *s).visit(arg);
+ break;
+ case 'l':
+ if (*s == 'l')
+ ArgConverter(arg, *++s).visit(arg);
+ else
+ ArgConverter(arg, *s).visit(arg);
+ break;
+ case 'j':
+ ArgConverter(arg, *s).visit(arg);
+ break;
+ case 'z':
+ ArgConverter(arg, *s).visit(arg);
+ break;
+ case 't':
+ ArgConverter(arg, *s).visit(arg);
+ break;
+ case 'L':
+ // printf produces garbage when 'L' is omitted for long double, no
+ // need to do the same.
+ break;
+ default:
+ --s;
+ ArgConverter(arg, *s).visit(arg);
+ }
+
+ // Parse type.
+ if (!*s)
+ FMT_THROW(FormatError("invalid format string"));
+ spec.type_ = static_cast(*s++);
+ if (arg.type <= Arg::LAST_INTEGER_TYPE) {
+ // Normalize type.
+ switch (spec.type_) {
+ case 'i':
+ case 'u':
+ spec.type_ = 'd';
+ break;
+ case 'c':
+ // TODO: handle wchar_t
+ CharConverter(arg).visit(arg);
+ break;
+ }
+ }
+
+ start = s;
+
+ // Format argument.
+ switch (arg.type) {
+ case Arg::INT:
+ writer.write_int(arg.int_value, spec);
+ break;
+ case Arg::UINT:
+ writer.write_int(arg.uint_value, spec);
+ break;
+ case Arg::LONG_LONG:
+ writer.write_int(arg.long_long_value, spec);
+ break;
+ case Arg::ULONG_LONG:
+ writer.write_int(arg.ulong_long_value, spec);
+ break;
+ case Arg::CHAR: {
+ if (spec.type_ && spec.type_ != 'c')
+ writer.write_int(arg.int_value, spec);
+ typedef typename BasicWriter::CharPtr CharPtr;
+ CharPtr out = CharPtr();
+ if (spec.width_ > 1) {
+ Char fill = ' ';
+ out = writer.grow_buffer(spec.width_);
+ if (spec.align_ != ALIGN_LEFT) {
+ std::fill_n(out, spec.width_ - 1, fill);
+ out += spec.width_ - 1;
+ }
+ else {
+ std::fill_n(out + 1, spec.width_ - 1, fill);
+ }
+ }
+ else {
+ out = writer.grow_buffer(1);
+ }
+ *out = static_cast(arg.int_value);
+ break;
+ }
+ case Arg::DOUBLE:
+ writer.write_double(arg.double_value, spec);
+ break;
+ case Arg::LONG_DOUBLE:
+ writer.write_double(arg.long_double_value, spec);
+ break;
+ case Arg::CSTRING:
+ arg.string.size = 0;
+ writer.write_str(arg.string, spec);
+ break;
+ case Arg::STRING:
+ writer.write_str(arg.string, spec);
+ break;
+ case Arg::WSTRING:
+ writer.write_str(ignore_incompatible_str(arg.wstring), spec);
+ break;
+ case Arg::POINTER:
+ if (spec.type_ && spec.type_ != 'p')
+ internal::report_unknown_type(spec.type_, "pointer");
+ spec.flags_ = HASH_FLAG;
+ spec.type_ = 'x';
+ writer.write_int(reinterpret_cast(arg.pointer), spec);
+ break;
+ case Arg::CUSTOM: {
+ if (spec.type_)
+ internal::report_unknown_type(spec.type_, "object");
+ const void *s = "s";
+ arg.custom.format(&writer, arg.custom.value, &s);
+ break;
+ }
+ default:
+ assert(false);
+ break;
+ }
+ }
+ write(writer, start, s);
+}
+
+template
+FMT_FUNC const Char *spdlog::details::fmt::BasicFormatter::format(
+ const Char *&format_str, const Arg &arg) {
+ const Char *s = format_str;
+ FormatSpec spec;
+ if (*s == ':') {
+ if (arg.type == Arg::CUSTOM) {
+ arg.custom.format(this, arg.custom.value, &s);
+ return s;
+ }
+ ++s;
+ // Parse fill and alignment.
+ if (Char c = *s) {
+ const Char *p = s + 1;
+ spec.align_ = ALIGN_DEFAULT;
+ do {
+ switch (*p) {
+ case '<':
+ spec.align_ = ALIGN_LEFT;
+ break;
+ case '>':
+ spec.align_ = ALIGN_RIGHT;
+ break;
+ case '=':
+ spec.align_ = ALIGN_NUMERIC;
+ break;
+ case '^':
+ spec.align_ = ALIGN_CENTER;
+ break;
+ }
+ if (spec.align_ != ALIGN_DEFAULT) {
+ if (p != s) {
+ if (c == '}') break;
+ if (c == '{')
+ FMT_THROW(FormatError("invalid fill character '{'"));
+ s += 2;
+ spec.fill_ = c;
+ }
+ else ++s;
+ if (spec.align_ == ALIGN_NUMERIC)
+ require_numeric_argument(arg, '=');
+ break;
+ }
+ } while (--p >= s);
+ }
+
+ // Parse sign.
+ switch (*s) {
+ case '+':
+ check_sign(s, arg);
+ spec.flags_ |= SIGN_FLAG | PLUS_FLAG;
+ break;
+ case '-':
+ check_sign(s, arg);
+ spec.flags_ |= MINUS_FLAG;
+ break;
+ case ' ':
+ check_sign(s, arg);
+ spec.flags_ |= SIGN_FLAG;
+ break;
+ }
+
+ if (*s == '#') {
+ require_numeric_argument(arg, '#');
+ spec.flags_ |= HASH_FLAG;
+ ++s;
+ }
+
+ // Parse width and zero flag.
+ if ('0' <= *s && *s <= '9') {
+ if (*s == '0') {
+ require_numeric_argument(arg, '0');
+ spec.align_ = ALIGN_NUMERIC;
+ spec.fill_ = '0';
+ }
+ // Zero may be parsed again as a part of the width, but it is simpler
+ // and more efficient than checking if the next char is a digit.
+ spec.width_ = parse_nonnegative_int(s);
+ }
+
+ // Parse precision.
+ if (*s == '.') {
+ ++s;
+ spec.precision_ = 0;
+ if ('0' <= *s && *s <= '9') {
+ spec.precision_ = parse_nonnegative_int(s);
+ }
+ else if (*s == '{') {
+ ++s;
+ const Arg &precision_arg = parse_arg_index(s);
+ if (*s++ != '}')
+ FMT_THROW(FormatError("invalid format string"));
+ ULongLong value = 0;
+ switch (precision_arg.type) {
+ case Arg::INT:
+ if (precision_arg.int_value < 0)
+ FMT_THROW(FormatError("negative precision"));
+ value = precision_arg.int_value;
+ break;
+ case Arg::UINT:
+ value = precision_arg.uint_value;
+ break;
+ case Arg::LONG_LONG:
+ if (precision_arg.long_long_value < 0)
+ FMT_THROW(FormatError("negative precision"));
+ value = precision_arg.long_long_value;
+ break;
+ case Arg::ULONG_LONG:
+ value = precision_arg.ulong_long_value;
+ break;
+ default:
+ FMT_THROW(FormatError("precision is not integer"));
+ }
+ if (value > INT_MAX)
+ FMT_THROW(FormatError("number is too big"));
+ spec.precision_ = static_cast(value);
+ }
+ else {
+ FMT_THROW(FormatError("missing precision specifier"));
+ }
+ if (arg.type != Arg::DOUBLE && arg.type != Arg::LONG_DOUBLE) {
+ FMT_THROW(FormatError(
+ "precision specifier requires floating-point argument"));
+ }
+ }
+
+ // Parse type.
+ if (*s != '}' && *s)
+ spec.type_ = static_cast(*s++);
+ }
+
+ if (*s++ != '}')
+ FMT_THROW(FormatError("missing '}' in format string"));
+ start_ = s;
+
+ // Format argument.
+ internal::ArgFormatter(*this, spec, s - 1).visit(arg);
+ return s;
+}
+
+template
+FMT_FUNC void spdlog::details::fmt::BasicFormatter::format(
+ BasicStringRef format_str, const ArgList &args) {
+ const Char *s = start_ = format_str.c_str();
+ set_args(args);
+ while (*s) {
+ Char c = *s++;
+ if (c != '{' && c != '}') continue;
+ if (*s == c) {
+ write(writer_, start_, s);
+ start_ = ++s;
+ continue;
+ }
+ if (c == '}')
+ FMT_THROW(FormatError("unmatched '}' in format string"));
+ write(writer_, start_, s - 1);
+ Arg arg = parse_arg_index(s);
+ s = format(s, arg);
+ }
+ write(writer_, start_, s);
+}
+
+FMT_FUNC void spdlog::details::fmt::report_system_error(
+ int error_code, spdlog::details::fmt::StringRef message) FMT_NOEXCEPT(true) {
+ report_error(internal::format_system_error, error_code, message);
+}
+
+#ifdef _WIN32
+FMT_FUNC void spdlog::details::fmt::report_windows_error(
+ int error_code, spdlog::details::fmt::StringRef message) FMT_NOEXCEPT(true) {
+ report_error(internal::format_windows_error, error_code, message);
+}
+#endif
+
+FMT_FUNC void spdlog::details::fmt::print(std::FILE *f, StringRef format_str, ArgList args) {
+ MemoryWriter w;
+ w.write(format_str, args);
+ std::fwrite(w.data(), 1, w.size(), f);
+}
+
+FMT_FUNC void spdlog::details::fmt::print(StringRef format_str, ArgList args) {
+ print(stdout, format_str, args);
+}
+
+FMT_FUNC void spdlog::details::fmt::print(std::ostream &os, StringRef format_str, ArgList args) {
+ MemoryWriter w;
+ w.write(format_str, args);
+ os.write(w.data(), w.size());
+}
+
+FMT_FUNC void spdlog::details::fmt::print_colored(Color c, StringRef format, ArgList args) {
+ char escape[] = "\x1b[30m";
+ escape[3] = '0' + static_cast(c);
+ std::fputs(escape, stdout);
+ print(format, args);
+ std::fputs(RESET_COLOR, stdout);
+}
+
+FMT_FUNC int spdlog::details::fmt::fprintf(std::FILE *f, StringRef format, ArgList args) {
+ MemoryWriter w;
+ printf(w, format, args);
+ std::size_t size = w.size();
+ return std::fwrite(w.data(), 1, size, f) < size ? -1 : static_cast(size);
+}
+
+// Explicit instantiations for char.
+
+template const char *spdlog::details::fmt::BasicFormatter::format(
+ const char *&format_str, const spdlog::details::fmt::internal::Arg &arg);
+
+template void spdlog::details::fmt::BasicFormatter::format(
+ BasicStringRef format, const ArgList &args);
+
+template void spdlog::details::fmt::internal::PrintfFormatter::format(
+ BasicWriter &writer, BasicStringRef format, const ArgList &args);
+
+template int spdlog::details::fmt::internal::CharTraits::format_float(
+ char *buffer, std::size_t size, const char *format,
+ unsigned width, int precision, double value);
+
+template int spdlog::details::fmt::internal::CharTraits::format_float(
+ char *buffer, std::size_t size, const char *format,
+ unsigned width, int precision, long double value);
+
+// Explicit instantiations for wchar_t.
+
+template const wchar_t *spdlog::details::fmt::BasicFormatter::format(
+ const wchar_t *&format_str, const spdlog::details::fmt::internal::Arg &arg);
+
+template void spdlog::details::fmt::BasicFormatter::format(
+ BasicStringRef format, const ArgList &args);
+
+template void spdlog::details::fmt::internal::PrintfFormatter::format(
+ BasicWriter &writer, BasicStringRef format,
+ const ArgList &args);
+
+template int spdlog::details::fmt::internal::CharTraits::format_float(
+ wchar_t *buffer, std::size_t size, const wchar_t *format,
+ unsigned width, int precision, double value);
+
+template int spdlog::details::fmt::internal::CharTraits::format_float(
+ wchar_t *buffer, std::size_t size, const wchar_t *format,
+ unsigned width, int precision, long double value);
+
+#if _MSC_VER
+# pragma warning(pop)
+#endif
\ No newline at end of file
diff --git a/include/spdlog/details/format.h b/include/spdlog/details/format.h
new file mode 100644
index 00000000..337b4ab8
--- /dev/null
+++ b/include/spdlog/details/format.h
@@ -0,0 +1,2882 @@
+/*
+Formatting library for C++
+
+Copyright (c) 2012 - 2014, Victor Zverovich
+All rights reserved.
+
+Redistribution and use in source and binary forms, with or without
+modification, are permitted provided that the following conditions are met:
+
+1. Redistributions of source code must retain the above copyright notice, this
+list of conditions and the following disclaimer.
+2. Redistributions in binary form must reproduce the above copyright notice,
+this list of conditions and the following disclaimer in the documentation
+and/or other materials provided with the distribution.
+
+THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
+ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR
+ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+(INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+(INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+*/
+
+#ifndef FMT_FORMAT_H_
+#define FMT_FORMAT_H_
+
+#include
+
+#include
+#include
+#include // for std::ptrdiff_t
+#include
+#include
+#include
+#include
+#include
+#include
+
+#if _SECURE_SCL
+# include
+#endif
+
+#ifdef __GNUC__
+// Ignore shadow warnings
+# pragma GCC diagnostic push
+# pragma GCC diagnostic ignored "-Wshadow"
+
+# define FMT_GCC_VERSION (__GNUC__ * 100 + __GNUC_MINOR__)
+# define FMT_GCC_EXTENSION __extension__
+// Disable warning about "long long" which is sometimes reported even
+// when using __extension__.
+# if FMT_GCC_VERSION >= 406
+# pragma GCC diagnostic push
+# pragma GCC diagnostic ignored "-Wlong-long"
+# endif
+#else
+# define FMT_GCC_EXTENSION
+#endif
+
+#ifdef __GNUC_LIBSTD__
+# define FMT_GNUC_LIBSTD_VERSION (__GNUC_LIBSTD__ * 100 + __GNUC_LIBSTD_MINOR__)
+#endif
+
+#ifdef __has_feature
+# define FMT_HAS_FEATURE(x) __has_feature(x)
+#else
+# define FMT_HAS_FEATURE(x) 0
+#endif
+
+#ifdef __has_builtin
+# define FMT_HAS_BUILTIN(x) __has_builtin(x)
+#else
+# define FMT_HAS_BUILTIN(x) 0
+#endif
+
+#ifndef FMT_USE_VARIADIC_TEMPLATES
+// Variadic templates are available in GCC since version 4.4
+// (http://gcc.gnu.org/projects/cxx0x.html) and in Visual C++
+// since version 2013.
+# define FMT_USE_VARIADIC_TEMPLATES \
+ (FMT_HAS_FEATURE(cxx_variadic_templates) || \
+ (FMT_GCC_VERSION >= 404 && __cplusplus >= 201103) || _MSC_VER >= 1800)
+#endif
+
+#ifndef FMT_USE_RVALUE_REFERENCES
+// Don't use rvalue references when compiling with clang and an old libstdc++
+// as the latter doesn't provide std::move.
+# if defined(FMT_GNUC_LIBSTD_VERSION) && FMT_GNUC_LIBSTD_VERSION <= 402
+# define FMT_USE_RVALUE_REFERENCES 0
+# else
+# define FMT_USE_RVALUE_REFERENCES \
+ (FMT_HAS_FEATURE(cxx_rvalue_references) || \
+ (FMT_GCC_VERSION >= 403 && __cplusplus >= 201103) || _MSC_VER >= 1600)
+# endif
+#endif
+
+#if FMT_USE_RVALUE_REFERENCES
+# include // for std::move
+#endif
+
+// Define FMT_USE_NOEXCEPT to make C++ Format use noexcept (C++11 feature).
+#if FMT_USE_NOEXCEPT || FMT_HAS_FEATURE(cxx_noexcept) || \
+ (FMT_GCC_VERSION >= 408 && __cplusplus >= 201103)
+# define FMT_NOEXCEPT(expr) noexcept(expr)
+#else
+# define FMT_NOEXCEPT(expr)
+#endif
+
+// A macro to disallow the copy constructor and operator= functions
+// This should be used in the private: declarations for a class
+#define FMT_DISALLOW_COPY_AND_ASSIGN(TypeName) \
+ TypeName(const TypeName&); \
+ void operator=(const TypeName&)
+namespace spdlog {
+namespace details {
+namespace fmt
+{
+
+// Fix the warning about long long on older versions of GCC
+// that don't support the diagnostic pragma.
+FMT_GCC_EXTENSION typedef long long LongLong;
+FMT_GCC_EXTENSION typedef unsigned long long ULongLong;
+
+#if FMT_USE_RVALUE_REFERENCES
+using std::move;
+#endif
+
+template
+class BasicWriter;
+
+typedef BasicWriter Writer;
+typedef BasicWriter WWriter;
+
+template
+class BasicFormatter;
+
+template
+void format(BasicFormatter &f, const Char *&format_str, const T &value);
+
+/**
+\rst
+A string reference. It can be constructed from a C string or
+``std::string``.
+
+You can use one of the following typedefs for common character types:
+
++------------+-------------------------+
+| Type | Definition |
++============+=========================+
+| StringRef | BasicStringRef |
++------------+-------------------------+
+| WStringRef | BasicStringRef |
++------------+-------------------------+
+
+This class is most useful as a parameter type to allow passing
+different types of strings to a function, for example::
+
+template
+std::string format(StringRef format, const Args & ... args);
+
+format("{}", 42);
+format(std::string("{}"), 42);
+\endrst
+*/
+template
+class BasicStringRef
+{
+private:
+ const Char *data_;
+ std::size_t size_;
+
+public:
+ /**
+ Constructs a string reference object from a C string and a size.
+ */
+ BasicStringRef(const Char *s, std::size_t size) : data_(s), size_(size) {}
+
+ /**
+ Constructs a string reference object from a C string computing
+ the size with ``std::char_traits::length``.
+ */
+ BasicStringRef(const Char *s)
+ : data_(s), size_(std::char_traits::length(s)) {}
+
+ /**
+ Constructs a string reference from an `std::string` object.
+ */
+ BasicStringRef(const std::basic_string &s)
+ : data_(s.c_str()), size_(s.size()) {}
+
+ /**
+ Converts a string reference to an `std::string` object.
+ */
+ operator std::basic_string() const
+ {
+ return std::basic_string(data_, size());
+ }
+
+ /**
+ Returns the pointer to a C string.
+ */
+ const Char *c_str() const
+ {
+ return data_;
+ }
+
+ /**
+ Returns the string size.
+ */
+ std::size_t size() const
+ {
+ return size_;
+ }
+
+ friend bool operator==(BasicStringRef lhs, BasicStringRef rhs)
+ {
+ return lhs.data_ == rhs.data_;
+ }
+ friend bool operator!=(BasicStringRef lhs, BasicStringRef rhs)
+ {
+ return lhs.data_ != rhs.data_;
+ }
+};
+
+typedef BasicStringRef StringRef;
+typedef BasicStringRef WStringRef;
+
+/**
+A formatting error such as invalid format string.
+*/
+class FormatError : public std::runtime_error
+{
+public:
+ explicit FormatError(StringRef message)
+ : std::runtime_error(message.c_str()) {}
+};
+
+namespace internal
+{
+
+// The number of characters to store in the MemoryBuffer object itself
+// to avoid dynamic memory allocation.
+enum { INLINE_BUFFER_SIZE = 500 };
+
+#if _SECURE_SCL
+// Use checked iterator to avoid warnings on MSVC.
+template
+inline stdext::checked_array_iterator make_ptr(T *ptr, std::size_t size)
+{
+ return stdext::checked_array_iterator(ptr, size);
+}
+#else
+template
+inline T *make_ptr(T *ptr, std::size_t)
+{
+ return ptr;
+}
+#endif
+
+// A buffer for POD types. It supports a subset of std::vector's operations.
+template
+class Buffer
+{
+private:
+ FMT_DISALLOW_COPY_AND_ASSIGN(Buffer);
+
+protected:
+ T *ptr_;
+ std::size_t size_;
+ std::size_t capacity_;
+
+ Buffer(T *ptr = 0, std::size_t capacity = 0)
+ : ptr_(ptr), size_(0), capacity_(capacity) {}
+
+ virtual void grow(std::size_t size) = 0;
+
+public:
+ virtual ~Buffer() {}
+
+ // Returns the size of this buffer.
+ std::size_t size() const
+ {
+ return size_;
+ }
+
+ // Returns the capacity of this buffer.
+ std::size_t capacity() const
+ {
+ return capacity_;
+ }
+
+ // Resizes the buffer. If T is a POD type new elements are not initialized.
+ void resize(std::size_t new_size)
+ {
+ if (new_size > capacity_)
+ grow(new_size);
+ size_ = new_size;
+ }
+
+ // Reserves space to store at least capacity elements.
+ void reserve(std::size_t capacity)
+ {
+ if (capacity > capacity_)
+ grow(capacity);
+ }
+
+ void clear() FMT_NOEXCEPT(true)
+ {
+ size_ = 0;
+ }
+
+ void push_back(const T &value)
+ {
+ if (size_ == capacity_)
+ grow(size_ + 1);
+ ptr_[size_++] = value;
+ }
+
+ // Appends data to the end of the buffer.
+ void append(const T *begin, const T *end);
+
+ T &operator[](std::size_t index)
+ {
+ return ptr_[index];
+ }
+ const T &operator[](std::size_t index) const
+ {
+ return ptr_[index];
+ }
+};
+
+template
+void Buffer::append(const T *begin, const T *end)
+{
+ std::ptrdiff_t num_elements = end - begin;
+ if (size_ + num_elements > capacity_)
+ grow(size_ + num_elements);
+ std::copy(begin, end, make_ptr(ptr_, capacity_) + size_);
+ size_ += num_elements;
+}
+
+// A memory buffer for POD types with the first SIZE elements stored in
+// the object itself.
+template >
+class MemoryBuffer : private Allocator, public Buffer
+{
+private:
+ T data_[SIZE];
+
+ // Free memory allocated by the buffer.
+ void free()
+ {
+ if (this->ptr_ != data_) this->deallocate(this->ptr_, this->capacity_);
+ }
+
+protected:
+ void grow(std::size_t size);
+
+public:
+ explicit MemoryBuffer(const Allocator &alloc = Allocator())
+ : Allocator(alloc), Buffer(data_, SIZE) {}
+ ~MemoryBuffer()
+ {
+ free();
+ }
+
+#if FMT_USE_RVALUE_REFERENCES
+private:
+ // Move data from other to this buffer.
+ void move(MemoryBuffer &other)
+ {
+ Allocator &this_alloc = *this, &other_alloc = other;
+ this_alloc = std::move(other_alloc);
+ this->size_ = other.size_;
+ this->capacity_ = other.capacity_;
+ if (other.ptr_ == other.data_)
+ {
+ this->ptr_ = data_;
+ std::copy(other.data_,
+ other.data_ + this->size_, make_ptr(data_, this->capacity_));
+ }
+ else
+ {
+ this->ptr_ = other.ptr_;
+ // Set pointer to the inline array so that delete is not called
+ // when freeing.
+ other.ptr_ = other.data_;
+ }
+ }
+
+public:
+ MemoryBuffer(MemoryBuffer &&other)
+ {
+ move(other);
+ }
+
+ MemoryBuffer &operator=(MemoryBuffer &&other)
+ {
+ assert(this != &other);
+ free();
+ move(other);
+ return *this;
+ }
+#endif
+
+ // Returns a copy of the allocator associated with this buffer.
+ Allocator get_allocator() const
+ {
+ return *this;
+ }
+};
+
+template
+void MemoryBuffer::grow(std::size_t size)
+{
+ std::size_t new_capacity =
+ (std::max)(size, this->capacity_ + this->capacity_ / 2);
+ T *new_ptr = this->allocate(new_capacity);
+ // The following code doesn't throw, so the raw pointer above doesn't leak.
+ std::copy(this->ptr_,
+ this->ptr_ + this->size_, make_ptr(new_ptr, new_capacity));
+ std::size_t old_capacity = this->capacity_;
+ T *old_ptr = this->ptr_;
+ this->capacity_ = new_capacity;
+ this->ptr_ = new_ptr;
+ // deallocate may throw (at least in principle), but it doesn't matter since
+ // the buffer already uses the new storage and will deallocate it in case
+ // of exception.
+ if (old_ptr != data_)
+ this->deallocate(old_ptr, old_capacity);
+}
+
+#ifndef _MSC_VER
+// Portable version of signbit.
+inline int getsign(double x)
+{
+ // When compiled in C++11 mode signbit is no longer a macro but a function
+ // defined in namespace std and the macro is undefined.
+# ifdef signbit
+ return signbit(x);
+# else
+ return std::signbit(x);
+# endif
+}
+
+// Portable version of isinf.
+# ifdef isinf
+inline int isinfinity(double x)
+{
+ return isinf(x);
+}
+inline int isinfinity(long double x)
+{
+ return isinf(x);
+}
+# else
+inline int isinfinity(double x)
+{
+ return std::isinf(x);
+}
+inline int isinfinity(long double x)
+{
+ return std::isinf(x);
+}
+# endif
+#else
+inline int getsign(double value)
+{
+ if (value < 0) return 1;
+ if (value == value) return 0;
+ int dec = 0, sign = 0;
+ char buffer[2]; // The buffer size must be >= 2 or _ecvt_s will fail.
+ _ecvt_s(buffer, sizeof(buffer), value, 0, &dec, &sign);
+ return sign;
+}
+inline int isinfinity(double x)
+{
+ return !_finite(x);
+}
+#endif
+
+template
+struct IsLongDouble
+{
+ enum { VALUE = 0 };
+};
+
+template <>
+struct IsLongDouble
+{
+ enum { VALUE = 1 };
+};
+
+template
+class BasicCharTraits
+{
+public:
+#if _SECURE_SCL
+ typedef stdext::checked_array_iterator CharPtr;
+#else
+ typedef Char *CharPtr;
+#endif
+};
+
+template
+class CharTraits;
+
+template <>
+class CharTraits : public BasicCharTraits
+{
+private:
+ // Conversion from wchar_t to char is not allowed.
+ static char convert(wchar_t);
+
+public:
+ typedef const wchar_t *UnsupportedStrType;
+
+ static char convert(char value)
+ {
+ return value;
+ }
+
+ // Formats a floating-point number.
+ template
+ static int format_float(char *buffer, std::size_t size,
+ const char *format, unsigned width, int precision, T value);
+};
+
+template <>
+class CharTraits : public BasicCharTraits
+{
+public:
+ typedef const char *UnsupportedStrType;
+
+ static wchar_t convert(char value)
+ {
+ return value;
+ }
+ static wchar_t convert(wchar_t value)
+ {
+ return value;
+ }
+
+ template
+ static int format_float(wchar_t *buffer, std::size_t size,
+ const wchar_t *format, unsigned width, int precision, T value);
+};
+
+// Checks if a number is negative - used to avoid warnings.
+template
+struct SignChecker
+{
+ template
+ static bool is_negative(T value)
+ {
+ return value < 0;
+ }
+};
+
+template <>
+struct SignChecker
+{
+ template
+ static bool is_negative(T)
+ {
+ return false;
+ }
+};
+
+// Returns true if value is negative, false otherwise.
+// Same as (value < 0) but doesn't produce warnings if T is an unsigned type.
+template
+inline bool is_negative(T value)
+{
+ return SignChecker::is_signed>::is_negative(value);
+}
+
+// Selects uint32_t if FitsIn32Bits is true, uint64_t otherwise.
+template
+struct TypeSelector
+{
+ typedef uint32_t Type;
+};
+
+template <>
+struct TypeSelector
+{
+ typedef uint64_t Type;
+};
+
+template
+struct IntTraits
+{
+ // Smallest of uint32_t and uint64_t that is large enough to represent
+ // all values of T.
+ typedef typename
+ TypeSelector