Subversion Repositories tpanel

/*

 * Copyright (C) 2020, 2021 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

 */

#include <iostream>

#include <fstream>

#include <sstream>

#include <ios>

#include <time.h>

#include <mutex>

#include <thread>

//#ifdef __APPLE__

//#include <unistd.h>

//#include <sys/syscall.h>

//#endif

#include "terror.h"

#include "tconfig.h"

#include <QMessageBox>

#include <QTimer>

#if LOGPATH == LPATH_SYSLOG || defined(__ANDROID__)

#   ifdef __ANDROID__

#       include <android/log.h>

#   else

#       include <syslog.h>

#   endif

#endif

#define LOGBUFFER_SIZE      4096

using std::string;

using std::mutex;

std::mutex message_mutex;

std::mutex _macro_mutex;

bool TError::mHaveError{false};

terrtype_t TError::mErrType{TERRNONE};

TStreamError *TError::mCurrent{nullptr};

std::string TError::msError;

threadID_t TError::mThreadID{0};

int TStreamError::mIndent{1};

std::ostream *TStreamError::mStream{nullptr};

std::filebuf TStreamError::mOfStream;

char *TStreamError::mBuffer{nullptr};

std::string TStreamError::mLogfile;

bool TStreamError::mInitialized{false};

unsigned int TStreamError::mLogLevel{HLOG_PROTOCOL};

unsigned int TStreamError::mLogLevelOld{HLOG_NONE};

bool TStreamError::haveTemporaryLogLevel{false};

string _threadIDtoStr(threadID_t tid)

{

    std::stringstream s;

    s << std::hex << std::setw(8) << std::setfill('0') << tid;

    return s.str();

}

threadID_t _getThreadID()

{

#ifdef __APPLE__

//    threadID_t tid;

//    return pthread_threadid_np(NULL, &tid);

    return pthread_mach_thread_np(pthread_self());

//    return syscall(SYS_thread_selfid);

#else

    return std::this_thread::get_id();

#endif

}

void _lock()

{

    _macro_mutex.lock();

}

void _unlock()

{

    _macro_mutex.unlock();

}

#if LOGPATH == LPATH_SYSLOG || defined(__ANDROID__)

class androidbuf : public std::streambuf

{

    public:

        enum { bufsize = 1024 };

        androidbuf() { this->setp(buffer, buffer + bufsize - 1); }

    private:

        int overflow(int c)

        {

            if (c == traits_type::eof())

            {

                *this->pptr() = traits_type::to_char_type(c);

                this->sbumpc();

            }

            return this->sync()? traits_type::eof(): traits_type::not_eof(c);

        }

        int sync()

        {

            int rc = 0;

            if (this->pbase() != this->pptr())

            {

                char writebuf[bufsize+1];

                memcpy(writebuf, this->pbase(), this->pptr() - this->pbase());

                writebuf[this->pptr() - this->pbase()] = '\0';

                int eType;

#ifdef __ANDROID__

                switch(TError::getErrorType())

                {

                    case TERRINFO:      eType = ANDROID_LOG_INFO; break;

                    case TERRWARNING:   eType = ANDROID_LOG_WARN; break;

                    case TERRERROR:     eType = ANDROID_LOG_ERROR; break;

                    case TERRTRACE:     eType = ANDROID_LOG_VERBOSE; break;

                    case TERRDEBUG:     eType = ANDROID_LOG_DEBUG; break;

                    case TERRNONE:      eType = ANDROID_LOG_INFO; break;

                }

                rc = __android_log_print(eType, "tpanel", "%s", writebuf) > 0;

#else

                switch(TError::getErrorType())

                {

                    case TERRINFO:      eType = LOG_INFO; break;

                    case TERRWARNING:   eType = LOG_WARN; break;

                    case TERRERROR:     eType = LOG_ERROR; break;

                    case TERRTRACE:     eType = LOG_INFO; break;

                    case TERRDEBUG:     eType = LOG_DEBUG; break;

                    case TERRNONE:      eType = LOG_INFO; break;

                }

                syslog(eType, writebuf);

                rc = 1;

#endif

                this->setp(buffer, buffer + bufsize - 1);

            }

            return rc;

        }

        char buffer[bufsize];

};

#endif

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

{

    if (!TConfig::isInitialized())

        return;

    if (!logFile.empty())

        mLogfile = logFile;

    else if (!TConfig::getLogFile().empty())

        mLogfile = TConfig::getLogFile();

    if (!logLevel.empty())

        setLogLevel(logLevel);

    else if (!TConfig::getLogLevel().empty())

        setLogLevel(TConfig::getLogFile());

    _init();

}

TStreamError::~TStreamError()

{

    if (mOfStream.is_open())

        mOfStream.close();

    if (mStream)

    {

        delete mStream;

        mStream = nullptr;

    }

    if (mBuffer)

        delete mBuffer;

    mInitialized = false;

}

void TStreamError::setLogFile(const std::string &lf)

{

#ifdef Q_OS_IOS

    if (!lf.empty())

    {

        if ((!mLogfile.empty() && mLogfile != lf) || mLogfile.empty())

            mLogfile = lf;

    }

    if (!mInitialized)

        _init();

#else

    if (mInitialized && mLogfile.compare(lf) == 0)

        return;

    mLogfile = lf;

    mInitialized = false;

    _init();

#endif

}

void TStreamError::setLogLevel(const std::string& slv)

{

    size_t pos = slv.find("|");

    size_t start = 0;

    string lv;

    mLogLevel = 0;

    while (pos != string::npos)

    {

        lv = slv.substr(start, pos - start);

        start = pos + 1;

        mLogLevel |= _getLevel(lv);

        pos = slv.find("|", start);

    }

    mLogLevel |= _getLevel(slv.substr(start));

#ifdef __ANDROID__

    __android_log_print(ANDROID_LOG_INFO, "tpanel", "TStreamError::setLogLevel: New loglevel: %s", slv.c_str());

#else

    if (TError::Current()->getStream())

        *TError::Current()->getStream() << TError::append(HLOG_INFO) << "New loglevel: " << slv << std::endl;

    else

        std::cout << TError::append(HLOG_INFO) << "New loglevel: " << slv << std::endl;

#endif

}

bool TStreamError::checkFilter(terrtype_t err)

{

    if (!TConfig::isInitialized())

        return false;

    if (err == TERRINFO && (mLogLevel & HLOG_INFO) != 0)

        return true;

    else if (err == TERRWARNING && (mLogLevel & HLOG_WARNING) != 0)

        return true;

    else if (err == TERRERROR && (mLogLevel & HLOG_ERROR) != 0)

        return true;

    else if (err == TERRTRACE && (mLogLevel & HLOG_TRACE) != 0)

        return true;

    else if (err == TERRDEBUG && (mLogLevel & HLOG_DEBUG) != 0)

        return true;

    return false;

}

bool TStreamError::checkFilter(int lv)

{

    if (!TConfig::isInitialized())

        return false;

    if ((mLogLevel & lv) != 0)

        return true;

    return false;

}

unsigned int TStreamError::_getLevel(const std::string& slv)

{

    if (slv.compare(SLOG_NONE) == 0)

        return HLOG_NONE;

    if (slv.compare(SLOG_INFO) == 0)

        return HLOG_INFO;

    if (slv.compare(SLOG_WARNING) == 0)

        return HLOG_WARNING;

    if (slv.compare(SLOG_ERROR) == 0)

        return HLOG_ERROR;

    if (slv.compare(SLOG_TRACE) == 0)

        return HLOG_TRACE;

    if (slv.compare(SLOG_DEBUG) == 0)

        return HLOG_DEBUG;

    if (slv.compare(SLOG_PROTOCOL) == 0)

        return HLOG_PROTOCOL;

    if (slv.compare(SLOG_ALL) == 0)

        return HLOG_ALL;

    return HLOG_NONE;

}

void TStreamError::_init(bool reinit)

{

    if (!TConfig::isInitialized() || mInitialized)

        return;

    mInitialized = true;

#if LOGPATH == LPATH_FILE

    if (!mLogfile.empty())

    {

        try

        {

#ifndef __ANDROID__

            if (mOfStream.is_open())

                mOfStream.close();

            if (mStream && mStream != &std::cout)

                delete mStream;

            if (!mBuffer)

            {

                mBuffer = new char[LOGBUFFER_SIZE];

                mOfStream.pubsetbuf(mBuffer, LOGBUFFER_SIZE);

            }

#if __cplusplus < 201402L

            mOfStream.open(mLogfile.c_str(), std::ios::out | std::ios::ate);

#else   // __cplusplus < 201402L

            mOfStream.open(mLogfile, std::ios::out | std::ios::ate);

#endif  //__cplusplus < 201402L

            mStream = new std::ostream(&mOfStream);

            if (!isStreamValid())

            {

                if (mOfStream.is_open())

                    mOfStream.close();

                mStream = &std::cout;

            }

#else   //__ANDROID__

            char *HOME = getenv("HOME");

            bool bigLog = false;

            uint logLevel = _getLevel(TConfig::getLogLevel());

            if ((logLevel & HLOG_TRACE) || (logLevel & HLOG_DEBUG))

                bigLog = true;

            if (HOME && !bigLog && mLogfile.find(HOME) == string::npos)

            {

                if (mOfStream.is_open())

                    mOfStream.close();

                if (mStream && mStream != &std::cout)

                    delete mStream;

#if __cplusplus < 201402L

                mOfStream.open(mLogfile.c_str(), std::ios::out | std::ios::ate);

#else   // __cplusplus < 201402L

                mOfStream.open(mLogfile, std::ios::out | std::ios::ate);

#endif  //__cplusplus < 201402L

                mStream = new std::ostream(&mOfStream);

                if (!isStreamValid())

                {

                    if (mOfStream.is_open())

                        mOfStream.close();

                    mStream = &std::cout;

                }

            }

            else

            {

                std::cout.rdbuf(new androidbuf);

                mStream = &std::cout;

            }

#endif  // __ANDROID__

        }

        catch (std::exception& e)

        {

#ifdef __ANDROID__

            __android_log_print(ANDROID_LOG_ERROR, "tpanel", "TStreamError::_init: %s", e.what());

#else   // __ANDROID__

            std::cerr << "ERROR: " << e.what() << std::endl;

#endif  // __ANDROID__

            mStream = &std::cout;

        }

    }

    else if (!isStreamValid())

    {

#ifdef __ANDROID__

        std::cout.rdbuf(new androidbuf);

#endif  // __ANDROID__

        mStream = &std::cout;

#if defined(QT_DEBUG) || defined(DEBUG)

#ifdef __ANDROID__

        __android_log_print(ANDROID_LOG_DEBUG, "tpanel", "TStreamError::_init: Stream wurde auf std::cout gesetzt.");

#else

        std::cout << "DEBUG: Stream wurde auf std::cout gesetzt." << std::endl;

#endif  // __ANDROID__

#endif

    }

#else  // LOGPATH == LPATH_FILE

    if (!mStream)

    {

#ifdef __ANDROID__

        std::cout.rdbuf(new androidbuf);

#endif

        mStream = &std::cout;

    }

#endif  // LOGPATH == LPATH_FILE

    if (reinit)

        return;

    if (mLogLevel > 0)

        *mStream << "Logfile started at " << getTime() << std::endl;

    *mStream << TConfig::getProgName() << " version " << VERSION_STRING() << std::endl;

    *mStream << "(C) Copyright by Andreas Theofilu <andreas@theosys.at>\n" << std::endl;

    if (mLogLevel > 0)

    {

        if (TConfig::isLongFormat())

            *mStream << "Timestamp           Type LNr., File name           , ThreadID Message" << std::endl;

        else

            *mStream << "Type LNr., Message" << std::endl;

        *mStream << "-----------------------------------------------------------------" << std::endl << std::flush;

    }

    else

        *mStream << std::flush;

}

std::ostream *TStreamError::resetFlags(std::ostream *os)

{

    if (!isStreamValid(*os))

        return os;

    *os << std::resetiosflags(std::ios::boolalpha) <<

           std::resetiosflags(std::ios::showbase) <<

           std::resetiosflags(std::ios::showpoint) <<

           std::resetiosflags(std::ios::showpos) <<

           std::resetiosflags(std::ios::skipws) <<

           std::resetiosflags(std::ios::unitbuf) <<

           std::resetiosflags(std::ios::uppercase) <<

           std::resetiosflags(std::ios::dec) <<

           std::resetiosflags(std::ios::hex) <<

           std::resetiosflags(std::ios::oct) <<

           std::resetiosflags(std::ios::fixed) <<

           std::resetiosflags(std::ios::scientific) <<

           std::resetiosflags(std::ios::internal) <<

           std::resetiosflags(std::ios::left) <<

           std::resetiosflags(std::ios::right) <<

           std::setfill(' ');

    return os;

}

void TStreamError::resetFlags()

{

    std::lock_guard<mutex> guard(message_mutex);

    resetFlags(TError::Current()->getStream());

}

void TStreamError::decIndent()

{

    if (mIndent > 0)

        mIndent--;

}

string TStreamError::getTime()

{

    time_t rawtime;

    struct tm * timeinfo;

    char buffer[80];

    rawtime = time(nullptr);

    timeinfo = localtime(&rawtime);

    if (!timeinfo)

    {

#ifdef __ANDROID__

        __android_log_print(ANDROID_LOG_ERROR, "tpanel", "TStreamError::getTime: Couldn't get the local time!");

#else

        std::cerr << "ERROR: Couldn't get the local time!" << std::endl;

#endif

        return string();

    }

    strftime(buffer, sizeof(buffer), "%Y-%m-%d %H:%M:%S", timeinfo);

    string str(buffer);

    return str;

}

std::ostream *TStreamError::getStream()

{

    try

    {

        if (!isStreamValid())

        {

#ifdef __ANDROID__

            __android_log_print(ANDROID_LOG_ERROR, "tpanel", "TStreamError::getStream: Internal stream is invalid!");

#else

            std::cerr << "ERROR: Internal stream is invalid!" << std::endl;

#endif

            mInitialized = false;

            _init();

#ifdef __ANDROID__

            __android_log_print(ANDROID_LOG_INFO, "tpanel", "TStreamError::getStream: Reinitialized stream.");

#else

            std::cerr << "INFO: Reinitialized stream." << std::endl;

#endif

            if (!isStreamValid())

            {

#ifdef __ANDROID__

                __android_log_print(ANDROID_LOG_ERROR, "tpanel", "TStreamError::getStream: Reinitializing of stream failed!");

#else

                std::cerr << "ERROR: Reinitializing of stream failed! Using \"std::cout\" to write log messages." << std::endl;

#endif

                return &std::cout;

            }

        }

        return mStream;

    }

    catch (std::exception& e)

    {

#ifdef __ANDROID__

        __android_log_print(ANDROID_LOG_ERROR, "tpanel", "TStreamError::getStream: Error retrieving the current stream!");

#else

        std::cerr << "ERROR: Error retrieving the current stream! Using \"std::cout\" instead." << std::endl;

#endif

    }

    return &std::cout;

}

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

{

    if (!TStreamError::isStreamValid(os))

        return os;

    if (TStreamError::getIndent() > 0)

        os << std::setw(TStreamError::getIndent()) << " ";

    return os;

}

bool TStreamError::isStreamValid()

{

    if (!mStream)

        return false;

    if (mStream->rdstate() & std::ostream::failbit)

        return false;

    if (mStream->rdstate() & std::ostream::badbit)

        return false;

    return true;

}

bool TStreamError::isStreamValid(std::ostream& os)

{

    if (os.rdstate() & std::ostream::failbit)

        return false;

    if (os.rdstate() & std::ostream::badbit)

        return false;

    return true;

}

void TStreamError::startTemporaryLogLevel(unsigned int l)

{

    if (haveTemporaryLogLevel)

        return;

    mLogLevelOld = mLogLevel;

    mLogLevel |= l;

    haveTemporaryLogLevel = true;

}

void TStreamError::endTemporaryLogLevel()

{

    if (!haveTemporaryLogLevel)

        return;

    mLogLevel = mLogLevelOld;

    haveTemporaryLogLevel = false;

}

/********************************************************************/

std::mutex tracer_mutex;

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

    : mThreadID(tid)

{

    if (!TConfig::isInitialized() || !TStreamError::checkFilter(HLOG_TRACE))

        return;

    std::lock_guard<mutex> guard(tracer_mutex);

    mFile = file;

    size_t pos = mFile.find_last_of("/");

    if (pos != string::npos)

        mFile = mFile.substr(pos + 1);

    TError::setErrorType(TERRTRACE);

    std::lock_guard<mutex> guardm(message_mutex);

#if LOGPATH == LPATH_FILE

    if (!TConfig::isLongFormat())

        *TError::Current()->getStream() << "TRC " << std::setw(5) << std::right << line << ", " << indent << "{entry " << msg << std::endl;

    else

        *TError::Current()->getStream() << TStreamError::getTime() <<  " TRC " << std::setw(5) << std::right << line << ", " << std::setw(20) << std::left << mFile << ", " << _threadIDtoStr(mThreadID) << " " << indent << "{entry " << msg << std::endl;

#else

    std::stringstream s;

    if (!TConfig::isLongFormat())

        s  << "TRC " << std::setw(5) << std::right << line << ", " << &indents << "{entry " << msg << std::endl;

    else

        s << TStreamError::getTime() <<  " TRC " << std::setw(5) << std::right << line << ", " << std::setw(20) << std::left << mFile << ", " << _threadIDtoStr(mThreadID) << &indents << "{entry " << msg << std::endl;

    TError::Current()->logMsg(s);

#endif

    TError::Current()->incIndent();

    mHeadMsg = msg;

    mLine = line;

    if (TConfig::getProfiling())

        mTimePoint = std::chrono::steady_clock::now();

}

TTracer::~TTracer()

{

    if (!TConfig::isInitialized() || !TStreamError::checkFilter(HLOG_TRACE))

        return;

    std::lock_guard<mutex> guard(tracer_mutex);

    TError::setErrorType(TERRTRACE);

    TError::Current()->decIndent();

    string nanosecs;

    if (TConfig::getProfiling())

    {

        std::chrono::steady_clock::time_point endPoint = std::chrono::steady_clock::now();

        std::chrono::nanoseconds difftime = endPoint - mTimePoint;

        std::chrono::seconds secs = std::chrono::duration_cast<std::chrono::seconds>(difftime);

        std::chrono::milliseconds msecs = std::chrono::duration_cast<std::chrono::milliseconds>(difftime) - std::chrono::duration_cast<std::chrono::seconds>(secs);

        std::stringstream s;

        s << std::chrono::duration_cast<std::chrono::nanoseconds> (difftime).count() << "[ns]" << " --> " << std::chrono::duration_cast<std::chrono::seconds>(secs).count() << "s " << std::chrono::duration_cast<std::chrono::milliseconds>(msecs).count() << "ms";

        nanosecs = s.str();

    }

    std::lock_guard<mutex> guardm(message_mutex);

#if LOGPATH == LPATH_FILE

    if (TConfig::getProfiling())

    {

        if (!TConfig::isLongFormat())

            *TError::Current()->getStream() << "TRC      , " << indent << "}exit " << mHeadMsg << " Elapsed time: " << nanosecs << std::endl;

        else

            *TError::Current()->getStream() << TStreamError::getTime() << " TRC      , " << std::setw(20) << std::left << mFile << ", " << _threadIDtoStr(mThreadID) << " " << indent << "}exit " << mHeadMsg << " Elapsed time: " << nanosecs << std::endl;

    }

    else

    {

        if (!TConfig::isLongFormat())

            *TError::Current()->getStream() << "TRC      , " << indent << "}exit " << mHeadMsg << std::endl;

        else

            *TError::Current()->getStream() << TStreamError::getTime() << " TRC      , " << std::setw(20) << std::left << mFile << ", " << _threadIDtoStr(mThreadID) << " " << indent << "}exit " << mHeadMsg << std::endl;

    }

#else

    std::stringstream s;

    if (!TConfig::isLongFormat())

        s << "TRC      , " << &indents << "}exit " << mHeadMsg;

    else

        s << TStreamError::getTime() << " TRC      , " << std::setw(20) << std::left << mFile << ", " << _threadIDtoStr(mThreadID) << " " << &indents << "}exit " << mHeadMsg;

    if (TConfig::getProfiling())

        s  << " Elapsed time: " << nanosecs << std::endl;

    else

        s << std::endl;

    TError::Current()->logMsg(s);

#endif

    mHeadMsg.clear();

}

/********************************************************************/

TError::~TError()

{

    if (mCurrent)

    {

        delete mCurrent;

        mCurrent = nullptr;

    }

}

TStreamError* TError::Current()

{

    if (!mCurrent)

        mCurrent = new TStreamError(TConfig::getLogFile(), TConfig::getLogLevel());

    return mCurrent;

}

TStreamError *TError::Current(threadID_t tid)

{

    mThreadID = tid;

    return Current();

}

void TError::logHex(char* str, size_t size)

{

    if (!str || !size)

        return;

    if (!Current())

        return;

    // Print out the message

    std::ostream *stream = mCurrent->getStream();

    *stream << strToHex(str, size, 16, true, 12) << std::endl;

    *stream << mCurrent->resetFlags(stream);

}

string TError::toHex(int num, int width)

{

    string ret;

    std::stringstream stream;

    stream << std::setfill ('0') << std::setw(width) << std::hex << num;

    ret = stream.str();

    return ret;

}

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

{

    int len = 0, pos = 0, old = 0;

    int w = (format) ? 1 : width;

    string out, left, right;

    string ind;

    if (indent > 0)

    {

        for (int j = 0; j < indent; j++)

            ind.append(" ");

    }

    for (size_t i = 0; i < size; i++)

    {

        if (len >= w)

        {

            left.append(" ");

            len = 0;

        }

        if (format && i > 0 && (pos % width) == 0)

        {

            out += ind + toHex(old, 4) + ": " + left + " | " + right + "\n";

            left.clear();

            right.clear();

            old = pos;

        }

        int c = *(str+i) & 0x000000ff;

        left.append(toHex(c, 2));

        if (format)

        {

            if (std::isprint(c))

                right.push_back(c);

            else

                right.push_back('.');

        }

        len++;

        pos++;

    }

    if (!format)

        return left;

    else if (pos > 0)

    {

        if ((pos % width) != 0)

        {

            for (int i = 0; i < (width - (pos % width)); i++)

                left.append("   ");

        }

        out += ind + toHex(old, 4)+": "+left + "  | " + right;

    }

    return out;

}

void TError::setErrorMsg(const std::string& msg)

{

    if (msg.empty())

        return;

    msError = msg;

    mHaveError = true;