Subversion Repositories tpanel

/*

 * Copyright (C) 2020 to 2024 by Andreas Theofilu <andreas@theosys.at>

 *

 * This program is free software; you can redistribute it and/or modify

 * it under the terms of the GNU General Public License as published by

 * the Free Software Foundation; either version 3 of the License, or

 * (at your option) any later version.

 *

 * This program is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the

 * GNU General Public License for more details.

 *

 * You should have received a copy of the GNU General Public License

 * along with this program; if not, write to the Free Software Foundation,

 * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301  USA

 */

#ifndef __TERROR_H__

#define __TERROR_H__

#include <iostream>

//#include <iomanip>

#include <iostream>

//#include <sstream>

#include <string>

#include <chrono>

//#include <mutex>

#include <thread>

#define LPATH_FILE          1   //!< Creates a log file and protocolls there

#define LPATH_SYSLOG        2   //!< Writes to the syslog.

#ifdef __ENVIRONMENT_IPHONE_OS_VERSION_MIN_REQUIRED__

#define LOGPATH             LPATH_SYSLOG

#else

#define LOGPATH             LPATH_FILE

#endif

#define HLOG_NONE           0x0000

#define HLOG_INFO           0x0001

#define HLOG_WARNING        0x0002

#define HLOG_ERROR          0x0004

#define HLOG_TRACE          0x0008

#define HLOG_DEBUG          0x0010

#define HLOG_PROTOCOL       (HLOG_INFO | HLOG_WARNING | HLOG_ERROR)

#define HLOG_ALL            (HLOG_INFO | HLOG_WARNING | HLOG_ERROR | HLOG_TRACE | HLOG_DEBUG)

#define SLOG_NONE           "NONE"

#define SLOG_INFO           "INFO"

#define SLOG_WARNING        "WARNING"

#define SLOG_ERROR          "ERROR"

#define SLOG_TRACE          "TRACE"

#define SLOG_DEBUG          "DEBUG"

#define SLOG_PROTOCOL       "PROTOCOL"

#define SLOG_ALL            "ALL"

#define T_UNUSED(x) (void)x;

typedef enum terrtype_t

{

    TERRNONE,

    TERRINFO,

    TERRWARNING,

    TERRERROR,

    TERRTRACE,

    TERRDEBUG

}terrtype_t;

#ifdef __APPLE__

typedef uint64_t threadID_t;

#else

typedef std::thread::id threadID_t;

#endif

threadID_t _getThreadID();

std::ostream& indent(std::ostream& os);

void _msg(int lv, std::ostream& os);

void _lock();

void _unlock();

class TStreamError

{

    public:

        TStreamError(const std::string& logFile, const std::string& logLevel);

        ~TStreamError();

        static void setLogFile(const std::string& lf);

        static void setLogFileOnly(const std::string& lf) { mLogfile = lf; }

        static std::string& getLogFile() { return mLogfile; }

        static void setLogLevel(const std::string& slv);

        static void setLogLevel(unsigned int ll) { mLogLevel = ll; }

        static unsigned int getLogLevel() { return mLogLevel; }

//        static void logMsg(std::ostream& str);

        static bool checkFilter(terrtype_t err);

        static bool checkFilter(unsigned int lv);

        friend std::ostream& indent(std::ostream& os);

        static void incIndent() { mIndent++; }

        static void decIndent();

        static int getIndent() { return mIndent; }

        static std::ostream *getStream();

        static std::string getTime();

        static std::ostream *resetFlags(std::ostream *os);

        static void resetFlags();

        static bool isStreamValid();

        static bool isStreamValid(std::ostream& os);

        static void startTemporaryLogLevel(unsigned int l);

        static void endTemporaryLogLevel();

        static void setLogFileEnabled(bool s) { mLogFileEnabled = s; }

        static bool isInitialized() { return (mInitialized && mStream != nullptr); }

    private:

        static unsigned int _getLevel(const std::string& slv);

        static void _init(bool reinit=false);

        const TStreamError& operator=(const TStreamError& ref);

        static bool mInitialized;

        static std::string mLogfile;

        static unsigned int mLogLevel;

        static unsigned int mLogLevelOld;

        static bool haveTemporaryLogLevel;

        static bool mLogFileEnabled;

        static int mIndent;

        static std::ostream *mStream;

        static std::filebuf mOfStream;

        static char *mBuffer;

};

class TTracer

{

    public:

        TTracer(const std::string& msg, int line, const char *file, threadID_t tid);

        ~TTracer();

    private:

        std::string mHeadMsg;

        int mLine{0};

        std::string mFile;

        std::chrono::steady_clock::time_point mTimePoint;

#ifdef __ANDROID__

        threadID_t mThreadID;

#else

        threadID_t mThreadID{0};

#endif

};

class TError : public std::ostream

{

    public:

        static void setErrorMsg(const std::string& msg);

        static void setErrorMsg(terrtype_t t, const std::string& msg);

        static void setError() { mHaveError = true; }

        static std::string& getErrorMsg() { return msError; }

        static bool isError() { return mHaveError; }

        static bool haveErrorMsg() { return !msError.empty(); }

        static terrtype_t getErrorType() { return mErrType; }

        static void setErrorType(terrtype_t et) { mErrType = et; }

        static std::ostream& append(int lv, std::ostream& os);

        static std::string append(int lv);

        static TStreamError* Current();

        static TStreamError* Current(threadID_t tid);

        static void clear() { mHaveError = false; msError.clear(); mErrType = TERRNONE; }

        static void logHex(const char *str, size_t size);

        const TError& operator=(const TError& ref);

        static void displayMessage(const std::string& msg);

    protected:

        static std::string strToHex(const char *str, size_t size, int width, bool format, int indent);

    private:

        static std::string toHex(int num, int width);

        TError() {}

        ~TError();

        static std::string msError;

        static bool mHaveError;

        static terrtype_t mErrType;

        static TStreamError *mCurrent;

        static threadID_t mThreadID;

//        std::string mHeadMsg;

};

#define MSG_INFO(msg)       { if (TStreamError::checkFilter(HLOG_INFO)) { _lock(); *TError::Current(_getThreadID())->getStream() << TError::append(HLOG_INFO) << msg << std::endl; TStreamError::resetFlags(); _unlock(); }}

#define MSG_WARNING(msg)    { if (TStreamError::checkFilter(HLOG_WARNING)) { _lock(); *TError::Current(_getThreadID())->getStream() << TError::append(HLOG_WARNING) << msg << std::endl; TStreamError::resetFlags(); _unlock(); }}

#define MSG_ERROR(msg)      { if (TStreamError::checkFilter(HLOG_ERROR)) { _lock(); *TError::Current(_getThreadID())->getStream() << TError::append(HLOG_ERROR) << msg << std::endl; TStreamError::resetFlags(); _unlock(); }}

#define MSG_TRACE(msg)      { if (TStreamError::checkFilter(HLOG_TRACE)) { _lock(); *TError::Current(_getThreadID())->getStream() << TError::append(HLOG_TRACE) << msg << std::endl; TStreamError::resetFlags(); _unlock(); }}

#ifndef NDEBUG

#define MSG_DEBUG(msg)      { if (TStreamError::checkFilter(HLOG_DEBUG)) { _lock(); *TError::Current(_getThreadID())->getStream() << TError::append(HLOG_DEBUG) << msg << std::endl; TStreamError::resetFlags(); _unlock(); }}

#else

#define MSG_DEBUG(msg)

#endif

#define MSG_PROTOCOL(msg)   { if (TStreamError::checkFilter(HLOG_PROTOCOL)) { _lock(); *TError::Current(_getThreadID())->getStream() << TError::append(HLOG_PROTOCOL) << msg << std::endl; TStreamError::resetFlags(); _unlock(); }}

#define DECL_TRACER(msg)    TTracer _hidden_tracer(msg, __LINE__, static_cast<const char *>(__FILE__), _getThreadID());

#define IS_LOG_INFO()       TStreamError::checkFilter(HLOG_INFO)

#define IS_LOG_WARNING()    TStreamError::checkFilter(HLOG_WARNING)

#define IS_LOG_ERROR()      TStreamError::checkFilter(HLOG_ERROR)

#define IS_LOG_TRACE()      TStreamError::checkFilter(HLOG_TRACE)

#define IS_LOG_DEBUG()      TStreamError::checkFilter(HLOG_DEBUG)

#define IS_LOG_PROTOCOL()   TStreamError::checkFilter(HLOG_PROTOCOL)

#define IS_LOG_ALL()        TStreamError::checkFilter(HLOG_ALL)

#ifndef NDEBUG

#define START_TEMPORARY_TRACE()     TStreamError::startTemporaryLogLevel(HLOG_TRACE)

#define START_TEMPORARY_DEBUG()     TStreamError::startTemporaryLogLevel(HLOG_DEBUG)

#define START_TEMPORARY_LOG(level)  TStreamError::startTemporaryLogLevel(level)

#define END_TEMPORARY_LOG()         TStreamError::endTemporaryLogLevel()

#else

#define START_TEMPORARY_TRACE()

#define START_TEMPORARY_DEBUG()

#define START_TEMPORARY_LOG(level)

#define END_TEMPORARY_LOG()

#endif

#endif