/search.css" rel="stylesheet" type="text/css"/> /search.js">
| Classes | Job Modules | Data Objects | Services | Algorithms | Tools | Packages | Directories | Tracs |

In This Package:

Public Member Functions | Private Member Functions | Private Attributes
DybDaq::DaqFromRecordPool Class Reference

#include <DaqFromRecordPool.h>

Inheritance diagram for DybDaq::DaqFromRecordPool:
Inheritance graph
[legend]
Collaboration diagram for DybDaq::DaqFromRecordPool:
Collaboration graph
[legend]

List of all members.

Public Member Functions

 DaqFromRecordPool (std::vector< std::string >::const_iterator &begin, std::vector< std::string >::const_iterator &end)
virtual ~DaqFromRecordPool ()
const FileBuffernextRecord ()
 Returns the next record in the stream or NULL if the end of the stream has been reached.
void setRepackRpc (bool repackRpc)
void setTimeAlignment (bool timeAlignment)

Private Member Functions

 DaqFromRecordPool ()

Private Attributes

RawRecordPoolm_recordPool
DaqFormatFromBytesm_daqFromBytes
 The DaqFormatFromBytes used to parse the contents of the file.

Detailed Description

Definition at line 13 of file DaqFromRecordPool.h.


Constructor & Destructor Documentation

DaqFromRecordPool::DaqFromRecordPool ( std::vector< std::string >::const_iterator &  begin,
std::vector< std::string >::const_iterator &  end 
)

Definition at line 16 of file DaqFromRecordPool.cc.

DaqFromRecordPool::~DaqFromRecordPool ( ) [virtual]

Definition at line 23 of file DaqFromRecordPool.cc.

{
    delete m_daqFromBytes;
    if ( m_recordPool != 0 ) {
        delete m_recordPool;
    }
}
DybDaq::DaqFromRecordPool::DaqFromRecordPool ( ) [private]

Member Function Documentation

const FileBuffer * DaqFromRecordPool::nextRecord ( ) [virtual]

Returns the next record in the stream or NULL if the end of the stream has been reached.

Implements DybDaq::DaqFromStream.

Definition at line 31 of file DaqFromRecordPool.cc.

                                                {
    const FileBuffer* result = 0;

    RecordBuffer* record = m_recordPool->next();
    if ( record != 0 ) {
        ByteBuffer* buffer = new ByteBuffer(record->data(), record->size());
        result = m_daqFromBytes->createFileBuffer(buffer);
        if ( result == 0 ) {
            std::cout << __FILE__ << __LINE__
                      << ": should not at here, ERROR happened!" << std::endl;
            exit(1);
        }
        delete record;
    }

    return result;
}
void DaqFromRecordPool::setRepackRpc ( bool  repackRpc)

Definition at line 49 of file DaqFromRecordPool.cc.

{
    m_recordPool->setRepackRpc(repackRpc);
}
void DaqFromRecordPool::setTimeAlignment ( bool  timeAlignment)

Definition at line 54 of file DaqFromRecordPool.cc.

{
    m_recordPool->setTimeAlignment(timeAlignment);
}

Member Data Documentation

Definition at line 35 of file DaqFromRecordPool.h.

The DaqFormatFromBytes used to parse the contents of the file.

Definition at line 40 of file DaqFromRecordPool.h.


The documentation for this class was generated from the following files:
| Classes | Job Modules | Data Objects | Services | Algorithms | Tools | Packages | Directories | Tracs |

Generated on Fri May 16 2014 09:53:22 for FileReadoutFormat by doxygen 1.7.4