PacketScheduler.h

Go to the documentation of this file.

 
 
#ifndef _MADARA_PACKET_SCHEDULER_H_
#define _MADARA_PACKET_SCHEDULER_H_
 
#include <deque>
#include <queue>
#include <time.h>
 
#include "madara/LockType.h"
#include "madara/utility/StdInt.h"
#include "madara/MadaraExport.h"
#include "madara/transport/QoSTransportSettings.h"
 
class StrideTask;
 
namespace madara
{
namespace transport
{
class MADARA_EXPORT PacketScheduler
{
public:
  PacketScheduler(const QoSTransportSettings* settings = 0);
 
  PacketScheduler(const PacketScheduler& rhs);
 
  virtual ~PacketScheduler();
 
  void operator=(const PacketScheduler& rhs);
 
  bool add(void);
 
  void attach(const QoSTransportSettings* settings);
 
  uint64_t get_dropped(void);
 
  uint64_t get_sent(void);
 
  void clear(void);
 
  void reset(void);
 
  void print_status(
      unsigned int log_level = 0, const char* prefix = "PacketScheduler");
 
protected:
  mutable MADARA_LOCK_TYPE mutex_;
 
  const QoSTransportSettings* settings_;
 
  uint64_t sent_messages_;
 
  uint64_t dropped_messages_;
 
  uint64_t consecutive_drops_;
 
  std::priority_queue<StrideTask, std::vector<StrideTask> > queue_;
};
}
}
 
#endif  // _MADARA_PACKET_SCHEDULER_H_