Diagnostics.cpp

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#include <fesa-core/Diagnostic/Diagnostics.h>

#include <fesa-core/Diagnostic/AbstractUserDiagnostics.h>
#include <fesa-core/Utilities/Thread.h>

#include <iostream>


namespace fesa
{

Diagnostics::Diagnostics(const FrameworkDiagnostics& frameworkDiagnostics, const boost::shared_ptr<AbstractUserDiagnostics>& userDiagnostics) :
    frameworkDiagnostics_(frameworkDiagnostics),
    userDiagnostics_(userDiagnostics)
{
}
    

Diagnostics::~Diagnostics()
{
}


const DiagnosticUtils::DiagnosticTopics&
Diagnostics::getTopics(DiagnosticUtils::Side side) const
{
    switch (side)
    {
        case DiagnosticUtils::framework:
            return frameworkDiagnostics_.getTopics();
        case DiagnosticUtils::user:
            return userDiagnostics_.get()->getTopics();
        default:
            assert(false);
    }
}


void
Diagnostics::log(const std::string& topic, DiagnosticUtils::DiagnosticMessage& diagMsg)
{
//    diagMsg.thread = Thread::getThreadName(pthread_self());
    std::string extendedTopic(topic);
    if (diagMsg.name.empty() == false)
    {
        extendedTopic.append("." + diagMsg.name);
    }
    switch (diagMsg.side)
    {
        case DiagnosticUtils::framework:
            frameworkDiagnostics_.log(extendedTopic, diagMsg);
            break;
        case DiagnosticUtils::user:
            userDiagnostics_->log(extendedTopic, diagMsg);
            break;
        default:
            assert(false);
    }
}


void
Diagnostics::enable(DiagnosticUtils::Side side, const std::string& topic) const
{
    switch (side)
    {
        case DiagnosticUtils::framework:
            frameworkDiagnostics_.enable(topic);
            break;
        case DiagnosticUtils::user:
            return userDiagnostics_.get()->enable(topic);
            break;
        default:
            assert(false);
    }
}


void
Diagnostics::disable(DiagnosticUtils::Side side, const std::string& topic) const
{
    switch (side)
    {
        case DiagnosticUtils::framework:
            frameworkDiagnostics_.disable(topic);
            break;
        case DiagnosticUtils::user:
            return userDiagnostics_.get()->disable(topic);
            break;
        default:
            assert(false);
    }
}

} // fesa