NotificationThreadFactory.cpp

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#include <fesa-core/RDADeviceServer/NotificationThreadFactory.h>
#include <fesa-core/RDADeviceServer/NotificationThread.h>

#include <iostream>

#include <cmw-log/Logger.h>

namespace
{
CMW::Log::Logger& logger = CMW::Log::LoggerFactory::getLogger("FESA.FWK.fesa-core.RDADeviceServer");
}



namespace fesa
{

NotificationThreadFactory::NotificationThreadFactory()
{
}

NotificationThreadFactory::~NotificationThreadFactory()
{
}

NotificationThread& NotificationThreadFactory::getThread(const std::string& className, const std::string& notificationThreadKey)
{
    std::map<std::string, boost::shared_ptr<NotificationThread> >::iterator iter;
    // key of the map = className + notificationThreadKey
    std::string key = className + notificationThreadKey;
    iter = threadPool_.find(key);
    if (iter != threadPool_.end()) // Thread was found in the collection
    {
        return *((*iter).second.get());
    }
    else // We need to create a new Notification thread for such notificationThreadKey
    {
        if(logger.isLoggable(CMW::Log::Level::LL_DEBUG))
        {
            std::ostringstream msg;
            msg << "creating new notification thread with key: " << key;
            LOG_DEBUG_IF(logger, msg.str());
        }
        boost::shared_ptr<NotificationThread> thread(new NotificationThread(className, notificationThreadKey));
        threadPool_.insert(std::make_pair(key, thread));
        return *(thread.get());
    }
}
} // fesa