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_