#include <AssociationData.h>
Public Member Functions | |
AssociationData () | |
Static Public Member Functions | |
static ACE_INET_Addr | get_remote_address (const TransportBLOB &remote) |
Public Attributes | |
RepoId | remote_id_ |
TransportLocatorSeq | remote_data_ |
Priority | publication_transport_priority_ |
bool | remote_reliable_ |
bool | remote_durable_ |
Definition at line 21 of file AssociationData.h.
OpenDDS::DCPS::AssociationData::AssociationData | ( | ) | [inline] |
Definition at line 27 of file AssociationData.h.
00028 : remote_id_(GUID_UNKNOWN) 00029 , publication_transport_priority_(0) 00030 , remote_reliable_(false) 00031 , remote_durable_(false) 00032 {}
static ACE_INET_Addr OpenDDS::DCPS::AssociationData::get_remote_address | ( | const TransportBLOB & | remote | ) | [inline, static] |
Definition at line 34 of file AssociationData.h.
References ACE_TEXT(), LM_ERROR, and OpenDDS::DCPS::NetworkAddress::to_addr().
Referenced by OpenDDS::DCPS::TcpTransport::blob_to_key().
00035 { 00036 ACE_INET_Addr remote_address; 00037 NetworkAddress network_order_address; 00038 00039 // Get the remote address from the "blob" in the remote_info struct. 00040 ACE_InputCDR cdr((const char*)remote.get_buffer(), 00041 remote.length()); 00042 00043 if ((cdr >> network_order_address) == 0) { 00044 ACE_ERROR((LM_ERROR, 00045 ACE_TEXT("(%P|%t) ERROR: AssociationData::get_remote_address") 00046 ACE_TEXT(" failed to de-serialize the NetworkAddress\n"))); 00047 } else { 00048 network_order_address.to_addr(remote_address); 00049 } 00050 00051 return remote_address; 00052 }
Definition at line 24 of file AssociationData.h.
Referenced by OpenDDS::DCPS::RecorderImpl::add_association(), OpenDDS::DCPS::DataReaderImpl::add_association(), OpenDDS::DCPS::TransportClient::associate(), OpenDDS::RTPS::create_association_data_proto(), OpenDDS::DCPS::RecorderImpl::get_priority_value(), OpenDDS::DCPS::DataReaderImpl::get_priority_value(), and OpenDDS::DCPS::TransportClient::PendingAssoc::initiate_connect().
Definition at line 23 of file AssociationData.h.
Referenced by OpenDDS::DCPS::ReplayerImpl::add_association(), OpenDDS::DCPS::RecorderImpl::add_association(), OpenDDS::DCPS::DataWriterImpl::add_association(), OpenDDS::DCPS::DataReaderImpl::add_association(), OpenDDS::DCPS::TransportClient::associate(), OpenDDS::RTPS::create_association_data_proto(), and OpenDDS::DCPS::TransportClient::PendingAssoc::initiate_connect().
Definition at line 25 of file AssociationData.h.
Referenced by OpenDDS::DCPS::ReplayerImpl::add_association(), OpenDDS::DCPS::RecorderImpl::add_association(), OpenDDS::DCPS::DataWriterImpl::add_association(), OpenDDS::DCPS::DataReaderImpl::add_association(), OpenDDS::DCPS::TransportClient::associate(), OpenDDS::RTPS::create_association_data_proto(), and OpenDDS::DCPS::TransportClient::PendingAssoc::initiate_connect().
Definition at line 22 of file AssociationData.h.
Referenced by OpenDDS::DCPS::ReplayerImpl::add_association(), OpenDDS::DCPS::RecorderImpl::add_association(), OpenDDS::DCPS::DataWriterImpl::add_association(), OpenDDS::DCPS::DataReaderImpl::add_association(), OpenDDS::DCPS::TransportClient::associate(), OpenDDS::RTPS::Sedp::associate(), OpenDDS::RTPS::create_association_data_proto(), OpenDDS::DCPS::TransportClient::PendingAssoc::handle_timeout(), OpenDDS::DCPS::TransportClient::PendingAssoc::initiate_connect(), and OpenDDS::RTPS::Sedp::Task::svc_i().
Definition at line 25 of file AssociationData.h.
Referenced by OpenDDS::DCPS::ReplayerImpl::add_association(), OpenDDS::DCPS::RecorderImpl::add_association(), OpenDDS::DCPS::DataWriterImpl::add_association(), OpenDDS::DCPS::DataReaderImpl::add_association(), OpenDDS::DCPS::TransportClient::associate(), OpenDDS::RTPS::create_association_data_proto(), and OpenDDS::DCPS::TransportClient::PendingAssoc::initiate_connect().