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 "ace/High_Res_Timer.h"

#include "madara/knowledge/KnowledgeRecord.h"
#include "madara/knowledge/Functions.h"
#include "madara/utility/stdint.h"
#include "madara/MADARA_export.h"
#include "madara/transport/TransportContext.h"
#include "madara/knowledge/ExternFunctionVariables.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_