3 #ifndef _MADARA_PACKET_SCHEDULER_H_ 4 #define _MADARA_PACKET_SCHEDULER_H_ 18 #include "madara/LockType.h" 20 #include "madara/MadaraExport.h" 76 uint64_t get_dropped (
void);
83 uint64_t get_sent (
void);
102 void print_status (
unsigned int log_level = 0,
103 const char * prefix =
"PacketScheduler");
135 std::priority_queue <StrideTask, std::vector <StrideTask> >
queue_;
140 #endif // _MADARA_PACKET_SCHEDULER_H_ std::priority_queue< StrideTask, std::vector< StrideTask > > queue_
queue used by stride scheduling algorithm
uint64_t consecutive_drops_
Consecutive dropped messages.
Provides scheduler for dropping packets.
const QoSTransportSettings * settings_
Transport settings.
uint64_t dropped_messages_
Number of dropped messages.
MADARA_LOCK_TYPE mutex_
Mutex for supporting multithreaded monitor calls.
Container for quality-of-service settings.
Copyright (c) 2015 Carnegie Mellon University.
INTERNAL USE: Task that can be added to a Stride scheduler
uint64_t sent_messages_
Number of sent messages.