In This Package:

RtmReadout.cc

Go to the documentation of this file.

#include "RtmReadoutFormat/RtmReadout.h"
#include "RtmReadoutFormat/RtmTraits.h"
#include "RtmReadoutFormat/RtmData.h"
#include "DaqReadoutFormat/ByteBuffer.h"

using DybDaq::DaqBuffer;
using DybDaq::DaqTraits;
using DybDaq::RtmData;
using DybDaq::RtmTraits;
using DybDaq::RtmReadout;


RtmReadout::RtmReadout(const RtmTraits& traits)
   : DaqContainer(),
     m_rtmList(0),
     m_verFormat(0),
     m_rtmTraits(&traits)
{
}

RtmReadout::RtmReadout(const ByteBuffer& byteBuffer,
                       const unsigned int bufferSize,
                       const unsigned int verFormat)
   : DaqContainer(byteBuffer, bufferSize),
     m_rtmList(0),
     m_verFormat(verFormat),
     m_rtmTraits(0)
{
   byteBuffer.position( byteBuffer.position() + bufferSize * kBytesInInt );
}

RtmReadout::~RtmReadout()
{
   if ( m_rtmList != 0 ) {
      RtmDataPtrList::iterator it = m_rtmList->begin();
      while ( it != m_rtmList->end() ) {
         delete *it;
         ++it;
      }
      delete m_rtmList;
   }
}

const DaqTraits& RtmReadout::daqTraits() const
{
   return rtmTraits();
}

const RtmReadout::RtmDataPtrList& RtmReadout::rtmDataList() const
{
   if ( m_rtmList == 0 ) {
      m_rtmList = new RtmDataPtrList();
      if ( hasByteBuffer() ) {
         const RtmTraits& traits = rtmTraits();
         const ByteBuffer& buffer = byteBuffer();

         const unsigned int originalPosition = buffer.position();
         buffer.position( begin() );
         const unsigned int finished = containerSize() / traits.rtmSize();
         for ( unsigned int count = 0; count != finished; ++count ) {
            RtmData* rtmData = new RtmData(buffer, traits);
            m_rtmList->push_back(rtmData);
         }
         buffer.position( originalPosition );
      }
   }
   return *m_rtmList;
}

unsigned int RtmReadout::romSize() const
{
   return bufferSize();
}

unsigned int RtmReadout::gatherRom(OutputBufferList& outputBuffers) const
{
   return gather(outputBuffers);
}

unsigned int RtmReadout::inspectRom(DaqBuffer::Bytes& inspectors) const
{
    return inspect(inspectors);
}

unsigned int RtmReadout::bufferSize() const
{
   unsigned int result = 0;
   const RtmDataPtrList& rtmList = rtmDataList();

   RtmDataPtrList::const_iterator it = rtmList.begin();
   while ( it != rtmList.end() ) {
      result += (*it)->bufferSize();
      ++it;
   }

   return result;
}

const RtmData& RtmReadout::addRtmData(const unsigned int rpcCFId,
                                      const bool transErr,
                                      const bool romAlmostFull,
                                      const bool rtmAlmostFull,
                                      const bool fullFlag,
                                      const bool validGPS,
                                      const bool validCLK,
                                      const bool usingUTC,
                                      const unsigned int second,
                                      const unsigned int nanoSecond,
                                      const unsigned int accumulation,
                                      const unsigned int triggerRot,
                                      const unsigned int triggerMap)
{
   RtmData* result = new RtmData(rpcCFId,
                                 transErr,
                                 romAlmostFull,
                                 rtmAlmostFull,
                                 fullFlag,
                                 validGPS,
                                 validCLK,
                                 usingUTC,
                                 second,
                                 nanoSecond,
                                 accumulation,
                                 triggerRot,
                                 triggerMap,
                                 rtmTraits() );
   return add( result );
}

unsigned int RtmReadout::gatherComponents(OutputBufferList& outputBuffers) const 
{
   unsigned int result = 0;
   const RtmDataPtrList& rtmList = rtmDataList();

   RtmDataPtrList::const_iterator it = rtmList.begin();
   while ( it != rtmList.end() ) {
      result += (*it)->gather(outputBuffers);
      ++it;
   }

   return result;
}

unsigned int RtmReadout::inspectComponents(DaqBuffer::Bytes& inspectors) const
{
    unsigned int result = 0;
    const RtmDataPtrList& rtmList = rtmDataList();
    
    RtmDataPtrList::const_iterator it = rtmList.begin();
    while ( it != rtmList.end() ) {
        result += (*it)->inspect(inspectors);
        ++it;
    }
    
    return result;
}

void RtmReadout::expanded(const unsigned int size)
{
   notifyExpandable(size);
}

bool RtmReadout::setRomExpandable(DaqExpandable& expandable)
{
   return setExpandable(expandable);
}

const RtmTraits& RtmReadout::rtmTraits() const
{
   if ( m_rtmTraits == 0 ) {
      m_rtmTraits = RtmTraits::getTraits(m_verFormat);
   }
   return *m_rtmTraits;
}

const RtmData& RtmReadout::add(const RtmData* rtmData)
{
   if ( m_rtmList == 0 ) {
      m_rtmList = new RtmDataPtrList();
   }

   m_rtmList->push_back(rtmData);
   expanded( rtmData->bufferSize() );

   return *rtmData;
}

---