drvemTSBuffer.h

Go to the documentation of this file.

/*************************************************************************\
* Copyright (c) 2020 Michael Davidsaver
* mrfioc2 is distributed subject to a Software License Agreement found
* in file LICENSE that is included with this distribution.
\*************************************************************************/
#ifndef DRVEMTSBUFFER_H
#define DRVEMTSBUFFER_H

#include <vector>
#include <utility> // std::pair

#include <dbScan.h>

#include "mrf/object.h"

class EVRMRM;

struct EVRMRMTSBuffer : public mrf::ObjectInst<EVRMRMTSBuffer>
{
    typedef mrf::ObjectInst<EVRMRMTSBuffer> base_t;

    explicit EVRMRMTSBuffer(const std::string& n, EVRMRM* evr);
    virtual ~EVRMRMTSBuffer();

    virtual void lock() const OVERRIDE FINAL;
    virtual void unlock() const OVERRIDE FINAL;

    epicsUInt32 dropCount() const { return dropped; }

    epicsUInt16 timeEvent() const { return timeEvt; }
    void flushTimeSet(epicsUInt16 v);

    epicsUInt16 flushEvent() const { return flushEvt; }
    void flushEventSet(epicsUInt16 v);

    void flushNow();
    void doFlush();

    epicsUInt32 getTimesRelFirst(epicsInt32 *arr, epicsUInt32 count) const;
    epicsUInt32 getTimesRelFlush(epicsInt32 *arr, epicsUInt32 count) const;
    epicsUInt32 getTimesRelPrevFlush(epicsInt32 *arr, epicsUInt32 count) const;

    IOSCANPVT flushed() const { return scan; }

    EVRMRM* const evr;

    epicsUInt32 dropped;

    IOSCANPVT scan;

    epicsUInt8 timeEvt;
    epicsUInt8 flushEvt;

    struct ebuf_t {
        size_t pos;
        std::vector<epicsTimeStamp> buf;
        epicsTimeStamp flushtime, prevflushtime;
        bool ok, prevok;
        bool drop;
        ebuf_t() :pos(0u), ok(false), prevok(false), drop(false) {
            flushtime.secPastEpoch = 0u;
            flushtime.nsec = 0u;
            prevflushtime = flushtime;
        }
    private:
        ebuf_t(const ebuf_t&);
    } ebufs[2];
    // active buffer being filled.  Other is for readout.
    // must lock both evr and this mutex to change.
    unsigned char active; // either 0 or 1
};

#endif // DRVEMTSBUFFER_H