input_base.cpp

Go to the documentation of this file.

// Copyright (C) 2011,2013 Lutz Foucar

/**
 * @file input_base.cpp contains the base class for all input modules
 *
 * @author Lutz Foucar
 */

#include "input_base.h"

#include "ratemeter.h"

using namespace cass;
using namespace std;

// ============define static members==============
InputBase::shared_pointer InputBase::_instance;
QMutex InputBase::_mutex;

InputBase::shared_pointer InputBase::instance()
{
  QMutexLocker lock(&_mutex);
  if(!_instance)
    throw logic_error("InputBase::instance(): is not created yet");
  return _instance;
}

InputBase::shared_pointer::element_type& InputBase::reference()
{
  QMutexLocker lock(&_mutex);
  if(!_instance)
    throw logic_error("InputBase::reference():is not created yet");
  return *_instance;
}
//===================================================

void InputBase::newEventAdded(const size_t eventsize)
{
  _ratemeter.count();
  _loadmeter.count(eventsize);
}

RingBuffer<CASSEvent>& InputBase::ringbuffer()
{
  return _ringbuffer;
}

InputBase::rbItem_t InputBase::getNextFillable(unsigned timeout)
{
  InputBase::rbItem_t rbItem(_ringbuffer.end());
  while ((rbItem = _ringbuffer.nextToFill(timeout)) == _ringbuffer.end())
    if (_control == _quit)
      break;
  return rbItem;
}

double InputBase::progress()
{
  return 0.;
}

uint64_t InputBase::eventcounter()
{
  return 0;
}

uint64_t InputBase::skippedeventcounter()
{
  return 0;
}