Processor.hpp

/*
 * (c) Copyright, Real-Time Innovations, 2017.
 * All rights reserved.
 *
 * No duplications, whole or partial, manual or electronic, may be made
 * without express written permission.  Any such copies, or
 * revisions thereof, must display this notice unaltered.
 * This code contains trade secrets of Real-Time Innovations, Inc.
 */
 
#ifndef RTI_ROUTING_PROCESSOR_PROCESSOR_HPP_
#define RTI_ROUTING_PROCESSOR_PROCESSOR_HPP_
 
#include <dds/core/Value.hpp>
#include <dds/core/SafeEnumeration.hpp>
#include <rti/core/NativeValueType.hpp>
 
#include "routingservice/routingservice_processor.h"
 
#include <rti/routing/processor/Route.hpp>
#include <rti/routing/UpdatableEntity.hpp>
 
namespace rti { namespace routing { namespace processor {
 
class Processor : public rti::routing::UpdatableEntity {
public:
 
 
    virtual void on_input_enabled(
            Route& route,
            rti::routing::processor::Input& input) = 0;
 
    virtual void on_input_disabled(
            Route& route,
            rti::routing::processor::Input& input) = 0;
 
    virtual void on_output_enabled(
            Route& route,
            rti::routing::processor::Output& output) = 0;
 
    virtual void on_output_disabled(
            Route& route,
            rti::routing::processor::Output& output) = 0;
 
    virtual void on_start(Route& route) = 0;
 
    virtual void on_stop(Route& route) = 0;
 
    virtual void on_run(Route& route) = 0;
 
    virtual void on_pause(Route& route) = 0;
 
    virtual void on_periodic_action(Route& route) = 0;
 
    virtual void on_data_available(Route& route) = 0;
 
    virtual ~Processor() {}
};
 
 
class NoOpProcessor : public Processor {
 
 
    virtual void on_input_enabled(Route&, rti::routing::processor::Input&)
    {
    }
 
    virtual void on_input_disabled(Route&, rti::routing::processor::Input&)
    {
    }
 
    virtual void on_output_enabled(Route&, rti::routing::processor::Output&)
    {
    }
 
    virtual void on_output_disabled(Route&, rti::routing::processor::Output&)
    {
    }
 
    virtual void on_start(Route&)
    {
    }
 
    virtual void on_stop(Route&)
    {
    }
 
    virtual void on_run(Route&)
    {
    }
 
    virtual void on_pause(Route&)
    {
    }
 
 
    virtual void on_data_available(Route&)
    {
    }
 
 
    virtual void on_periodic_action(Route&)
    {
    }
 
};
 
} } }
 
 
#endif // RTI_ROUTING_PROCESSOR_PROCESSOR_HPP_