CircularBuffer.cxx

Go to the documentation of this file.

#include "CircularBuffer.h"

#include "DataSourceException.h"

using std::string;

CircularBuffer::CircularBuffer ( const std::string & filename )
  : NTuple ( filename ),
    m_capacity ( 0 ),
    m_next_row ( 0 ),
    m_has_filled ( false )
{
}

CircularBuffer::CircularBuffer ( const std::vector< std::string >  & v )
  : NTuple ( v ),
    m_capacity ( 0 ),
    m_next_row ( 0 ),
    m_has_filled ( false )
{
}

CircularBuffer::CircularBuffer ( const CircularBuffer & nt )
  : NTuple ( nt ),
    m_capacity ( nt.m_capacity ),
    m_next_row ( nt.m_next_row ),
    m_has_filled ( nt.m_has_filled )
{
}

CircularBuffer::CircularBuffer ( unsigned int n )
  : NTuple ( n ),
    m_capacity ( 0 ),
    m_next_row ( 0 ),
    m_has_filled ( false )
{
}

CircularBuffer::CircularBuffer ()
  : NTuple (),
    m_capacity ( 0 ),
    m_next_row ( 0 ),
    m_has_filled ( false )
{
}

void CircularBuffer::clear()
{
  m_next_row = 0;
  m_has_filled = false;

  NTuple::clear ();
}

void
CircularBuffer::
incrementRowIndex ()
{
  m_next_row++;
  if ( m_next_row == m_capacity ) {
    m_next_row = 0;
    m_has_filled = true;
  }
}

void
CircularBuffer::
addRow ( const std::vector< double > & v )
{
  if ( m_has_filled ) {
    NTuple::replaceRow ( m_next_row, v );
  }
  else {
    NTuple::addRow ( v );
  }

  incrementRowIndex ( );
}

void CircularBuffer::reserve ( unsigned int count )
{
  if ( empty () == false ) {
    const string what ( "CircularBuffer: Attempt to set the capacity of "
                        "non-empty buffer is not allowed" );
    throw DataSourceException ( what );
  }

  NTuple::reserve ( count );
  m_capacity = count;
}

---