pipelineService.h

Go to the documentation of this file.

#ifndef PIPELINESERVICE_H
#define PIPELINESERVICE_H

#include <stdexcept>

#ifdef epicsExportSharedSymbols
#   define pipelineServiceEpicsExportSharedSymbols
#   undef epicsExportSharedSymbols
#endif

#include <pv/sharedPtr.h>
#include <pv/status.h>

#ifdef pipelineServiceEpicsExportSharedSymbols
#   define epicsExportSharedSymbols
#       undef pipelineServiceEpicsExportSharedSymbols
#endif

#include <pv/pvAccess.h>

#include <shareLib.h>

namespace epics {
namespace pvAccess {

class epicsShareClass PipelineControl
{
public:
    POINTER_DEFINITIONS(PipelineControl);

    virtual ~PipelineControl() {};

    virtual size_t getFreeElementCount() = 0;

    virtual size_t getRequestedCount() = 0;

    virtual MonitorElement::shared_pointer getFreeElement() = 0;

    virtual void putElement(MonitorElement::shared_pointer const & element) = 0;

    virtual void done() = 0;

};


class epicsShareClass PipelineSession
{
public:
    POINTER_DEFINITIONS(PipelineSession);

    virtual ~PipelineSession() {};

    virtual size_t getMinQueueSize() const = 0;

    virtual epics::pvData::Structure::const_shared_pointer getStructure() const = 0;

    virtual void request(PipelineControl::shared_pointer const & control, size_t elementCount) = 0;

    virtual void cancel() = 0;
};


class epicsShareClass PipelineService
{
public:
    POINTER_DEFINITIONS(PipelineService);

    virtual ~PipelineService() {};

    virtual PipelineSession::shared_pointer createPipeline(
        epics::pvData::PVStructure::shared_pointer const & pvRequest
    ) = 0;

};


}
}

#endif  /* PIPELINESERVICE_H */