00001 /* 00002 * 00003 * 00004 * Distributed under the OpenDDS License. 00005 * See: http://www.opendds.org/license.html 00006 */ 00007 00008 #include "TransportInst.h" 00009 #include "TransportReactorTask.h" 00010 #include "DataLink_rch.h" 00011 #include "DataLink.h" 00012 #include "EntryExit.h" 00013 00014 #include "ace/Reactor.h" 00015 00016 OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL 00017 00018 ACE_INLINE OpenDDS::DCPS::TransportInst& 00019 OpenDDS::DCPS::TransportImpl::config() const 00020 { 00021 return this->config_; 00022 } 00023 00024 ACE_INLINE OpenDDS::DCPS::TransportReactorTask_rch 00025 OpenDDS::DCPS::TransportImpl::reactor_task() 00026 { 00027 DBG_ENTRY_LVL("TransportImpl","reactor_task",6); 00028 return this->reactor_task_; 00029 } 00030 00031 ACE_INLINE ACE_Reactor_Timer_Interface* 00032 OpenDDS::DCPS::TransportImpl::timer() const 00033 { 00034 return reactor(); 00035 } 00036 00037 ACE_INLINE ACE_Reactor* 00038 OpenDDS::DCPS::TransportImpl::reactor() const 00039 { 00040 TransportReactorTask_rch task = this->reactor_task_; 00041 return task.is_nil() ? 0 : task->get_reactor(); 00042 } 00043 00044 ACE_INLINE ACE_thread_t 00045 OpenDDS::DCPS::TransportImpl::reactor_owner() const 00046 { 00047 return this->reactor_task_->get_reactor_owner(); 00048 } 00049 00050 ACE_INLINE bool 00051 OpenDDS::DCPS::TransportImpl::connection_info 00052 (TransportLocator& local_info) const 00053 { 00054 return this->connection_info_i(local_info); 00055 } 00056 00057 00058 OPENDDS_END_VERSIONED_NAMESPACE_DECL