bufrxmgr.h

/*************************************************************************\
* 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