summaryrefslogtreecommitdiff
path: root/src/components/transport_manager/src/tcp/tcp_transport_adapter.cc
diff options
context:
space:
mode:
Diffstat (limited to 'src/components/transport_manager/src/tcp/tcp_transport_adapter.cc')
-rw-r--r--src/components/transport_manager/src/tcp/tcp_transport_adapter.cc49
1 files changed, 22 insertions, 27 deletions
diff --git a/src/components/transport_manager/src/tcp/tcp_transport_adapter.cc b/src/components/transport_manager/src/tcp/tcp_transport_adapter.cc
index 3998c02ab9..a389deb517 100644
--- a/src/components/transport_manager/src/tcp/tcp_transport_adapter.cc
+++ b/src/components/transport_manager/src/tcp/tcp_transport_adapter.cc
@@ -42,33 +42,26 @@
#include "utils/logger.h"
#include "utils/threads/thread_delegate.h"
-#include "resumption/last_state.h"
#include "transport_manager/tcp/tcp_client_listener.h"
#include "transport_manager/tcp/tcp_connection_factory.h"
#include "transport_manager/tcp/tcp_device.h"
-#ifdef AVAHI_SUPPORT
-#include "transport_manager/tcp/dnssd_service_browser.h"
-#endif
-
namespace transport_manager {
namespace transport_adapter {
-CREATE_LOGGERPTR_GLOBAL(logger_, "TransportAdapterImpl")
+CREATE_LOGGERPTR_GLOBAL(logger_, "TransportManager")
-TcpTransportAdapter::TcpTransportAdapter(const uint16_t port)
- : TransportAdapterImpl(
-#ifdef AVAHI_SUPPORT
- new DnssdServiceBrowser(this),
-#else
- NULL,
-#endif
+TcpTransportAdapter::TcpTransportAdapter(
+ const uint16_t port,
+ resumption::LastState& last_state,
+ const TransportManagerSettings& settings)
+ : TransportAdapterImpl(NULL,
new TcpConnectionFactory(this),
- new TcpClientListener(this, port, true)) {
-}
+ new TcpClientListener(this, port, true),
+ last_state,
+ settings) {}
-TcpTransportAdapter::~TcpTransportAdapter() {
-}
+TcpTransportAdapter::~TcpTransportAdapter() {}
DeviceType TcpTransportAdapter::GetDeviceType() const {
return TCP;
@@ -80,14 +73,14 @@ void TcpTransportAdapter::Store() const {
Json::Value devices_dictionary;
DeviceList device_ids = GetDeviceList();
for (DeviceList::const_iterator i = device_ids.begin(); i != device_ids.end();
- ++i) {
+ ++i) {
DeviceUID device_id = *i;
DeviceSptr device = FindDevice(device_id);
if (!device) { // device could have been disconnected
continue;
}
- utils::SharedPtr<TcpDevice> tcp_device = DeviceSptr::static_pointer_cast<
- TcpDevice>(device);
+ utils::SharedPtr<TcpDevice> tcp_device =
+ DeviceSptr::static_pointer_cast<TcpDevice>(device);
Json::Value device_dictionary;
device_dictionary["name"] = tcp_device->name();
struct in_addr address;
@@ -96,7 +89,8 @@ void TcpTransportAdapter::Store() const {
Json::Value applications_dictionary;
ApplicationList app_ids = tcp_device->GetApplicationList();
for (ApplicationList::const_iterator j = app_ids.begin();
- j != app_ids.end(); ++j) {
+ j != app_ids.end();
+ ++j) {
ApplicationHandle app_handle = *j;
if (FindEstablishedConnection(tcp_device->unique_device_id(),
app_handle)) {
@@ -116,18 +110,19 @@ void TcpTransportAdapter::Store() const {
}
}
tcp_adapter_dictionary["devices"] = devices_dictionary;
- Json::Value& dictionary = resumption::LastState::instance()->dictionary;
+ Json::Value& dictionary = last_state().dictionary;
dictionary["TransportManager"]["TcpAdapter"] = tcp_adapter_dictionary;
}
bool TcpTransportAdapter::Restore() {
LOG4CXX_AUTO_TRACE(logger_);
bool errors_occurred = false;
- const Json::Value tcp_adapter_dictionary = resumption::LastState::instance()
- ->dictionary["TransportManager"]["TcpAdapter"];
+ const Json::Value tcp_adapter_dictionary =
+ last_state().dictionary["TransportManager"]["TcpAdapter"];
const Json::Value devices_dictionary = tcp_adapter_dictionary["devices"];
for (Json::Value::const_iterator i = devices_dictionary.begin();
- i != devices_dictionary.end(); ++i) {
+ i != devices_dictionary.end();
+ ++i) {
const Json::Value device_dictionary = *i;
std::string name = device_dictionary["name"].asString();
std::string address_record = device_dictionary["address"].asString();
@@ -138,7 +133,8 @@ bool TcpTransportAdapter::Restore() {
const Json::Value applications_dictionary =
device_dictionary["applications"];
for (Json::Value::const_iterator j = applications_dictionary.begin();
- j != applications_dictionary.end(); ++j) {
+ j != applications_dictionary.end();
+ ++j) {
const Json::Value application_dictionary = *j;
std::string port_record = application_dictionary["port"].asString();
int port = atoi(port_record.c_str());
@@ -155,4 +151,3 @@ bool TcpTransportAdapter::Restore() {
} // namespace transport_adapter
} // namespace transport_manager
-