|| || || || || ||

---

LogSystem.h

Go to the documentation of this file.

#ifndef Impala_Basis_LogSystem_h
#define Impala_Basis_LogSystem_h

#include <sstream>

#include "Basis/ILog.h"
#include "Basis/FileExists.h"
#include "Basis/StringList.h"

namespace Impala
{

class LogSystem
{

public:

    class LogSystemConfig 
    {

    public:

        String mLogProperties;
        String mLogFile;
        String mLogLayout;
        bool mDebug;
        int mLogLevel; // for Ork's logger
        String mDebugCat;
        bool mNoErrorLog;
        String mJobErrorLog;
        bool mExitOnError;
        bool mLogFlushOutput;

    }; //class LogSystemConfig

    static LogSystem&
    GetInstance()
    {
        static LogSystem theLogSystem;
        return theLogSystem;
    }

    virtual
    ~LogSystem()
    {
#ifdef LOG4CPP_USED
        log4cpp::Category::shutdown();
#endif
    }


#ifdef LOG4CPP_USED
    void
    Configure(const LogSystemConfig& config)
    {
        if (FileExists(config.mLogProperties))
        {
            const String logPropertiesFile = config.mLogProperties;
            log4cpp::PropertyConfigurator::configure(logPropertiesFile);
        }
        else
        {
            log4cpp::Appender* appender =
                new log4cpp::OstreamAppender("stdout", &std::cout);
            AddAppender(appender, config.mLogLayout);
        }

        if (config.mDebug)
        {
            log4cpp::Category& root = log4cpp::Category::getRoot();
            root.setPriority(log4cpp::Priority::DEBUG);
        }

        if (!config.mDebugCat.empty())
        {
            StringList catList(config.mDebugCat, ';');
            StringListCI i;
            for (i = catList.begin() ; i != catList.end() ; i++)
            {
                std::cout << "debug cat " << *i << std::endl;
                log4cpp::Category& cat = log4cpp::Category::getInstance(*i);
                cat.setPriority(log4cpp::Priority::DEBUG);
            }
        }

        if (!config.mLogFile.empty())
        {
            std::ostringstream oss;
            if (Link::Mpi::NrProcs() > 1)
                oss << "p" << Link::Mpi::MyId() << "_";
            oss << config.mLogFile;
            log4cpp::Appender* appender = 
                new log4cpp::FileAppender("proc_file", oss.str());
            AddAppender(appender, config.mLogLayout);
        }

        if (!config.mNoErrorLog)
        {
            std::ostringstream oss;
            if (Link::Mpi::NrProcs() > 1)
                oss << "p" << Link::Mpi::MyId() << "_";
            oss << "errors.log";
            if(!WritableFile(oss.str()))
            {
                std::cerr << "WARNING [LogSystem.h] failed to open errors.log for"
                          << " writing. You can 1) use log properties to write to"
                          << " another file; 2) run in another folder; 3) use"
                          << " option noErrorLog to not log to errors.log.\n"
                          << "Shutting down for now..." << std::endl;
                exit(1);
            }
            log4cpp::Appender* appender = 
                new log4cpp::FileAppender("err_file", oss.str());
            appender->setThreshold(log4cpp::Priority::ERROR);
            AddAppender(appender, "%d{%a%d %H:%M:%S,%l} - [%c %x] %m%n");
            if (! config.mJobErrorLog.empty())
            {
                log4cpp::Appender* jobAppender = 
                    new log4cpp::FileAppender("err_file", config.mJobErrorLog);
                jobAppender->setThreshold(log4cpp::Priority::ERROR);
                AddAppender(jobAppender, "%d{%a%d %H:%M:%S,%l} - [%c %x] %m%n");
            }
        }
        log4cpp::StringQueueAppender* ap =
            new log4cpp::StringQueueAppender("err_queue");
        ap->setThreshold(log4cpp::Priority::ERROR);
        AddAppender(ap, "%d{%a%d %H:%M:%S,%l} - [%c %x] %m%n");
        ILogErrors::GetInstance().SetAppender(ap);
        gExitOnErrorLogged = config.mExitOnError;
        gLog4CppFlushOutput = config.mLogFlushOutput;
    }

    void
    AddAppender(log4cpp::Appender* appender, CString layoutPattern)
    {
        log4cpp::PatternLayout* layout = new log4cpp::PatternLayout();
        layout->setConversionPattern(layoutPattern);
        appender->setLayout(layout);
        log4cpp::Category& root = log4cpp::Category::getRoot();
        root.addAppender(appender);
    }
#endif // LOG4CPP_USED

#ifdef BASISLOG_USED
    void
    Configure(const LogSystemConfig& config)
    {
        Logger::Configure(config.mLogLevel, config.mLogFile, config.mDebug);
        gExitOnErrorLogged = config.mExitOnError;
        gLog4CppFlushOutput = config.mLogFlushOutput;
    }
#endif // BASISLOG_USED

#ifdef STDLOG_USED
    void
    Configure(const LogSystemConfig& config)
    {
        gExitOnErrorLogged = config.mExitOnError;
        gLog4CppFlushOutput = config.mLogFlushOutput;
    }
#endif // STDLOG_USED


private:

    LogSystem()
    {
    }

    LogSystem(const LogSystem&)
    {
    }

    LogSystem&
    operator=(const LogSystem&)
    {
    }

}; //class LogSystem

} // namespace Impala

#endif

---