summaryrefslogtreecommitdiff
path: root/src/components/transport_manager/include/transport_manager/transport_manager_impl.h
diff options
context:
space:
mode:
authorKozoriz <kozorizandriy@gmail.com>2016-04-11 16:37:41 +0300
committerKozoriz <kozorizandriy@gmail.com>2016-04-25 12:15:47 +0300
commit78714c9fee6e88483d91a682d0002e7afd4e6c6c (patch)
treeb18635a81a88c42ad0add734bf55c665f9f869a6 /src/components/transport_manager/include/transport_manager/transport_manager_impl.h
parenta86a2b2cbc6d0a0fb06af317f01eae8167c7e3dc (diff)
downloadsdl_core-78714c9fee6e88483d91a682d0002e7afd4e6c6c.tar.gz
TransportManager update after removing all singletons
Diffstat (limited to 'src/components/transport_manager/include/transport_manager/transport_manager_impl.h')
-rw-r--r--src/components/transport_manager/include/transport_manager/transport_manager_impl.h25
1 files changed, 17 insertions, 8 deletions
diff --git a/src/components/transport_manager/include/transport_manager/transport_manager_impl.h b/src/components/transport_manager/include/transport_manager/transport_manager_impl.h
index 921120a7d5..9de6a0720b 100644
--- a/src/components/transport_manager/include/transport_manager/transport_manager_impl.h
+++ b/src/components/transport_manager/include/transport_manager/transport_manager_impl.h
@@ -50,10 +50,11 @@
#include "protocol/common.h"
#ifdef TELEMETRY_MONITOR
#include "transport_manager/telemetry_observer.h"
+#include "telemetry_monitor/telemetry_observable.h"
#endif // TELEMETRY_MONITOR
#include "utils/threads/message_loop_thread.h"
#include "transport_manager/transport_adapter/transport_adapter_event.h"
-#include "telemetry_monitor/telemetry_observable.h"
+#include "transport_manager/transport_manager_settings.h"
namespace transport_manager {
@@ -66,14 +67,14 @@ typedef utils::SharedPtr<timer::Timer> TimerSPtr;
/**
* @brief Implementation of transport manager.s
*/
-class TransportManagerImpl
- : public TransportManager,
- public RawMessageLoopThread::Handler
+class TransportManagerImpl : public TransportManager,
+ public RawMessageLoopThread::Handler,
+ public TransportAdapterEventLoopThread::Handler
#ifdef TELEMETRY_MONITOR
,
public telemetry_monitor::TelemetryObservable<TMTelemetryObserver>
#endif // TELEMETRY_MONITOR
- , public TransportAdapterEventLoopThread::Handler {
+ {
public:
struct Connection {
ConnectionUID id;
@@ -89,7 +90,7 @@ class TransportManagerImpl
TransportManagerImpl* transport_manager;
TransportAdapter* transport_adapter;
TimerSPtr timer;
- bool shut_down;
+ bool shutdown_;
DeviceHandle device_handle_;
int messages_count;
@@ -103,6 +104,13 @@ class TransportManagerImpl
void DisconnectFailedRoutine();
};
public:
+
+
+ /**
+ * @brief Constructor.
+ **/
+ explicit TransportManagerImpl(const TransportManagerSettings& settings);
+
/**
* @brief Destructor.
**/
@@ -234,12 +242,13 @@ class TransportManagerImpl
void SetTelemetryObserver(TMTelemetryObserver* observer);
#endif // TELEMETRY_MONITOR
-
/**
* @brief Constructor.
**/
TransportManagerImpl();
+ const TransportManagerSettings& get_settings() const;
+
protected:
template <class Proc, class... Args>
void RaiseEvent(Proc proc, Args... args) {
@@ -343,7 +352,7 @@ class TransportManagerImpl
transport_adapter_listeners_;
RawMessageLoopThread message_queue_;
TransportAdapterEventLoopThread event_queue_;
-
+ const TransportManagerSettings& settings_;
typedef std::vector<std::pair<const TransportAdapter*, DeviceInfo> >
DeviceInfoList;
sync_primitives::RWLock device_list_lock_;