CounterFilter.h

Go to the documentation of this file.

 
 
#ifndef _MADARA_FILTERS_COUNTER_FILTER_H_
#define _MADARA_FILTERS_COUNTER_FILTER_H_
 
#include <string>
#include <vector>
#include <map>
#include <list>
 
#include "madara/knowledge/KnowledgeRecord.h"
#include "madara/knowledge/Functions.h"
#include "madara/utility/StdInt.h"
#include "madara/MadaraExport.h"
#include "madara/transport/TransportContext.h"
#include "madara/knowledge/Variables.h"
#include "madara/knowledge/containers/Integer.h"
 
#include "AggregateFilter.h"
 
namespace madara
{
namespace filters
{
class MADARA_EXPORT CounterFilter : public AggregateFilter
{
public:
  CounterFilter();
 
  virtual ~CounterFilter();
 
  virtual void filter(knowledge::KnowledgeMap& records,
      const transport::TransportContext& transport_context,
      knowledge::Variables& vars);
 
  inline knowledge::KnowledgeRecord::Integer get_count();
 
  inline knowledge::KnowledgeRecord::Integer get_elapsed();
 
  inline double get_throughput();
 
protected:
  bool initialized_;
 
  knowledge::KnowledgeRecord::Integer packets_;
 
  knowledge::KnowledgeRecord::Integer first_message_;
 
  knowledge::KnowledgeRecord::Integer last_message_;
};
}
}
 
#include "CounterFilter.inl"
 
#endif  // _MADARA_FILTERS_COUNTER_FILTER_H_