summaryrefslogtreecommitdiff
path: root/src/components/telemetry_monitor/include/telemetry_monitor/telemetry_monitor.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/components/telemetry_monitor/include/telemetry_monitor/telemetry_monitor.h')
-rw-r--r--src/components/telemetry_monitor/include/telemetry_monitor/telemetry_monitor.h16
1 files changed, 5 insertions, 11 deletions
diff --git a/src/components/telemetry_monitor/include/telemetry_monitor/telemetry_monitor.h b/src/components/telemetry_monitor/include/telemetry_monitor/telemetry_monitor.h
index 618901ffa8..ff7b9da9d6 100644
--- a/src/components/telemetry_monitor/include/telemetry_monitor/telemetry_monitor.h
+++ b/src/components/telemetry_monitor/include/telemetry_monitor/telemetry_monitor.h
@@ -46,11 +46,6 @@
#include "protocol_handler_observer.h"
#include "protocol_handler/protocol_handler_impl.h"
-namespace utils {
-template <typename T>
-class SharedPtr;
-}
-
namespace telemetry_monitor {
using ::utils::MessageQueue;
@@ -62,7 +57,7 @@ class Streamer : public threads::ThreadDelegate {
void threadMain() OVERRIDE;
void exitThreadMain() OVERRIDE;
- virtual void PushMessage(utils::SharedPtr<MetricWrapper> metric);
+ virtual void PushMessage(std::shared_ptr<MetricWrapper> metric);
volatile bool is_client_connected_;
private:
@@ -75,7 +70,7 @@ class Streamer : public threads::ThreadDelegate {
int32_t server_socket_fd_;
int32_t client_socket_fd_;
volatile bool stop_flag_;
- MessageQueue<utils::SharedPtr<MetricWrapper> > messages_;
+ MessageQueue<std::shared_ptr<MetricWrapper> > messages_;
DISALLOW_COPY_AND_ASSIGN(Streamer);
};
@@ -91,9 +86,8 @@ class TelemetryMonitor {
transport_manager);
virtual void Stop();
virtual void Start();
- virtual void SendMetric(utils::SharedPtr<MetricWrapper> metric);
- DEPRECATED void set_streamer(Streamer* streamer);
- void set_streamer(utils::SharedPtr<Streamer> streamer);
+ virtual void SendMetric(std::shared_ptr<MetricWrapper> metric);
+ void set_streamer(std::shared_ptr<Streamer> streamer);
const std::string& ip() const;
int16_t port() const;
@@ -101,7 +95,7 @@ class TelemetryMonitor {
std::string server_address_;
int16_t port_;
threads::Thread* thread_;
- utils::SharedPtr<Streamer> streamer_;
+ std::shared_ptr<Streamer> streamer_;
ApplicationManagerObserver app_observer;
TransportManagerObserver tm_observer;
ProtocolHandlerObserver ph_observer;