cxReporterThread.cpp

Go to the documentation of this file.

/*=========================================================================
This file is part of CustusX, an Image Guided Therapy Application.
                 
Copyright (c) SINTEF Department of Medical Technology.
All rights reserved.
                 
CustusX is released under a BSD 3-Clause license.
                 
See Lisence.txt (https://github.com/SINTEFMedtek/CustusX/blob/master/License.txt) for details.
=========================================================================*/

#include "cxReporterThread.h"
#include "cxReporter.h"
#include "cxLogger.h"
#include <QtGlobal>
#include <iostream>
#include "boost/bind.hpp"
#include "boost/shared_ptr.hpp"
#include <QString>
#include <QMutex>
#include <QSound>
#include <QDir>
#include <QTextStream>
#include <QTimer>
#include "cxTypeConversions.h"
#include "cxDefinitionStrings.h"
#include "cxTime.h"
#include "cxMessageListener.h"

#include "cxLogQDebugRedirecter.h"
#include "cxLogIOStreamRedirecter.h"
#include "cxReporterMessageRepository.h"
#include "cxTime.h"
#include "cxLogFile.h"

namespace cx
{

ReporterThread::ReporterThread(QObject *parent) :
        LogThread(parent)
{
        qInstallMessageHandler(convertQtMessagesToCxMessages);
        qRegisterMetaType<Message>("Message");

        connect(this, &LogThread::emittedMessage, this, &ReporterThread::onMessageEmitted);

        // make sure streams are closed properly before reconnecting.
        mCout.reset();
        mCerr.reset();

        mCout.reset(new SingleStreamerImpl(std::cout, mlCOUT));
        mCerr.reset(new SingleStreamerImpl(std::cerr, mlCERR));
}

ReporterThread::~ReporterThread()
{
        qInstallMessageHandler(0);
        mCout.reset();
        mCerr.reset();
}

bool ReporterThread::initializeLogFile(LogFile file)
{
        QString filename = file.getFilename();
        if (mInitializedFiles.contains(filename))
                return true;

        mInitializedFiles << filename;

        file.writeHeader();

        if (!file.isWritable())
        {
                this->processMessage(Message("Failed to open log file " + filename, mlERROR));
                return false;
        }

        return true;
}

void ReporterThread::executeSetLoggingFolder(QString absoluteLoggingFolderPath)
{
        mLogPath = absoluteLoggingFolderPath;

        QFileInfo(mLogPath+"/").absoluteDir().mkpath(".");

//      this->initializeLogFile(this->getFilenameForChannel("console"));
//      this->initializeLogFile(this->getFilenameForChannel("all"));

        this->initializeLogFile(LogFile::fromChannel(mLogPath, "console"));
        this->initializeLogFile(LogFile::fromChannel(mLogPath, "all"));
}

void ReporterThread::logMessage(Message msg)
{
        // send in calling thread- this helps if the app
        // is about to crash and we need debug info.
        this->sendToCout(msg);

        QMetaObject::invokeMethod(this, "processMessage",
                                                          Qt::QueuedConnection,
                                                          Q_ARG(Message, msg));
}

void ReporterThread::onMessageEmitted(Message msg)
{
        //      this->sendToCout(message);
        this->sendToFile(msg);
}

void ReporterThread::sendToFile(Message message)
{
        if (message.getMessageLevel()==mlVOLATILE)
                return;

//      QString channelFile = this->getFilenameForChannel(message.mChannel);
        LogFile channelLog = LogFile::fromChannel(mLogPath, message.mChannel);
        LogFile allLog = LogFile::fromChannel(mLogPath, "all");

        this->initializeLogFile(channelLog);

        channelLog.write(message);
        allLog.write(message);
}

void ReporterThread::sendToCout(Message message)
{
        if (!mCout)
                return;
        if (message.getMessageLevel()==mlVOLATILE)
                return;
        if (( message.getMessageLevel() == mlCOUT )||( message.getMessageLevel() == mlCERR ))
                return;

        mCout->sendUnredirected(message.getPrintableMessage()+"\n");
}

} //End namespace cx