summaryrefslogtreecommitdiff
path: root/src/components/telemetry_monitor/src/transport_manager_observer.cc
diff options
context:
space:
mode:
Diffstat (limited to 'src/components/telemetry_monitor/src/transport_manager_observer.cc')
-rw-r--r--src/components/telemetry_monitor/src/transport_manager_observer.cc38
1 files changed, 21 insertions, 17 deletions
diff --git a/src/components/telemetry_monitor/src/transport_manager_observer.cc b/src/components/telemetry_monitor/src/transport_manager_observer.cc
index 36f0e3c75a..b3e57ac22a 100644
--- a/src/components/telemetry_monitor/src/transport_manager_observer.cc
+++ b/src/components/telemetry_monitor/src/transport_manager_observer.cc
@@ -38,26 +38,30 @@
namespace telemetry_monitor {
-TransportManagerObserver::TransportManagerObserver(TelemetryMonitor* telemetry_monitor):
- telemetry_monitor_ (telemetry_monitor) {
-}
+TransportManagerObserver::TransportManagerObserver(
+ TelemetryMonitor* telemetry_monitor)
+ : telemetry_monitor_(telemetry_monitor) {}
-void TransportManagerObserver::StartRawMsg(const protocol_handler::RawMessage* ptr) {
+void TransportManagerObserver::StartRawMsg(
+ const protocol_handler::RawMessage* ptr) {
time_starts[ptr] = date_time::DateTime::getCurrentTime();
}
-void TransportManagerObserver::StopRawMsg(const protocol_handler::RawMessage* ptr) {
- std::map<const protocol_handler::RawMessage*, TimevalStruct>::const_iterator it;
- it = time_starts.find(ptr);
- if (it != time_starts.end()) {
- TransportManagerMecticWrapper* m = new TransportManagerMecticWrapper();
- m->message_metric = new transport_manager::TMTelemetryObserver::MessageMetric();
- m->message_metric->begin = it->second;
- m->message_metric->end = date_time::DateTime::getCurrentTime();
- m->message_metric->data_size = ptr->data_size();
- m->grabResources();
- telemetry_monitor_->SendMetric(m);
- }
+void TransportManagerObserver::StopRawMsg(
+ const protocol_handler::RawMessage* ptr) {
+ std::map<const protocol_handler::RawMessage*, TimevalStruct>::const_iterator
+ it;
+ it = time_starts.find(ptr);
+ if (it != time_starts.end()) {
+ TransportManagerMecticWrapper* m = new TransportManagerMecticWrapper();
+ m->message_metric =
+ new transport_manager::TMTelemetryObserver::MessageMetric();
+ m->message_metric->begin = it->second;
+ m->message_metric->end = date_time::DateTime::getCurrentTime();
+ m->message_metric->data_size = ptr->data_size();
+ m->grabResources();
+ telemetry_monitor_->SendMetric(m);
+ }
}
-} //namespace telemetry_monitor
+} // namespace telemetry_monitor