loggingserver.h

Go to the documentation of this file.

#ifndef LOGGINGSERVER_H_
#define LOGGINGSERVER_H_
 
#include <QtGlobal>
#if QT_VERSION >= QT_VERSION_CHECK(6,5,0)
#include <QtSystemDetection>
#endif
#include <QMutexLocker>
#include <QSocketNotifier>
#include <QMutex>
#include <QQueue>
#include <QElapsedTimer>
 
#include <cstdint>
#include <fstream>
#include <unistd.h>
 
#include "mythconfig.h"
#include "mythbaseexp.h"  //  MBASE_PUBLIC , etc.
#include "verbosedefs.h"
#include "mthread.h"
 
class QString;
class MSqlQuery;
class LoggingItem;
 
class LoggerBase
{
  public:
    explicit LoggerBase(const char *string);
    virtual ~LoggerBase();
    virtual bool logmsg(LoggingItem *item) = 0;
    virtual void reopen(void) = 0;
  protected:
    QString m_handle; 
};
 
class FileLogger : public LoggerBase
{
  public:
    explicit FileLogger(const char *filename);
    ~FileLogger() override;
    bool logmsg(LoggingItem *item) override; // LoggerBase
    void reopen(void) override; // LoggerBase
    static FileLogger *create(const QString& filename, QMutex *mutex);
  private:
    std::ofstream m_ofstream; 
};
 
#ifndef Q_OS_WINDOWS
class SyslogLogger : public LoggerBase
{
  public:
    explicit SyslogLogger(bool open);
    ~SyslogLogger() override;
    bool logmsg(LoggingItem *item) override; // LoggerBase
    void reopen(void) override { } // LoggerBase
    static SyslogLogger *create(QMutex *mutex, bool open = true);
  private:
    bool m_opened {false};  
};
#endif
 
#if CONFIG_SYSTEMD_JOURNAL
class JournalLogger : public LoggerBase
{
  public:
    JournalLogger();
    ~JournalLogger() override;
    bool logmsg(LoggingItem *item) override; // LoggerBase
    void reopen(void) override { }; // LoggerBase
    static JournalLogger *create(QMutex *mutex);
};
#endif
 
using LoggingItemList = QList<LoggingItem *>;
 
class LogForwardThread : public QObject, public MThread
{
    Q_OBJECT
 
    friend void logSigHup(void);
  public:
    LogForwardThread();
    ~LogForwardThread() override;
    void stop(void);
  protected:
    void run(void) override; // MThread
  private:
    bool m_aborted {false};          
 
    static void forwardMessage(LoggingItem *item);
  signals:
    void incomingSigHup(void);
  protected slots:
    static void handleSigHup(void);
};
 
MBASE_PUBLIC bool logForwardStart(void);
MBASE_PUBLIC void logForwardStop(void);
MBASE_PUBLIC void logForwardMessage(LoggingItem *item);
 
 
#ifndef Q_OS_WINDOWS
MBASE_PUBLIC void logSigHup(void);
#endif
 
#endif
 
/*
 * vim:ts=4:sw=4:ai:et:si:sts=4
 */