cxLog.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 "cxLog.h"

#include "cxLogger.h"
#include <QtGlobal>
#include <QThread>
#include <iostream>
#include "boost/shared_ptr.hpp"
#include <QString>
#include <QMutex>
#include <QSound>
#include <QDir>
#include <QTextStream>
#include "cxTypeConversions.h"
#include "cxTime.h"
#include "cxProfile.h"
#include "cxMessageListener.h"
#include "internal/cxLogThread.h"
#include "internal/cxReporterThread.h"
#include "QApplication"

namespace cx
{

class EventProcessingThread : public QThread
{
public:
        EventProcessingThread()
        {
        }
        virtual ~EventProcessingThread()
        {

        }

        virtual void run()
        {
                this->exec();
                qApp->processEvents(); // exec() docs doesn't guarantee that the posted events are processed. - do that here.
        }
};


Log::Log()
{
        mLogPath = this->getDefaultLogPath();
}

Log::~Log()
{
        this->stopThread();
}

QString Log::getDefaultLogPath() const
{
        QString isoDateFormat("yyyy-MM-dd");
        QString isoDate = QDateTime::currentDateTime().toString(isoDateFormat);
        QString retval = ProfileManager::getInstance()->getSettingsPath()+"/Logs/"+isoDate;
        return retval;
}

void Log::initializeObject()
{
        if (mThread)
                return;

        this->stopThread();
        this->startThread();
}

void Log::startThread()
{
        if (mThread)
                return;

        mThread.reset(new EventProcessingThread());
        mThread->setObjectName("org.custusx.resource.core.logger");

        mWorker = this->createWorker();
        mWorker->moveToThread(mThread.get());
        if (!mLogPath.isEmpty())
                mWorker->setLoggingFolder(mLogPath);
        connect(mWorker.get(), &LogThread::emittedMessage, this, &Log::onEmittedMessage);

        mThread->start();
}

void Log::stopThread()
{
        if (!mThread)
                return;

        disconnect(mWorker.get(), &LogThread::emittedMessage, this, &Log::onEmittedMessage);
        LogThreadPtr tempWorker = mWorker;
        mWorker.reset();

        mThread->quit();
        mThread->wait(); // forever or until dead thread

        mThread.reset();
        tempWorker.reset();
}

void Log::setLoggingFolder(QString absoluteLoggingFolderPath)
{
        mLogPath = absoluteLoggingFolderPath;
        if (mWorker)
                mWorker->setLoggingFolder(mLogPath);
        emit loggingFolderChanged();
}

QString Log::getLoggingFolder() const
{
        return mLogPath;
}

void Log::installObserver(MessageObserverPtr observer, bool resend)
{
        if (mWorker)
                mWorker->installObserver(observer, resend);
}

void Log::uninstallObserver(MessageObserverPtr observer)
{
        if (mWorker)
                mWorker->uninstallObserver(observer);
}

void Log::stopQtMessages()
{
        ReporterThreadPtr reporterThread = boost::dynamic_pointer_cast<ReporterThread>(mWorker);
        if (reporterThread)
                reporterThread->stopQtMessages();
        else
                CX_LOG_WARNING() << "Found no reporterThread";
}
void Log::startQtMessages()
{
        ReporterThreadPtr reporterThread = boost::dynamic_pointer_cast<ReporterThread>(mWorker);
        if (reporterThread)
                reporterThread->startQtMessages();
}


} //End namespace cx