API
 
Loading...
Searching...
No Matches
telem_saving.hpp
Go to the documentation of this file.
1/** \file telem_saving.hpp
2 * \brief The MagAO-X logger telem_saving log type.
3 * \author Jared R. Males (jaredmales@gmail.com)
4 *
5 * \ingroup logger_types_files
6 *
7 * History:
8 * - 2019-05-04 created by JRM
9 */
10#ifndef logger_types_telem_saving_hpp
11#define logger_types_telem_saving_hpp
12
14#include "flatbuffer_log.hpp"
15
16namespace MagAOX
17{
18namespace logger
19{
20
21
22/// Log entry recording data saving statistics
23/** \ingroup logger_types
24 */
26{
27 ///The event code
29
30 ///The default level
32
33 static timespec lastRecord; ///< The time of the last time this log was recorded. Used by the telemetry system.
34
35 ///The type of the input message
36 struct messageT : public fbMessage
37 {
38 ///Construct from components
39 messageT( const uint32_t & rawSize,
40 const uint32_t & compressedSize,
41 const float & encodeRate,
42 const float & differenceRate,
43 const float & reorderRate,
44 const float & compressRate
45 )
46 {
47 auto fp = Createtelem_saving_fb(builder, rawSize,compressedSize, encodeRate, differenceRate, reorderRate, compressRate);
48 builder.Finish(fp);
49 }
50
51 };
52
53 static bool verify( flatlogs::bufferPtrT & logBuff, ///< [in] Buffer containing the flatbuffer serialized message.
54 flatlogs::msgLenT len ///< [in] length of msgBuffer.
55 )
56 {
57 auto verifier = flatbuffers::Verifier( static_cast<uint8_t*>(flatlogs::logHeader::messageBuffer(logBuff)), static_cast<size_t>(len));
58 return Verifytelem_saving_fbBuffer(verifier);
59 }
60
61 ///Get the message formatte for human consumption.
62 static std::string msgString( void * msgBuffer, /**< [in] Buffer containing the flatbuffer serialized message.*/
63 flatlogs::msgLenT len /**< [in] [unused] length of msgBuffer.*/
64 )
65 {
66 static_cast<void>(len);
67
68 auto fbs = Gettelem_saving_fb(msgBuffer);
69
70
71 std::stringstream s;
72 s << "Saved " << ((float)fbs->raw_size())/1048576.0 << " MB @ " << ((float) fbs->compressed_size() )/((float) fbs->raw_size()) << "%.";
73 return s.str();
74
75 }
76
77 static unsigned int raw_size( void * msgBuffer /**< [in] Buffer containing the flatbuffer serialized message.*/ )
78 {
79 auto fbs = Gettelem_saving_fb(msgBuffer);
80
81 return fbs->raw_size();
82 }
83
84 static unsigned int compressed_size( void * msgBuffer /**< [in] Buffer containing the flatbuffer serialized message.*/ )
85 {
86 auto fbs = Gettelem_saving_fb(msgBuffer);
87
88 return fbs->compressed_size();
89 }
90
91 static float encode_rate( void * msgBuffer /**< [in] Buffer containing the flatbuffer serialized message.*/ )
92 {
93 auto fbs = Gettelem_saving_fb(msgBuffer);
94
95 return fbs->encode_rate();
96 }
97
98 static float difference_rate( void * msgBuffer /**< [in] Buffer containing the flatbuffer serialized message.*/ )
99 {
100 auto fbs = Gettelem_saving_fb(msgBuffer);
101
102 return fbs->difference_rate();
103 }
104
105 static float reorder_rate( void * msgBuffer /**< [in] Buffer containing the flatbuffer serialized message.*/ )
106 {
107 auto fbs = Gettelem_saving_fb(msgBuffer);
108
109 return fbs->reorder_rate();
110 }
111
112 static float compress_rate( void * msgBuffer /**< [in] Buffer containing the flatbuffer serialized message.*/ )
113 {
114 auto fbs = Gettelem_saving_fb(msgBuffer);
115
116 return fbs->compress_rate();
117 }
118
119 /// Get the logMetaDetail for a member by name
120 /**
121 * \returns the a logMetaDetail filled in with the appropriate details
122 * \returns an empty logMetaDetail if member not recognized
123 */
124 static logMetaDetail getAccessor( const std::string & member /**< [in] the name of the member */ )
125 {
126 if( member == "raw_size") return logMetaDetail({"RAW SIZE", "archive raw sized", logMeta::valTypes::UInt, logMeta::metaTypes::State, reinterpret_cast<void*>(&raw_size), false});
127 else if( member == "compressed_size") return logMetaDetail({"COMPRESSED SIZE", "archive compressed sized", logMeta::valTypes::UInt, logMeta::metaTypes::State, reinterpret_cast<void*>(&compressed_size), false});
128 else if( member == "encode_sate") return logMetaDetail({"ENCODE RATE", "encoding rate [MB/s]", logMeta::valTypes::Double, logMeta::metaTypes::State, reinterpret_cast<void*>(&encode_rate), false});
129 else if( member == "difference_rate") return logMetaDetail({"DIFFERENCING RATE", "differencing rate [MB/s]", logMeta::valTypes::Double, logMeta::metaTypes::State, reinterpret_cast<void*>(&difference_rate), false});
130 else if( member == "reorder_rate") return logMetaDetail({"REORDERING RATE", "reordering rate [MB/s]", logMeta::valTypes::Double, logMeta::metaTypes::State, reinterpret_cast<void*>(&reorder_rate), false});
131 else if( member == "compress_rate") return logMetaDetail({"COMPRESSION RATE", "compression rate [MB/s]", logMeta::valTypes::Double, logMeta::metaTypes::State, reinterpret_cast<void*>(&compress_rate), false});
132 else
133 {
134 std::cerr << "No member " << member << " in telem_saving\n";
135 return logMetaDetail();
136 }
137 }
138
139}; //telem_saving
140
141
142} //namespace logger
143} //namespace MagAOX
144
145#endif //logger_types_telem_saving_hpp
The MagAO-X logger flatbuffer log base type.
uint16_t eventCodeT
The type of an event code (16-bit unsigned int).
Definition logDefs.hpp:40
msgLen2T msgLenT
The type used to refer to the message length, regardless of length.
Definition logDefs.hpp:69
int8_t logPrioT
The type of the log priority code.
Definition logDefs.hpp:21
static void * messageBuffer(bufferPtrT &logBuffer)
Get the message buffer address.
std::shared_ptr< char > bufferPtrT
The log entry buffer smart pointer.
Definition logHeader.hpp:58
static constexpr flatlogs::eventCodeT TELEM_SAVING
Definition logCodes.hpp:32
inline ::flatbuffers::Offset< telem_saving_fb > Createtelem_saving_fb(::flatbuffers::FlatBufferBuilder &_fbb, uint32_t raw_size=0, uint32_t compressed_size=0, float encode_rate=0.0f, float difference_rate=0.0f, float reorder_rate=0.0f, float compress_rate=0.0f)
bool Verifytelem_saving_fbBuffer(::flatbuffers::Verifier &verifier)
const MagAOX::logger::telem_saving_fb * Gettelem_saving_fb(const void *buf)
Definition dm.hpp:28
static constexpr logPrioT LOG_TELEM
A telemetry recording.
Message type for resolving log messages with a f.b. builder.
flatbuffers::FlatBufferBuilder builder
Base class for logs consisting of a flatbuffer message.
The type of the input message.
messageT(const uint32_t &rawSize, const uint32_t &compressedSize, const float &encodeRate, const float &differenceRate, const float &reorderRate, const float &compressRate)
Construct from components.
Log entry recording data saving statistics.
static float encode_rate(void *msgBuffer)
static logMetaDetail getAccessor(const std::string &member)
Get the logMetaDetail for a member by name.
static const flatlogs::eventCodeT eventCode
The event code.
static float reorder_rate(void *msgBuffer)
static unsigned int raw_size(void *msgBuffer)
static std::string msgString(void *msgBuffer, flatlogs::msgLenT len)
Get the message formatte for human consumption.
static float difference_rate(void *msgBuffer)
static const flatlogs::logPrioT defaultLevel
The default level.
static timespec lastRecord
The time of the last time this log was recorded. Used by the telemetry system.
static float compress_rate(void *msgBuffer)
static bool verify(flatlogs::bufferPtrT &logBuff, flatlogs::msgLenT len)
static unsigned int compressed_size(void *msgBuffer)