OpenCPN Partial API docs
|
Add unit test measurements to CommOutQueue. More...
#include <comm_out_queue.h>
Public Member Functions | |
MeasuredCommOutQueue (unsigned max_buffered, std::chrono::duration< unsigned, std::milli > min_msg_gap) | |
MeasuredCommOutQueue (unsigned max_buffered) | |
bool | push_back (const std::string &line) override |
Insert valid line of NMEA0183 data in buffer. More... | |
std::string | pop () override |
Return next line to send and remove it from buffer, throws exception if empty. | |
Public Member Functions inherited from CommOutQueue | |
virtual int | size () const |
Return number of lines in queue. | |
CommOutQueue (unsigned max_buffered, std::chrono::duration< unsigned, std::milli > min_msg_gap) | |
Create a buffer which stores at most max_buffered items of each message, applying rate limits if messages are entered "too" fast. More... | |
CommOutQueue (unsigned max_buffered) | |
Create a buffer which stores at most max_buffered items of each message. | |
CommOutQueue () | |
Default buffer, allows 10 buffered messages of each type, applies rate limits when repeated with less than 600 ms intervals. | |
CommOutQueue (const CommOutQueue &other)=delete | |
CommOutQueue & | operator= (const CommOutQueue &)=delete |
Public Attributes | |
std::unordered_map< unsigned long, PerfCounter > | msg_perf |
PerfCounter | perf |
double | push_time |
double | pop_time |
Additional Inherited Members | |
Protected Types inherited from CommOutQueue | |
using | duration_ms = std::chrono::duration< unsigned, std::milli > |
Protected Attributes inherited from CommOutQueue | |
std::vector< BufferItem > | m_buffer |
std::mutex | m_mutex |
int | m_size |
duration_ms | m_min_msg_gap |
bool | m_overrun_reported |
std::set< uint64_t > | m_rate_limits_logged |
Add unit test measurements to CommOutQueue.
Definition at line 154 of file comm_out_queue.h.
|
overridevirtual |
Insert valid line of NMEA0183 data in buffer.
Reimplemented from CommOutQueue.
Definition at line 151 of file comm_out_queue.cpp.