16b3a42afSjmmv // Copyright 2011 Google Inc.
26b3a42afSjmmv // All rights reserved.
36b3a42afSjmmv //
46b3a42afSjmmv // Redistribution and use in source and binary forms, with or without
56b3a42afSjmmv // modification, are permitted provided that the following conditions are
66b3a42afSjmmv // met:
76b3a42afSjmmv //
86b3a42afSjmmv // * Redistributions of source code must retain the above copyright
96b3a42afSjmmv // notice, this list of conditions and the following disclaimer.
106b3a42afSjmmv // * Redistributions in binary form must reproduce the above copyright
116b3a42afSjmmv // notice, this list of conditions and the following disclaimer in the
126b3a42afSjmmv // documentation and/or other materials provided with the distribution.
136b3a42afSjmmv // * Neither the name of Google Inc. nor the names of its contributors
146b3a42afSjmmv // may be used to endorse or promote products derived from this software
156b3a42afSjmmv // without specific prior written permission.
166b3a42afSjmmv //
176b3a42afSjmmv // THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
186b3a42afSjmmv // "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
196b3a42afSjmmv // LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
206b3a42afSjmmv // A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
216b3a42afSjmmv // OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
226b3a42afSjmmv // SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
236b3a42afSjmmv // LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
246b3a42afSjmmv // DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
256b3a42afSjmmv // THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
266b3a42afSjmmv // (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
276b3a42afSjmmv // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
286b3a42afSjmmv
296b3a42afSjmmv #include "utils/logging/operations.hpp"
306b3a42afSjmmv
316b3a42afSjmmv extern "C" {
326b3a42afSjmmv #include <unistd.h>
336b3a42afSjmmv }
346b3a42afSjmmv
356b3a42afSjmmv #include <fstream>
366b3a42afSjmmv #include <stdexcept>
376b3a42afSjmmv #include <string>
386b3a42afSjmmv #include <utility>
396b3a42afSjmmv #include <vector>
406b3a42afSjmmv
416b3a42afSjmmv #include "utils/datetime.hpp"
426b3a42afSjmmv #include "utils/format/macros.hpp"
436b3a42afSjmmv #include "utils/optional.ipp"
446b3a42afSjmmv #include "utils/sanity.hpp"
456b3a42afSjmmv
466b3a42afSjmmv namespace datetime = utils::datetime;
476b3a42afSjmmv namespace fs = utils::fs;
486b3a42afSjmmv namespace logging = utils::logging;
496b3a42afSjmmv
506b3a42afSjmmv using utils::none;
516b3a42afSjmmv using utils::optional;
526b3a42afSjmmv
536b3a42afSjmmv
546b3a42afSjmmv /// The general idea for the application-wide logging goes like this:
556b3a42afSjmmv ///
566b3a42afSjmmv /// 1. The application starts. Logging is initialized to capture _all_ log
576b3a42afSjmmv /// messages into memory regardless of their level by issuing a call to the
586b3a42afSjmmv /// set_inmemory() function.
596b3a42afSjmmv ///
606b3a42afSjmmv /// 2. The application offers the user a way to select the logging level and a
616b3a42afSjmmv /// file into which to store the log.
626b3a42afSjmmv ///
636b3a42afSjmmv /// 3. The application calls set_persistency providing a new log level and a log
646b3a42afSjmmv /// file. This must be done as early as possible, to minimize the chances of an
656b3a42afSjmmv /// early crash not capturing any logs.
666b3a42afSjmmv ///
676b3a42afSjmmv /// 4. At this point, any log messages stored into memory are flushed to disk
686b3a42afSjmmv /// respecting the provided log level.
696b3a42afSjmmv ///
706b3a42afSjmmv /// 5. The internal state of the logging module is updated to only capture
716b3a42afSjmmv /// messages that are of the provided log level (or below) and is configured to
726b3a42afSjmmv /// directly send messages to disk.
736b3a42afSjmmv ///
746b3a42afSjmmv /// The call to set_inmemory() should only be performed by the user-facing
756b3a42afSjmmv /// application. Tests should skip this call so that the logging messages go to
766b3a42afSjmmv /// stderr by default, thus generating a useful log to debug the tests.
776b3a42afSjmmv
786b3a42afSjmmv
796b3a42afSjmmv namespace {
806b3a42afSjmmv
816b3a42afSjmmv
826b3a42afSjmmv /// Current log level.
836b3a42afSjmmv static logging::level log_level = logging::level_debug;
846b3a42afSjmmv
856b3a42afSjmmv
866b3a42afSjmmv /// Indicates whether set_persistency() will be called automatically or not.
876b3a42afSjmmv static bool auto_set_persistency = true;
886b3a42afSjmmv
896b3a42afSjmmv
906b3a42afSjmmv /// First time recorded by the logging module.
916b3a42afSjmmv static optional< datetime::timestamp > first_timestamp = none;
926b3a42afSjmmv
936b3a42afSjmmv
946b3a42afSjmmv /// In-memory record of log entries before persistency is enabled.
956b3a42afSjmmv static std::vector< std::pair< logging::level, std::string > > backlog;
966b3a42afSjmmv
976b3a42afSjmmv
986b3a42afSjmmv /// Stream to the currently open log file.
99*46b85cbbSlukem static std::unique_ptr< std::ofstream > logfile;
1006b3a42afSjmmv
1016b3a42afSjmmv
1026b3a42afSjmmv /// Constant string to strftime to format timestamps.
1036b3a42afSjmmv static const char* timestamp_format = "%Y%m%d-%H%M%S";
1046b3a42afSjmmv
1056b3a42afSjmmv
1066b3a42afSjmmv /// Converts a level to a printable character.
1076b3a42afSjmmv ///
1086b3a42afSjmmv /// \param level The level to convert.
1096b3a42afSjmmv ///
1106b3a42afSjmmv /// \return The printable character, to be used in log messages.
1116b3a42afSjmmv static char
level_to_char(const logging::level level)1126b3a42afSjmmv level_to_char(const logging::level level)
1136b3a42afSjmmv {
1146b3a42afSjmmv switch (level) {
1156b3a42afSjmmv case logging::level_error: return 'E';
1166b3a42afSjmmv case logging::level_warning: return 'W';
1176b3a42afSjmmv case logging::level_info: return 'I';
1186b3a42afSjmmv case logging::level_debug: return 'D';
1196b3a42afSjmmv default: UNREACHABLE;
1206b3a42afSjmmv }
1216b3a42afSjmmv }
1226b3a42afSjmmv
1236b3a42afSjmmv
1246b3a42afSjmmv } // anonymous namespace
1256b3a42afSjmmv
1266b3a42afSjmmv
1276b3a42afSjmmv /// Generates a standard log name.
1286b3a42afSjmmv ///
1296b3a42afSjmmv /// This always adds the same timestamp to the log name for a particular run.
1306b3a42afSjmmv /// Also, the timestamp added to the file name corresponds to the first
1316b3a42afSjmmv /// timestamp recorded by the module; it does not necessarily contain the
1326b3a42afSjmmv /// current value of "now".
1336b3a42afSjmmv ///
1346b3a42afSjmmv /// \param logdir The path to the directory in which to place the log.
1356b3a42afSjmmv /// \param progname The name of the program that is generating the log.
1366b3a42afSjmmv fs::path
generate_log_name(const fs::path & logdir,const std::string & progname)1376b3a42afSjmmv logging::generate_log_name(const fs::path& logdir, const std::string& progname)
1386b3a42afSjmmv {
1396b3a42afSjmmv if (!first_timestamp)
1406b3a42afSjmmv first_timestamp = datetime::timestamp::now();
1416b3a42afSjmmv // Update doc/troubleshooting.texi if you change the name format.
1426b3a42afSjmmv return logdir / (F("%s.%s.log") % progname %
1436b3a42afSjmmv first_timestamp.get().strftime(timestamp_format));
1446b3a42afSjmmv }
1456b3a42afSjmmv
1466b3a42afSjmmv
1476b3a42afSjmmv /// Logs an entry to the log file.
1486b3a42afSjmmv ///
1496b3a42afSjmmv /// If the log is not yet set to persistent mode, the entry is recorded in the
1506b3a42afSjmmv /// in-memory backlog. Otherwise, it is just written to disk.
1516b3a42afSjmmv ///
1526b3a42afSjmmv /// \param message_level The level of the entry.
1536b3a42afSjmmv /// \param file The file from which the log message is generated.
1546b3a42afSjmmv /// \param line The line from which the log message is generated.
1556b3a42afSjmmv /// \param user_message The raw message to store.
1566b3a42afSjmmv void
log(const level message_level,const char * file,const int line,const std::string & user_message)1576b3a42afSjmmv logging::log(const level message_level, const char* file, const int line,
1586b3a42afSjmmv const std::string& user_message)
1596b3a42afSjmmv {
1606b3a42afSjmmv const datetime::timestamp now = datetime::timestamp::now();
1616b3a42afSjmmv if (!first_timestamp)
1626b3a42afSjmmv first_timestamp = now;
1636b3a42afSjmmv
1646b3a42afSjmmv if (auto_set_persistency) {
1656b3a42afSjmmv // These values are hardcoded here for testing purposes. The
1666b3a42afSjmmv // application should call set_inmemory() by itself during
1676b3a42afSjmmv // initialization to avoid this, so that it has explicit control on how
1686b3a42afSjmmv // the call to set_persistency() happens.
1696b3a42afSjmmv set_persistency("debug", fs::path("/dev/stderr"));
1706b3a42afSjmmv auto_set_persistency = false;
1716b3a42afSjmmv }
1726b3a42afSjmmv
1736b3a42afSjmmv if (message_level > log_level)
1746b3a42afSjmmv return;
1756b3a42afSjmmv
1766b3a42afSjmmv // Update doc/troubleshooting.texi if you change the log format.
1776b3a42afSjmmv const std::string message = F("%s %s %s %s:%s: %s") %
1786b3a42afSjmmv now.strftime(timestamp_format) % level_to_char(message_level) %
1796b3a42afSjmmv ::getpid() % file % line % user_message;
1806b3a42afSjmmv if (logfile.get() == NULL)
1816b3a42afSjmmv backlog.push_back(std::make_pair(message_level, message));
1826b3a42afSjmmv else {
1836b3a42afSjmmv INV(backlog.empty());
1846b3a42afSjmmv (*logfile) << message << '\n';
1856b3a42afSjmmv (*logfile).flush();
1866b3a42afSjmmv }
1876b3a42afSjmmv }
1886b3a42afSjmmv
1896b3a42afSjmmv
1906b3a42afSjmmv /// Sets the logging to record messages in memory for later flushing.
1916b3a42afSjmmv void
set_inmemory(void)1926b3a42afSjmmv logging::set_inmemory(void)
1936b3a42afSjmmv {
1946b3a42afSjmmv auto_set_persistency = false;
1956b3a42afSjmmv }
1966b3a42afSjmmv
1976b3a42afSjmmv
1986b3a42afSjmmv /// Makes the log persistent.
1996b3a42afSjmmv ///
2006b3a42afSjmmv /// Calling this function flushes the in-memory log, if any, to disk and sets
2016b3a42afSjmmv /// the logging module to send log entries to disk from this point onwards.
2026b3a42afSjmmv /// There is no way back, and the caller program should execute this function as
2036b3a42afSjmmv /// early as possible to ensure that a crash at startup does not discard too
2046b3a42afSjmmv /// many useful log entries.
2056b3a42afSjmmv ///
2066b3a42afSjmmv /// Any log entries above the provided new_level are discarded.
2076b3a42afSjmmv ///
2086b3a42afSjmmv /// \param new_level The new log level.
2096b3a42afSjmmv /// \param path The file to write the logs to.
2106b3a42afSjmmv ///
2116b3a42afSjmmv /// \throw std::range_error If the given log level is invalid.
2126b3a42afSjmmv /// \throw std::runtime_error If the given file cannot be created.
2136b3a42afSjmmv void
set_persistency(const std::string & new_level,const fs::path & path)2146b3a42afSjmmv logging::set_persistency(const std::string& new_level, const fs::path& path)
2156b3a42afSjmmv {
2166b3a42afSjmmv auto_set_persistency = false;
2176b3a42afSjmmv
2186b3a42afSjmmv PRE(logfile.get() == NULL);
2196b3a42afSjmmv
2206b3a42afSjmmv // Update doc/troubleshooting.info if you change the log levels.
2216b3a42afSjmmv if (new_level == "debug")
2226b3a42afSjmmv log_level = level_debug;
2236b3a42afSjmmv else if (new_level == "error")
2246b3a42afSjmmv log_level = level_error;
2256b3a42afSjmmv else if (new_level == "info")
2266b3a42afSjmmv log_level = level_info;
2276b3a42afSjmmv else if (new_level == "warning")
2286b3a42afSjmmv log_level = level_warning;
2296b3a42afSjmmv else
2306b3a42afSjmmv throw std::range_error(F("Unrecognized log level '%s'") % new_level);
2316b3a42afSjmmv
2326b3a42afSjmmv logfile.reset(new std::ofstream(path.c_str()));
2336b3a42afSjmmv if (!(*logfile))
2346b3a42afSjmmv throw std::runtime_error(F("Failed to create log file %s") % path);
2356b3a42afSjmmv
2366b3a42afSjmmv for (std::vector< std::pair< logging::level, std::string > >::const_iterator
2376b3a42afSjmmv iter = backlog.begin(); iter != backlog.end(); iter++) {
2386b3a42afSjmmv if ((*iter).first <= log_level)
2396b3a42afSjmmv (*logfile) << (*iter).second << '\n';
2406b3a42afSjmmv }
2416b3a42afSjmmv (*logfile).flush();
2426b3a42afSjmmv backlog.clear();
2436b3a42afSjmmv }
244