CounterFilter.cpp

Go to the documentation of this file.

#include "CounterFilter.h"
#include "madara/utility/Utility.h"

namespace utility = madara::utility;
typedef madara::knowledge::KnowledgeRecord::Integer   Integer;

madara::filters::CounterFilter::CounterFilter ()
  : initialized_ (false),
  packets_ (0), first_message_ (-1), last_message_ (-1)
{
}

madara::filters::CounterFilter::~CounterFilter ()
{
}


void
madara::filters::CounterFilter::filter (
  knowledge::KnowledgeMap & /*records*/,
  const transport::TransportContext & transport_context,
  knowledge::Variables & /*vars*/)
{
  Integer cur_time = (Integer) transport_context.get_current_time ();

  if (!initialized_)
  {
    this->initialized_ = true;
    this->first_message_ = cur_time;
  }

  ++this->packets_;
  this->last_message_ = cur_time;
}