Logger.h

Go to the documentation of this file.

#ifndef LOGGER_H_
#define LOGGER_H_

#if defined (__UNIX__) || defined (__OSX__)

#include <unistd.h>
#include <sys/types.h>
#define PID getpid()

#else
#define WIN32_LEAN_AND_MEAN
#include "process.h"
#include <winsock2.h>
#include <windows.h>
#include <conio.h>
#define PID _getpid()

#endif

#include <stdio.h>

#include <queue>
#include <string>

#include <boost/date_time/local_time/local_time.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>
#include <boost/filesystem.hpp>
#include <boost/lexical_cast.hpp>
#include <boost/thread.hpp>

// apparently std::queue doesn't quite work.
// don't try it.
using std::pair;
using std::string;

class Logger
{
    public:

        static inline void error(string msg, int port = NO_PORT, string host = "local")
        {
            if (Logger::is_enabled())
                Logger::queue(host, port, msg, "ERROR :  ");
        }

        static inline void info(string msg, int port = NO_PORT, string host = "local")
        {
            if (Logger::is_enabled())
                Logger::queue(host, port, msg, "INFO  :  ");
        }

        static inline void warn(string msg, int port = NO_PORT, string host = "local")
        {
            if (Logger::is_enabled())
                Logger::queue(host, port, msg, "WARN  :  ");
        }

        static const bool is_enabled()
        {
            return Logger::enabled;
        }

        static void shutdown();

        static const int NO_PORT = 0;

    private:

        /* Disallow instantiating. */
        Logger()
        {
        }

        static const int SLEEP_TIME_MS = 50;

        // add a log write request to the queue
        static void queue(string host, int port, string msg, string cat);

        static string get_date();

        static string get_timestamp();

        static string get_log_base_path();

        static void initialize();

        static void log_writer_run();

        static void handle_write_request(string dir, string line);

        static void formatter_run();

        static void handle_format_request(string host, int port, string msg, string cat);

        static bool initialized;

        static bool enabled;

        static boost::mutex log_writer_mtx;

        static boost::mutex formatter_mtx;

        static boost::mutex shutdown_mtx;

        static boost::condition_variable shutdown_cvar;

        static boost::condition_variable formatter_cvar;

        static boost::condition_variable log_writer_cvar;

        static std::queue<pair<pair<string, int> , pair<string, string> > > raw_requests;

        static std::queue<pair<string, string> > write_requests;

        static string pid;

        static boost::thread frm_t;

        static boost::thread lw_t;
};

#endif /* LOGGER_H_ */