qpidlogger.cpp

Go to the documentation of this file.

#include "qpiddebug.h"
#include "qpidlogger.h"
#include "qpidcontroller.h"
#include <QThread>
#include <stdio.h>
#include <errno.h>

QPidLogger::QPidLogger(QcepSettingsSaverWPtr saver, QPidControllerWPtr ctrl) :
  m_ObjectNamer(this, "logger"),
  m_Saver(saver),
  m_Controller(ctrl),
  m_File(NULL),
  m_Enabled(m_Saver, this, "enabled", true, "Logging Enabled?"),
  m_FileName(m_Saver, this, "fileName", "pidctrl.log", "Log file name"),
  m_UpdateInterval(m_Saver, this, "updateInterval", 30, "Logging interval (seconds)"),
  m_PointLimit(m_Saver, this, "pointLimit", 0, "Start new log scan after this many points"),
  m_ScanNumber(m_Saver, this, "scanNumber", 0, "Log file scan number"),
  m_PointCount(QcepSettingsSaverPtr(), this, "pointCount", 0, "Number of points in current log scan"),
  m_ChannelNames(QcepSettingsSaverPtr(), this, "channelNames", QStringList(), "Log File Column Names")
{
  connect(prop_FileName(), SIGNAL(valueChanged(QString,int)), this, SLOT(onFilenameChanged(QString, int)));
}

void QPidLogger::logChannelNames(QStringList names)
{
  if (QThread::currentThread() != thread()) {
    INVOKE_CHECK(QMetaObject::invokeMethod(this, "logChannelNames", Q_ARG(QStringList, names)));
  } else {
    if (qcepDebug(DEBUG_LOGGER)) {
      printMessage(tr("QPidLogger::logChannelNames %1 ,...").arg(names.value(0)));
    }

    set_ChannelNames(names);
  }
}

void QPidLogger::logChannelValues(QcepDoubleList values)
{
  if (QThread::currentThread() != thread()) {
    INVOKE_CHECK(QMetaObject::invokeMethod(this, "logChannelValues", Q_ARG(QcepDoubleList, values)));
  } else {
    if (qcepDebug(DEBUG_LOGGER)) {
      printMessage(tr("QPidLogger::logChannelValues %1 ,...").arg(values.value(0)));
    }

    if (get_Enabled()) {
      openLogFileIfNeeded();

      if (m_File) {
        if (get_PointCount() == 0) {
          QStringList names = get_ChannelNames();

          int n = names.length();

          fprintf(m_File, "#S %d qpid timescan \"%s\" %g\n",
                  get_ScanNumber(),
                  qPrintable(get_FileName()),
                  get_UpdateInterval());

          fprintf(m_File, "#D %s\n", qPrintable(QDateTime::currentDateTime().toString("ddd MMM d hh:mm:ss yyyy")));
          fprintf(m_File, "#N %d\n", n);
          fprintf(m_File, "#L ");

          if (n) {
            fprintf(m_File, "%s", qPrintable(names[0]));
          }

          for (int i=1; i<n; i++) {
            fprintf(m_File, "  %s", qPrintable(names[i]));
          }

          fprintf(m_File, "\n");
          fflush(m_File);

          prop_ScanNumber()->incValue(1);
        }

        int n = values.length();

        if (n) {
          fprintf(m_File, "%0.15g", values.value(0));
        }

        for (int i=1; i<n; i++) {
          fprintf(m_File, "\t%0.15g", values.value(i));
        }

        fprintf(m_File, "\n");
        fflush(m_File);

        prop_PointCount()->incValue(1);

        if ((get_PointLimit() > 0) && (get_PointCount() > get_PointLimit())) {
          set_PointCount(0);
        }
      }
    }
  }
}

void QPidLogger::logString(QString str)
{
  if (QThread::currentThread() != thread()) {
    INVOKE_CHECK(QMetaObject::invokeMethod(this, "logString", Q_ARG(QString, str)));
  } else {
    if (qcepDebug(DEBUG_LOGGER)) {
      printMessage(tr("QPidLogger::logString %1 ,...").arg(str));
    }

    if (get_Enabled()) {
      openLogFileIfNeeded();

      if (m_File) {
        fprintf(m_File, "#C %s. %s.\n", qPrintable(QDateTime::currentDateTime().toString("ddd MMM d hh:mm:ss yyyy")),
                                        qPrintable(str));
        fflush(m_File);
      }
    }
  }
}

void QPidLogger::openLogFileIfNeeded()
{
  if (m_File == NULL) {
    FILE *f = fopen(qPrintable(get_FileName()), "a+");

    if (f) {
      m_File = f;

      rewind(m_File);

      char buff[4096];
      int  scan=0;

      do {
        fgets(buff, sizeof(buff), m_File);

        if (ferror(m_File)) {
          printMessage(tr("File error %1").arg(errno));
        }

        if (sscanf(buff, "#S %d", &scan) == 1) {
          set_ScanNumber(scan+1);
        }
      } while(!feof(m_File));

      fprintf(m_File, "#F %s\n", qPrintable(get_FileName()));
      fprintf(m_File, "#E %d\n", QDateTime::currentDateTime().toTime_t());
      fprintf(m_File, "#D %s\n", qPrintable(QDateTime::currentDateTime().toString("ddd MMM d hh:mm:ss yyyy")));
      fflush(m_File);
    } else {
      printMessage("Couldn't open log file");
      set_Enabled(false);
    }
  }
}

void QPidLogger::onFilenameChanged(QString /*name*/, int /*n*/)
{
  if (m_File) {
    fclose(m_File);

    m_File = NULL;
  }
}

void QPidLogger::printMessage(QString msg, QDateTime ts)
{
  QPidControllerPtr ctl(m_Controller);

  if (ctl) {
    ctl->printMessage(msg, ts);
  }
}

void QPidLogger::writeSettings(QSettings *set, QString section)
{
  QcepProperty::writeSettings(this, &staticMetaObject, section, set);
}

void QPidLogger::readSettings(QSettings *set, QString section)
{
  QcepProperty::readSettings(this, &staticMetaObject, section, set);
}