Streaming Log

Name

streaming_log - Print log to std::ostreams

SYNOPSIS

DESCRIPTION

Streaming log is the best choice for printing complex objects or template objects. As most objects are complicate, user needs to convert all the fields to string first in order to use with %s. However it’s very inconvenient (can’t append numbers) and needs lots of temporary memory (caused by string). The solution in C++ is to send the log as a stream to the std::ostream object. For example, in order to print object A, we need to implement the following interface:

  1. std::ostream& operator<<(std::ostream& os, const A& a);

The signature of the function means to print object a to os and then return os. The return value of os enables us to combine binary operator << (left-combine). As a result, os << a << b << c; means operator<<(operator<<(operator<<(os, a), b), c);. Apparently operator<< needs a returning reference to complete this process, which is also called chaining. In languages that don’t support operator overloading, you will see a more tedious form, such as os.print(a).print(b).print(c).

You should also use chaining in your own implementation of operator<<. In fact, printing a complex object is like DFS a tree: Call operator<< on each child node, and then each child node invokes the function on the grandchild node, and so forth. For example, object A has two member variables: B and C. Printing A becomes the process of putting B and C ostream:

  1. struct A {
  2.     B b;
  3.     C c;
  4. };
  5. std::ostream& operator<<(std::ostream& os, const A& a) {
  6.     return os << "A{b=" << a.b << ", c=" << a.c << "}";
  7. }

Data structure of B and C along with the print function：

  1. struct B {
  2.     int value;
  3. };
  4. std::ostream& operator<<(std::ostream& os, const B& b) {
  5.     return os << "B{value=" << b.value << "}";
  6. }
  7. struct C {
  8.     string name;
  9. };
  10. std::ostream& operator<<(std::ostream& os, const C& c) {
  11.     return os << "C{name=" << c.name << "}";
  12. }

Finally the result of printing object A is:

  1. A{b=B{value=10}, c=C{name=tom}}

This way we don’t need to allocate temporary memory since objects are directly passed into the ostream object. Of course, the memory management of ostream itself is another topic.

OK, now we connect the whole printing process by ostream. The most common ostream objects are std::cout and std::cerr, so objects implement the above function can be directly sent to std::cout and std::cerr. In other words, if a log stream also inherits ostream, then these objects can be written into log. Streaming log is such a log stream that inherits std::ostream to send the object into the log. In the current implementation, the logs are recorded in a thread-local buffer, which will be flushed into screen or logging::LogSink after a complete log record. Of course, the implementation is thread safe.

If you have ever used glog before, you should find it easy to start. The log macro is the same as glog. For example, to print a FATAL log (Note that there is no ):

  1. LOG(FATAL) << "Fatal error occurred! contexts=" << ...;
  2. LOG(WARNING) << "Unusual thing happened ..." << ...;
  3. LOG(TRACE) << "Something just took place..." << ...;

The log level of streaming log in accordance with glog：

PLOG

The difference of PLOG and LOG is that it will append error information at the end of log. It’s kind of like %m in printf. Under POSIX environment, the error code is errno。

  1. int fd = open("foo.conf", O_RDONLY);   // foo.conf does not exist, errno was set to ENOENT
  2. if (fd < 0) { 
  3.     PLOG(FATAL) << "Fail to open foo.conf";    // "Fail to open foo.conf: No such file or directory"
  4.     return -1;
  5. }

noflush

The first two LOG(TRACE) doesn’t flush the log to the screen. They are recorded inside the thread-local buffer. The third LOG(TRACE) flush all logs into the screen. If there are 3 elements inside items and we don’t append noflush, the result would be:

  1. TRACE: ... Items:
  2. TRACE: ...  item1
  3. TRACE: ...  item2
  4. TRACE: ...  item3

After we add noflush:

  1. TRACE: ... Items: item1 item2 item3

The noflush feature also support bthread so that we can push lots of logs from the server’s bthreads without actually print them (using noflush), and flush the whole log at the end of RPC. Note that you should not use noflush when implementing an asynchronous method since it will change the underlying bthread, leaving noflush out of function.

LOG_IF

LOG_IF(log_level, condition) prints only when condition is true. It’s the same as if (condition) { LOG() << ...; } with shorter code：

  1. LOG_IF(NOTICE, n > 10) << "This log will only be printed when n > 10";

XXX represents for LOG, LOG_IF, PLOG, SYSLOG, VLOG, DLOG, and so on. These logging macros print log at most once per second. You can use these to check running status inside hotspot area. The first call to this macro prints the log immediately, and costs additional 30ns (caused by gettimeofday) compared to normal LOG.

  1. LOG_EVERY_SECOND(INFO) << "High-frequent logs";

XXX_EVERY_N

XXX represents for LOG, LOG_IF, PLOG, SYSLOG, VLOG, DLOG, and so on. These logging macros print log every N times. You can use these to check running status inside hotspot area. The first call to this macro prints the log immediately, and costs an additional atomic operation (relaxed order) compared to normal LOG. This macro is thread safe which means counting from multiple threads is also accurate while glog is not.

  1. LOG_EVERY_N(ERROR, 10) << "High-frequent logs";

XXX_FIRST_N

XXX represents for LOG, LOG_IF, PLOG, SYSLOG, VLOG, DLOG, and so on. These logging macros print log at most N times. It costs an additional atomic operation (relaxed order) compared to normal LOG before N, and zero cost after.

  1. LOG_FIRST_N(ERROR, 20) << "Logs that prints for at most 20 times";

XXX_ONCE

XX represents for LOG, LOG_IF, PLOG, SYSLOG, VLOG, DLOG, and so on. These logging macros print log at most once. It’s the same as XXX_FIRST_N(..., 1)

VLOG(verbose_level) is detail log that support multiple layers. It uses 2 gflags: –verbose and –verbose_module to control the logging layer you want (Note that glog uses –v and –vmodule). The log will be printed only when --verbose >= verbose_level:

  1. VLOG(0) << "verbose log tier 0";
  2. VLOG(1) << "verbose log tier 1";
  3. VLOG(2) << "verbose log tier 2";

When --verbose=1, the first 2 log will be printed while the last won’t. Module means a file or file path without the extension name, and value of --verbose_module will overwrite --verbose. For example:

  1. --verbose=1 --verbose_module="channel=2,server=3"    # print VLOG of those with verbose value:
  2.                                                      # channel.cpp <= 2
  4. --verbose=1 --verbose_module="src/brpc/channel=2,server=3"
  5.                                                     # For files with same names, add paths

You can set --verbose and --verbose_module through google::SetCommandLineOption dynamically.

  1. // public/foo/bar.cpp
  2. VLOG2("a/b/c", 2) << "being filtered by a/b/c rather than public/foo/bar";

DLOG

All log macros have debug versions, starting with D, such as DLOG, DVLOG. When NDEBUG is defined, these logs will not be printed.

Do not put important side effects inside the log streams beginning with D.

No printing means that even the parameters are not evaluated. If your parameters have side effects, they won’t happend when NDEBUG is defined. For example, DLOG(FATAL) << foo(); where foo is a function or it changes a dictionary, anyway, it’s essential. However, it won’t be evaluated when NDEBUG is defined.

CHECK

Another import variation of logging is CHECK(expression). When expression evaluates to false, it will print a fatal log. It’s kind of like ASSERT in gtest, and has other form such as CHECK_EQ, CHECK_GT, and so on. When check fails, the message after will be printed.

  1. CHECK_LT(1, 2) << "This is definitely true, this log will never be seen";
  2. CHECK_GT(1, 2) << "1 can't be greater than 2";

Run the above code you should see a fatal log and the calling stack：

  1. FATAL: ... Check failed: 1 > 2 (1 vs 2). 1 can't be greater than 2
  2. #0 0x000000afaa23 butil::debug::StackTrace::StackTrace()
  3. #1 0x000000c29fec logging::LogStream::FlushWithoutReset()
  4. #2 0x000000c2b8e6 logging::LogStream::Flush()
  5. #3 0x000000c2bd63 logging::DestroyLogStream()
  6. #4 0x000000c2a52d logging::LogMessage::~LogMessage()
  7. #5 0x000000a716b2 (anonymous namespace)::StreamingLogTest_check_Test::TestBody()
  8. #6 0x000000d16d04 testing::internal::HandleSehExceptionsInMethodIfSupported<>()
  9. #7 0x000000d19e96 testing::internal::HandleExceptionsInMethodIfSupported<>()
  10. #8 0x000000d08cd4 testing::Test::Run()
  11. #9 0x000000d08dfe testing::TestInfo::Run()
  12. #10 0x000000d08ec4 testing::TestCase::Run()
  13. #11 0x000000d123c7 testing::internal::UnitTestImpl::RunAllTests()
  14. #12 0x000000d16d94 testing::internal::HandleSehExceptionsInMethodIfSupported<>()

The second column of the callstack is the address of the code segment. You can use addr2line to check the corresponding file and line:

  1. $ addr2line -e ./test_base 0x000000a716b2 
  2. /home/gejun/latest_baidu_rpc/public/common/test/test_streaming_log.cpp:223

You should use CHECK_XX for arithmetic condition so that you can see more detailed information when check failed.

Like DLOG, you should NOT include important side effects inside DCHECK.

LogSink

The default destination of streaming log is the screen. You can change it through logging::SetLogSink. Users can inherit LogSink and implement their own output logic. We provide an internal LogSink as an example:

Inherit both LogSink and string. Store log content inside string and mainly aim for unit test. The following case shows a classic usage of StringSink:

  1. TEST_F(StreamingLogTest, log_at) {
  2.     ::logging::StringSink log_str;
  3.     ::logging::LogSink* old_sink = ::logging::SetLogSink(&log_str);
  4.     LOG_AT(FATAL, "specified_file.cc", 12345) << "file/line is specified";
  5.     // the file:line part should be using the argument given by us.
  6.     ASSERT_NE(std::string::npos, log_str.find("specified_file.cc:12345"));
  7.     // restore the old sink.
  8.     ::logging::SetLogSink(old_sink);