Notification.cpp

Go to the documentation of this file.

// Copyright CERN 2012 - Developed in collaboration with GSI

#include <fesa-core/RDADeviceServer/Notification.h>

#include <fesa-core/RDADeviceServer/SubscriptionParameter.h>
#include <fesa-core/Core/NotificationID.h>


namespace fesa
{

Notification::Notification(NotificationID& id) :
    id_(id)
{
}

void Notification::addSubscriber(boost::shared_ptr<SubscriptionParameter> sp)
{
    // Insert the subscriptionParameter if it's not already registered
    SubscriptionItr itr = subscriptions_.find(sp->getName());
    if(itr == subscriptions_.end())
    {
        subscriptions_[sp->getName()] = sp;
    }
}

void Notification::addCycle(const std::string& cycleSelector)
{
    // Update the subscriptionCycle list with the new cycleSelector
    subscriptionCycle_.addCycle(cycleSelector);
}

void Notification::removeSubscriber(boost::shared_ptr<SubscriptionParameter> sp, const std::string& cycleSelector, bool toBeDeleted)
{
    // Remove the subscriptionParameter
    SubscriptionItr itr = subscriptions_.find(sp->getName());
    if(itr != subscriptions_.end())
    {
        if (toBeDeleted)
            subscriptions_.erase(itr);
        // remove the newCycleSelector from subscriptionCycle
        subscriptionCycle_.removeCycle(cycleSelector);
    }
}

void Notification::notify(MultiplexingContext& muxContext, RequestType& reqType)
{
    // Check if any cycleSelector is matching the current context
    std::vector<std::string> validCS;
    // fill the validCS by calling matchContext
    subscriptionCycle_.matchContext(muxContext, validCS);

    if (validCS.size() != 0) // At least one registered cycleSelector is matching the current context
    {
        SubscriptionItr itr = subscriptions_.begin();
        SubscriptionItr itrEnd = subscriptions_.end();
        for(; itr != itrEnd; ++itr)
        {
            (*itr).second->notify(muxContext, reqType, validCS);
        }
    }
}

bool Notification::contains(const std::string& deviceName, const std::string &propName)
{
    return id_.contains(propName, deviceName);
}

void Notification::printDebugState(std::stringstream& str)
{
    str << "\t\tNotificationID: " << id_.getIDKey() << "\n";

    str << "\t\t\tSubscribers:\n";
    SubscriptionItr itr = subscriptions_.begin();
    SubscriptionItr itrEnd = subscriptions_.end();
    for(; itr != itrEnd; ++itr)
    {
        str << "\t\t\t\t" << (*itr).second->getName() << "\n";
    }

    str << "\t\t\tsubscriptionCycle:\n";
    subscriptionCycle_.printDebugState(str,4);
}


} // fesa