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 "ace/Guard_T.h"
#include "ace/Recursive_Thread_Mutex.h"
#include "madara/MADARA_export.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_