RpcEventBuilder.h

Go to the documentation of this file.

#ifndef DYBDAQ_RPC_EVENT_BUILDER_H
#define DYBDAQ_RPC_EVENT_BUILDER_H

#include <list>
#include <stdint.h>

namespace DybDaq {

class RecordBuffer;
class RecordParser;
class PackedRpcEvent;

class EventBuilder
{
    public :

        EventBuilder();
        virtual ~EventBuilder();

        virtual int  size();
        virtual bool empty();
        virtual int  add(RecordBuffer* record);

        virtual RecordBuffer* front();
        virtual RecordBuffer* pop_front();


    protected:

        int   m_size;
        std::list<RecordBuffer*> m_records;
};

class RpcEventBuilder : public EventBuilder
{
    public :

        RpcEventBuilder(RecordParser* parser);
        virtual ~RpcEventBuilder();

        int  size();
        bool empty();
        int  add(RecordBuffer* record);

        RecordBuffer* front();
        RecordBuffer* pop_front();

        void  purge();


    private :

        class ElementList {
            public :
                ElementList(int elementSize);
                virtual ~ElementList();

                bool empty();
                uint32_t* front();
                uint32_t* pre_front();
                void pop_front();
                void push_back(const uint32_t* element);

            private :
                typedef std::list<uint32_t*>::iterator element_iterator;

                int                  m_elementsSize;
                std::list<uint32_t*> m_elements;
                element_iterator     m_begin;
                element_iterator     m_end;

                ElementList();
        };

    private :

        void  tryPack(bool forced = false);

        ElementList**  m_rtm;
        ElementList*** m_fec;

        int            m_totRtm;
        int            m_totFec;

        bool             m_fresh;
        RecordParser*    m_parser;
        PackedRpcEvent*  m_target;

        RpcEventBuilder();  //is not supported
};

}  // namespace DybDaq
#endif