NDPluginAttrPlot.h

Go to the documentation of this file.

#ifndef NDATTRPLOT_H_
#define NDATTRPLOT_H_

#include "CircularBuffer.h"

#include <NDPluginDriver.h>
#include <epicsThread.h>

#include <string>
#include <vector>

#define NDAttrPlotDataString        "AP_Data"
#define NDAttrPlotDataLabelString   "AP_DataLabel"
#define NDAttrPlotDataSelectString  "AP_DataSelect"
#define NDAttrPlotAttributeString   "AP_Attribute"
#define NDAttrPlotResetString       "AP_Reset"
#define NDAttrPlotNPtsString        "AP_NPts"

#define ND_ATTRPLOT_UID_INDEX        -1
#define ND_ATTRPLOT_UID_LABEL        "UID"
#define ND_ATTRPLOT_NONE_INDEX       -2
#define ND_ATTRPLOT_NONE_LABEL       "None"

#define ND_ATTRPLOT_DATA_EXPOSURE_PERIOD 1. // Data callback period in seconds

class NDPluginAttrPlot;

class ExposeDataTask : public epicsThreadRunable
{
public:
    ExposeDataTask(NDPluginAttrPlot& plugin);

    void run();

    void start();

    void stop();

private:
    NDPluginAttrPlot& plugin_;

    bool stop_;

    epicsThread thread_;
};

class NDPluginAttrPlot : public NDPluginDriver
{
    typedef CircularBuffer<double> CB;

public:
    NDPluginAttrPlot(const char * port, int max_attributes, int cache_size,
            int max_selected, const char * in_port, int in_addr, int queue_size,
            int blocking_callbacks, int priority, int stackSize);

    void start_expose();

    friend class ExposeDataTask;

public:
    void processCallbacks(NDArray * pArray);

    asynStatus writeInt32(asynUser * pasynUser, epicsInt32 value);

protected:
    int NDAttrPlotData;
#define NDATTRPLOT_FIRST_PARAM NDAttrPlotData
    int NDAttrPlotDataLabel;
    int NDAttrPlotDataSelect;
    int NDAttrPlotAttribute;
    int NDAttrPlotReset;
    int NDAttrPlotNPts;
#define NDATTRPLOT_LAST_PARAM NDAttrPlotNPts
#define NUM_NDATTRPLOT_PARAMS (&NDATTRPLOT_LAST_PARAM - \
                               &NDATTRPLOT_FIRST_PARAM + 1)

private:
    enum NDAttrPlotState {
        NDAttrPlot_InitState,
        NDAttrPlot_ActiveState
    };

    void rebuild_attributes(NDAttributeList& attr_list);

    void reset_data();

    asynStatus push_data(epicsInt32 uid, NDAttributeList& attr_list);

    void callback_data();

    void callback_attributes();

    void callback_selected();

private:
    NDAttrPlotState state_;

    std::vector<CB> data_;

    CB uids_;

    const size_t n_attributes_;

    std::vector<std::string> attributes_;

    const unsigned n_data_blocks_;
    std::vector<int> data_selections_;

    ExposeDataTask expose_task_;
};

#endif // NDATTRPLOT_H_