00001 /* 00002 * 00003 * 00004 * Distributed under the OpenDDS License. 00005 * See: http://www.opendds.org/license.html 00006 */ 00007 00008 #include "TcpAcceptor.h" 00009 #include "TcpDataLink.h" 00010 #include "TcpSendStrategy.h" 00011 #include "TcpReceiveStrategy.h" 00012 #include "dds/DCPS/transport/framework/NetworkAddress.h" 00013 #include "ace/SOCK_Connector.h" 00014 #include "dds/DCPS/transport/framework/EntryExit.h" 00015 00016 OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL 00017 00018 ACE_INLINE 00019 std::size_t& 00020 OpenDDS::DCPS::TcpConnection::id() 00021 { 00022 return id_; 00023 } 00024 00025 00026 ACE_INLINE bool 00027 OpenDDS::DCPS::TcpConnection::is_connector() const 00028 { 00029 return this->is_connector_; 00030 } 00031 00032 ACE_INLINE bool 00033 OpenDDS::DCPS::TcpConnection::is_connected() const 00034 { 00035 return this->connected_.value(); 00036 } 00037 00038 ACE_INLINE void 00039 OpenDDS::DCPS::TcpConnection::set_datalink(const OpenDDS::DCPS::TcpDataLink_rch& link) 00040 { 00041 // Keep a "copy" of the reference to the data link for ourselves. 00042 this->link_ = link; 00043 } 00044 00045 ACE_INLINE ACE_INET_Addr 00046 OpenDDS::DCPS::TcpConnection::get_remote_address() 00047 { 00048 return this->remote_address_; 00049 } 00050 00051 ACE_INLINE 00052 OpenDDS::DCPS::Priority& 00053 OpenDDS::DCPS::TcpConnection::transport_priority() 00054 { 00055 return this->transport_priority_; 00056 } 00057 00058 ACE_INLINE 00059 OpenDDS::DCPS::Priority 00060 OpenDDS::DCPS::TcpConnection::transport_priority() const 00061 { 00062 return this->transport_priority_; 00063 } 00064 00065 OPENDDS_END_VERSIONED_NAMESPACE_DECL