bufrxmgr.h

Go to the documentation of this file.

/*************************************************************************\
* Copyright (c) 2010 Brookhaven Science Associates, as Operator of
*     Brookhaven National Laboratory.
* Copyright (c) 2015 Paul Scherrer Institute (PSI), Villigen, Switzerland
* mrfioc2 is distributed subject to a Software License Agreement found
* in file LICENSE that is included with this distribution.
\*************************************************************************/
/*
 * Author: Michael Davidsaver <mdavidsaver@gmail.com>
 */

#ifndef BUFRXMGR_H_INC
#define BUFRXMGR_H_INC


#include <ellLib.h>
#include <callback.h>

#include "mrf/databuf.h"

class epicsShareClass bufRxManager : public dataBufRx
{
public:
    bufRxManager(const std::string&, unsigned int qdepth, unsigned int bsize=0);

    virtual ~bufRxManager();

    unsigned int bsize(){return m_bsize;};

    epicsUInt8* getFree(unsigned int*);

    void receive(epicsUInt8*,unsigned int);

    virtual void dataRxError(dataBufComplete, void*) OVERRIDE FINAL;

    virtual void dataRxAddReceive(dataBufComplete fptr, void* arg=0) OVERRIDE FINAL;

    virtual void dataRxDeleteReceive(dataBufComplete fptr, void* arg=0) OVERRIDE FINAL;

private:
    epicsMutex guard;

    struct listener {
        ELLNODE node;

        dataBufComplete fn;
        void *fnarg;
    };
    ELLLIST dispatch;

    dataBufComplete onerror;
    void* onerror_arg;

protected:
    void haderror(epicsStatus e){onerror(onerror_arg,e,0,NULL);}

private:
    ELLLIST freebufs;
    ELLLIST usedbufs;

    CALLBACK received_cb;
    static void received(CALLBACK*);

    struct buffer {
        ELLNODE node;
        unsigned int used;
        epicsUInt8 data[1]; 
    };

    const unsigned int m_bsize;
};

#endif // BUFRXMGR_H_INC