diff options
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.cc | 49 |
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 - |