pattern_formatter support most strftime format

This commit is contained in:
gabi 2014-10-19 02:54:45 +03:00
parent 0c6a0d52d7
commit 32a8b51d05
13 changed files with 268 additions and 53 deletions

View File

@ -17,16 +17,18 @@ int main(int argc, char* argv[])
{ {
const unsigned int howmany = argc <= 1 ? 500000 : atoi(argv[1]); const unsigned int howmany = argc <= 1 ? 500000 : atoi(argv[1]);
//std::string pattern = "%Y:%m:%d %H:%M:%S.%e ---> [%n:%l] %t"; //std::string pattern = "%B %d, %Y %H:%M:%S.%e **************[%n:%l] %t";
//auto formatter = std::make_shared<details::pattern_formatter>(pattern); std::string pattern = " [%z] %t";
auto formatter = std::make_shared<details::pattern_formatter>(pattern);
logger cout_logger("bench", { std::make_shared<sinks::stderr_sink_mt>() }); logger cout_logger("bench", { std::make_shared<sinks::stderr_sink_mt>() });
cout_logger.formatter(formatter);
cout_logger.info() << "Hello logger " << 1234; cout_logger.info() << "Hello logger " << 1234;
auto nullsink = std::make_shared<sinks::null_sink_st>(); auto nullsink = std::make_shared<sinks::null_sink_st>();
auto rotating = std::make_shared<sinks::rotating_file_sink_mt>("myrotating", "txt", 1024 * 1024 * 5, 5, 1); auto rotating = std::make_shared<sinks::rotating_file_sink_mt>("myrotating", "txt", 1024 * 1024 * 5, 5, 100);
logger my_logger("my_logger", { rotating }); logger my_logger("my_logger", { nullsink }, formatter);
auto start = system_clock::now(); auto start = system_clock::now();
for (unsigned int i = 1; i <= howmany; ++i) for (unsigned int i = 1; i <= howmany; ++i)

View File

@ -26,7 +26,7 @@ inline std::string& fast_itostr(int n, std::string& s, int padding)
{ {
if (n == 0) if (n == 0)
{ {
s = "0"; s = std::string(padding, '0');
return s; return s;
} }

View File

@ -143,6 +143,11 @@ public:
_dev.sputn(s.data(), s.size()); _dev.sputn(s.data(), s.size());
} }
void write_data(const char* p, std::size_t size)
{
_dev.sputn(p, size);
}
void write_str(const std::string& s) void write_str(const std::string& s)
{ {
_dev.sputn(s.data(), s.size()); _dev.sputn(s.data(), s.size());

View File

@ -1,9 +1,8 @@
#pragma once #pragma once
#include <sstream>
#include "../common.h" #include "../common.h"
#include "../logger.h" #include "../logger.h"
#include "fast_oss.h" #include "./fast_oss.h"
// Line logger class - aggregates operator<< calls to fast ostream // Line logger class - aggregates operator<< calls to fast ostream

View File

@ -1,7 +1,7 @@
#pragma once #pragma once
#include "../common.h" #include "../common.h"
#include "fast_oss.h" #include "./fast_oss.h"
namespace c11log namespace c11log
{ {

View File

@ -3,6 +3,9 @@
#include<string> #include<string>
#include<cstdio> #include<cstdio>
#include<ctime> #include<ctime>
#ifdef _WIN32
#include <Windows.h>
#endif
namespace c11log namespace c11log
{ {
@ -81,6 +84,17 @@ inline bool fopen_s(FILE** fp, const std::string& filename, const char* mode)
#endif #endif
} }
inline float tz_offset()
{
#ifdef _WIN32
TIME_ZONE_INFORMATION tzinfo;
GetTimeZoneInformation(&tzinfo);
return tzinfo.Bias / -60.0f;
#else
return 0.0f;
#endif
}
} //os } //os
} //details } //details

View File

@ -6,10 +6,10 @@
#include <vector> #include <vector>
#include "../formatter.h" #include "../formatter.h"
#include "log_msg.h" #include "./log_msg.h"
#include "fast_oss.h" #include "./fast_oss.h"
#include "os.h" #include "./os.h"
#include "Windows.h"
namespace c11log namespace c11log
{ {
@ -42,6 +42,101 @@ class level_formatter :public flag_formatter
// Date time pattern appenders // Date time pattern appenders
/////////////////////////////////////////////////////////////////////// ///////////////////////////////////////////////////////////////////////
static const char* ampm(const tm& t)
{
return t.tm_hour >= 12 ? "PM" : "AM";
}
static int to12h(const tm& t)
{
return t.tm_hour > 12 ? t.tm_hour - 12 : t.tm_hour;
}
//Abbreviated weekday name
static const std::string days[] { "Sun", "Mon", "Tue", "Wed", "Thu", "Fri", "Sat" };
class a_formatter :public flag_formatter
{
void format(details::log_msg& msg) override
{
msg.formatted.write_str(days[msg.tm_time.tm_wday]);
}
};
//Full weekday name
static const std::string full_days[] { "Sunday", "Monday", "Tuesday", "Wednesday", "Thursday", "Friday", "Saturday" };
class A_formatter :public flag_formatter
{
void format(details::log_msg& msg) override
{
msg.formatted.write_str(full_days[msg.tm_time.tm_wday]);
}
};
//Abbreviated month
static const std::string months[] { "Jan", "Feb", "Mar", "Apr", "May", "June", "July", "Aug", "Sept", "Oct", "Nov", "Dec" };
class b_formatter :public flag_formatter
{
void format(details::log_msg& msg) override
{
msg.formatted.write_str(months[msg.tm_time.tm_mon]);
}
};
//Full month name
static const std::string full_months[] { "January", "February", "March", "April", "May", "June", "July", "August", "September", "October", "November", "December" };
class B_formatter :public flag_formatter
{
void format(details::log_msg& msg) override
{
msg.formatted.write_str(full_months[msg.tm_time.tm_mon]);
}
};
//Date and time representation (Thu Aug 23 15:35:46 2014)
class c_formatter :public flag_formatter
{
void format(details::log_msg& msg) override
{
msg.formatted.write_str(days[msg.tm_time.tm_wday]);
msg.formatted.putc(' ');
msg.formatted.write_str(months[msg.tm_time.tm_mon]);
msg.formatted.putc(' ');
msg.formatted.write_int(msg.tm_time.tm_mday, 2);
msg.formatted.putc(' ');
msg.formatted.write_int(msg.tm_time.tm_hour, 2);
msg.formatted.putc(':');
msg.formatted.write_int(msg.tm_time.tm_min, 2);
msg.formatted.putc(':');
msg.formatted.write_int(msg.tm_time.tm_sec, 2);
}
};
// year - 2 digit
class C_formatter :public flag_formatter
{
void format(details::log_msg& msg) override
{
msg.formatted.write_int(msg.tm_time.tm_year%100, 2);
}
};
// Short MM/DD/YY date, equivalent to %m/%d/%y 08/23/01
class D_formatter :public flag_formatter
{
void format(details::log_msg& msg) override
{
msg.formatted.write_int(msg.tm_time.tm_mon + 1, 2);
msg.formatted.putc('/');
msg.formatted.write_int(msg.tm_time.tm_mday, 2);
msg.formatted.putc('/');
msg.formatted.write_int(msg.tm_time.tm_year % 100, 2);
}
};
// year - 4 digit // year - 4 digit
class Y_formatter :public flag_formatter class Y_formatter :public flag_formatter
{ {
@ -51,14 +146,6 @@ class Y_formatter :public flag_formatter
} }
}; };
// year - 2 digit
class y_formatter :public flag_formatter
{
void format(details::log_msg& msg) override
{
msg.formatted.write_int(msg.tm_time.tm_year, 2);
}
};
// month 1-12 // month 1-12
class m_formatter :public flag_formatter class m_formatter :public flag_formatter
{ {
@ -91,7 +178,7 @@ class I_formatter :public flag_formatter
{ {
void format(details::log_msg& msg) override void format(details::log_msg& msg) override
{ {
msg.formatted.write_int((msg.tm_time.tm_hour + 1) % 1, 2); msg.formatted.write_int(to12h(msg.tm_time), 2);
} }
}; };
@ -124,6 +211,61 @@ class e_formatter :public flag_formatter
} }
}; };
// AM/PM
class p_formatter :public flag_formatter
{
void format(details::log_msg& msg) override
{
msg.formatted.write_data(ampm(msg.tm_time), 2);
}
};
// 12 hour clock 02:55:02 pm
class r_formatter :public flag_formatter
{
void format(details::log_msg& msg) override
{
int hours = to12h(msg.tm_time);
msg.formatted.write_int(to12h(msg.tm_time), 2);
msg.formatted.putc(':');
msg.formatted.write_int(msg.tm_time.tm_min, 2);
msg.formatted.putc(':');
msg.formatted.write_int(msg.tm_time.tm_sec, 2);
msg.formatted.putc(' ');
msg.formatted.write_data(ampm(msg.tm_time), 2);
}
};
// 24-hour HH:MM time, equivalent to %H:%M
class R_formatter :public flag_formatter
{
void format(details::log_msg& msg) override
{
msg.formatted.write_int(msg.tm_time.tm_hour, 2);
msg.formatted.putc(':');
msg.formatted.write_int(msg.tm_time.tm_min, 2);
}
};
// ISO 8601 time format (HH:MM:SS), equivalent to %H:%M:%S
class T_formatter :public flag_formatter
{
void format(details::log_msg& msg) override
{
msg.formatted.write_int(msg.tm_time.tm_hour, 2);
msg.formatted.putc(':');
msg.formatted.write_int(msg.tm_time.tm_min, 2);
msg.formatted.putc(':');
msg.formatted.write_int(msg.tm_time.tm_sec, 2);
}
};
class t_formatter :public flag_formatter class t_formatter :public flag_formatter
{ {
@ -147,10 +289,11 @@ private:
}; };
class str_formatter :public flag_formatter //aggregate user chars to display as is
class aggregate_formatter :public flag_formatter
{ {
public: public:
str_formatter() aggregate_formatter()
{} {}
void add_ch(char ch) void add_ch(char ch)
{ {
@ -158,7 +301,7 @@ public:
} }
void format(details::log_msg& msg) override void format(details::log_msg& msg) override
{ {
msg.formatted << _str; msg.formatted.write_str(_str);
} }
private: private:
std::string _str; std::string _str;
@ -181,32 +324,41 @@ private:
}; };
} }
} }
///////////////////////////////////////////////////////////////////////////////
// pattern_formatter inline impl
///////////////////////////////////////////////////////////////////////////////
inline c11log::details::pattern_formatter::pattern_formatter(const std::string& pattern) inline c11log::details::pattern_formatter::pattern_formatter(const std::string& pattern)
{ {
compile_pattern(pattern); compile_pattern(pattern);
} }
inline void c11log::details::pattern_formatter::compile_pattern(const std::string& pattern) inline void c11log::details::pattern_formatter::compile_pattern(const std::string& pattern)
{ {
auto end = pattern.end(); auto end = pattern.end();
std::unique_ptr<aggregate_formatter> user_chars;
for (auto it = pattern.begin(); it != end; ++it) for (auto it = pattern.begin(); it != end; ++it)
{ {
if (*it == '%') if (*it == '%')
{ {
if (user_chars) //append user chars found so far
_formatters.push_back(std::move(user_chars));
if (++it != end) if (++it != end)
handle_flag(*it); handle_flag(*it);
else else
return; break;
} }
else else // chars not following the % sign should be displayed as is
{ {
// chars not following the % sign should be displayed as is if (!user_chars)
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::ch_formatter(*it))); user_chars = std::unique_ptr<aggregate_formatter>(new aggregate_formatter());
user_chars->add_ch(*it);
} }
} }
if (user_chars) //append raw chars found so far
{
_formatters.push_back(std::move(user_chars));
}
} }
inline void c11log::details::pattern_formatter::handle_flag(char flag) inline void c11log::details::pattern_formatter::handle_flag(char flag)
@ -217,54 +369,97 @@ inline void c11log::details::pattern_formatter::handle_flag(char flag)
case 'n': case 'n':
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::name_formatter())); _formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::name_formatter()));
break; break;
// message log level
case 'l': case 'l':
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::level_formatter())); _formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::level_formatter()));
break; break;
// message text
case('t') : case('t') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::t_formatter())); _formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::t_formatter()));
break; break;
// year
case('a') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::a_formatter()));
break;
case('A') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::A_formatter()));
break;
case('b'):
case('h') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::b_formatter()));
break;
case('B') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::B_formatter()));
break;
case('c') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::c_formatter()));
break;
case('C') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::C_formatter()));
break;
case('Y') : case('Y') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::Y_formatter())); _formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::Y_formatter()));
break; break;
// year 2 digits
case('y') : case('D') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::y_formatter())); case('x') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::D_formatter()));
break; break;
// month
case('m') : case('m') :
// minute
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::m_formatter())); _formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::m_formatter()));
break; break;
// day in month
case('d') : case('d') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::d_formatter())); _formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::d_formatter()));
break; break;
// hour (24)
case('H') : case('H') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::H_formatter())); _formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::H_formatter()));
break; break;
// hour (12)
case('I') : case('I') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::I_formatter())); _formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::I_formatter()));
break; break;
// minutes
case('M') : case('M') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::M_formatter())); _formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::M_formatter()));
break; break;
// seconds
case('S') : case('S') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::S_formatter())); _formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::S_formatter()));
break; break;
// milliseconds part
case('e'): case('e'):
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::e_formatter())); _formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::e_formatter()));
break; break;
// % sign
case('%') : case('p'):
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::p_formatter()));
break;
case('r') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::r_formatter()));
break;
case('R') :
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::R_formatter()));
break;
case('T') :
case('X'):
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::T_formatter()));
break;
default: //Unkown flag appears as is
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::ch_formatter('%'))); _formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::ch_formatter('%')));
_formatters.push_back(std::unique_ptr<details::flag_formatter>(new details::ch_formatter(flag)));
break; break;
} }
} }

View File

@ -5,7 +5,7 @@
#include <atomic> #include <atomic>
#include <algorithm> #include <algorithm>
#include "base_sink.h" #include "./base_sink.h"
#include "../logger.h" #include "../logger.h"
#include "../details/blocking_queue.h" #include "../details/blocking_queue.h"
#include "../details/null_mutex.h" #include "../details/null_mutex.h"

View File

@ -3,7 +3,7 @@
#include<string> #include<string>
#include<mutex> #include<mutex>
#include<atomic> #include<atomic>
#include "sink.h" #include "./sink.h"
#include "../formatter.h" #include "../formatter.h"
#include "../common.h" #include "../common.h"
#include "../details/log_msg.h" #include "../details/log_msg.h"

View File

@ -3,7 +3,7 @@
#include <fstream> #include <fstream>
#include <sstream> #include <sstream>
#include <iomanip> #include <iomanip>
#include "base_sink.h" #include "./base_sink.h"
#include <mutex> #include <mutex>
#include "../details/null_mutex.h" #include "../details/null_mutex.h"
#include "../details/flush_helper.h" #include "../details/flush_helper.h"

View File

@ -1,6 +1,6 @@
#pragma once #pragma once
#include <mutex> #include <mutex>
#include "base_sink.h" #include "./base_sink.h"
#include "../details/null_mutex.h" #include "../details/null_mutex.h"

View File

@ -5,7 +5,7 @@
#include <memory> #include <memory>
#include "../details/null_mutex.h" #include "../details/null_mutex.h"
#include "base_sink.h" #include "./base_sink.h"
namespace c11log namespace c11log
{ {

View File

@ -2,7 +2,7 @@
#include <iostream> #include <iostream>
#include <mutex> #include <mutex>
#include "ostream_sink.h" #include "./ostream_sink.h"
#include "../details/null_mutex.h" #include "../details/null_mutex.h"
namespace c11log namespace c11log