#include <AssociationData.h>
Collaboration diagram for OpenDDS::DCPS::AssociationData:
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 18 of file AssociationData.h.
OpenDDS::DCPS::AssociationData::AssociationData | ( | ) | [inline] |
Definition at line 24 of file AssociationData.h.
00025 : remote_id_(GUID_UNKNOWN) 00026 , publication_transport_priority_(0) 00027 , remote_reliable_(false) 00028 , remote_durable_(false) 00029 {}
static ACE_INET_Addr OpenDDS::DCPS::AssociationData::get_remote_address | ( | const TransportBLOB & | remote | ) | [inline, static] |
Definition at line 31 of file AssociationData.h.
References OpenDDS::DCPS::NetworkAddress::to_addr().
Referenced by OpenDDS::DCPS::TcpTransport::blob_to_key().
00032 { 00033 ACE_INET_Addr remote_address; 00034 NetworkAddress network_order_address; 00035 00036 // Get the remote address from the "blob" in the remote_info struct. 00037 ACE_InputCDR cdr((const char*)remote.get_buffer(), 00038 remote.length()); 00039 00040 if ((cdr >> network_order_address) == 0) { 00041 ACE_ERROR((LM_ERROR, 00042 ACE_TEXT("(%P|%t) ERROR: AssociationData::get_remote_address") 00043 ACE_TEXT(" failed to de-serialize the NetworkAddress\n"))); 00044 } else { 00045 network_order_address.to_addr(remote_address); 00046 } 00047 00048 return remote_address; 00049 }
Definition at line 21 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 20 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::create_association_data_proto(), and OpenDDS::DCPS::TransportClient::PendingAssoc::initiate_connect().
Definition at line 19 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(), OpenDDS::RTPS::Sedp::Task::svc_i(), and OpenDDS::DCPS::TransportClient::use_datalink_i().
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::create_association_data_proto(), and OpenDDS::DCPS::TransportClient::PendingAssoc::initiate_connect().