diff options
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.h | 23 |
1 files changed, 9 insertions, 14 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 62fdb3fa2..4c38716f3 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 @@ -33,15 +33,12 @@ #ifndef SRC_COMPONENTS_TRANSPORT_MANAGER_INCLUDE_TRANSPORT_MANAGER_TRANSPORT_MANAGER_IMPL_H_ #define SRC_COMPONENTS_TRANSPORT_MANAGER_INCLUDE_TRANSPORT_MANAGER_TRANSPORT_MANAGER_IMPL_H_ -#include <pthread.h> - #include <queue> #include <map> #include <list> #include <algorithm> #include "utils/timer_thread.h" -#include "utils/rwlock.h" #include "transport_manager/transport_manager.h" #include "transport_manager/transport_manager_listener.h" @@ -104,6 +101,12 @@ class TransportManagerImpl : public TransportManager, virtual int Init(); /** + * Reinitializes transport manager + * @return Error code + */ + virtual int Reinit(); + + /** * @brief Start scanning for new devices. * * @return Code error. @@ -250,12 +253,6 @@ class TransportManagerImpl : public TransportManager, **/ void PostEvent(const TransportAdapterEvent& event); - /** - * @brief flag that indicates that thread is active - * if it is false then threads exist main loop - **/ - volatile bool all_thread_active_; - typedef std::list<TransportManagerListener*> TransportManagerListenerList; /** * @brief listener that would be called when TM's event happened. @@ -263,11 +260,6 @@ class TransportManagerImpl : public TransportManager, TransportManagerListenerList transport_manager_listener_; /** - * @brief Condition variable to wake up event - **/ - pthread_cond_t device_listener_thread_wakeup_; - - /** * @brief Flag that TM is initialized */ bool is_initialized_; @@ -352,6 +344,9 @@ class TransportManagerImpl : public TransportManager, unsigned char** frame); void OnDeviceListUpdated(TransportAdapter* ta); + void DisconnectAllDevices(); + void TerminateAllAdapters(); + int InitAllAdapters(); static Connection convert(const ConnectionInternal& p); }; // class ; |