Line data    Source code

       1             : /*
       2             :  *
       3             :  *
       4             :  * Distributed under the OpenDDS License.
       5             :  * See: http://www.opendds.org/license.html
       6             :  */
       7             : 
       8             : #include "TransportInst.h"
       9             : #include "dds/DCPS/ReactorTask.h"
      10             : #include "DataLink_rch.h"
      11             : #include "DataLink.h"
      12             : #include "EntryExit.h"
      13             : 
      14             : #include "ace/Reactor.h"
      15             : 
      16             : OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL
      17             : 
      18             : ACE_INLINE OpenDDS::DCPS::TransportInst_rch
      19           0 : OpenDDS::DCPS::TransportImpl::config() const
      20             : {
      21           0 :   return config_.lock();
      22             : }
      23             : 
      24             : ACE_INLINE OpenDDS::DCPS::ReactorTask_rch
      25           0 : OpenDDS::DCPS::TransportImpl::reactor_task()
      26             : {
      27             :   DBG_ENTRY_LVL("TransportImpl","reactor_task",6);
      28           0 :   return this->reactor_task_;
      29             : }
      30             : 
      31             : ACE_INLINE ACE_Reactor_Timer_Interface*
      32           0 : OpenDDS::DCPS::TransportImpl::timer() const
      33             : {
      34           0 :   return reactor();
      35             : }
      36             : 
      37             : ACE_INLINE ACE_Reactor*
      38           0 : OpenDDS::DCPS::TransportImpl::reactor() const
      39             : {
      40           0 :   ReactorTask_rch task = this->reactor_task_;
      41           0 :   return task.is_nil() ? 0 : task->get_reactor();
      42           0 : }
      43             : 
      44             : ACE_INLINE ACE_thread_t
      45           0 : OpenDDS::DCPS::TransportImpl::reactor_owner() const
      46             : {
      47           0 :   return reactor_task_ ? reactor_task_->get_reactor_owner() : ACE_OS::NULL_thread;
      48             : }
      49             : 
      50             : ACE_INLINE bool
      51           0 : OpenDDS::DCPS::TransportImpl::connection_info
      52             :   (TransportLocator& local_info, ConnectionInfoFlags flags) const
      53             : {
      54           0 :   return connection_info_i(local_info, flags);
      55             : }
      56             : 
      57             : 
      58             : OPENDDS_END_VERSIONED_NAMESPACE_DECL