|
| Reader (const DCPS::GUID_t &sub_id, Sedp &sedp) |
|
virtual | ~Reader () |
|
bool | assoc (const DCPS::AssociationData &publication) |
|
void | data_received (const DCPS::ReceivedDataSample &sample) |
|
void | notify_subscription_disconnected (const DCPS::WriterIdSeq &) |
|
void | notify_subscription_reconnected (const DCPS::WriterIdSeq &) |
|
void | notify_subscription_lost (const DCPS::WriterIdSeq &) |
|
void | remove_associations (const DCPS::WriterIdSeq &, bool) |
|
virtual | ~TransportReceiveListener () |
|
virtual void | transport_discovery_change () |
|
virtual | ~RcObject () |
|
virtual void | _add_ref () |
|
virtual void | _remove_ref () |
|
long | ref_count () const |
|
WeakObject * | _get_weak_object () const |
|
| Endpoint (const DCPS::GUID_t &repo_id, Sedp &sedp) |
|
virtual | ~Endpoint () |
|
bool | check_transport_qos (const DCPS::TransportInst &) |
|
DCPS::GUID_t | get_guid () const |
|
DDS::DomainId_t | domain_id () const |
|
CORBA::Long | get_priority_value (const DCPS::AssociationData &) const |
|
void | set_crypto_handles (DDS::Security::ParticipantCryptoHandle p, DDS::Security::NativeCryptoHandle e=DDS::HANDLE_NIL) |
|
DDS::Security::ParticipantCryptoHandle | get_crypto_handle () const |
|
DDS::Security::NativeCryptoHandle | get_endpoint_crypto_handle () const |
|
void | shutting_down () |
|
OPENDDS_STRING | get_instance_name (const DCPS::GUID_t &id) const |
|
EntityId_t | counterpart_entity_id () const |
|
GUID_t | make_counterpart_guid (const DCPS::GUID_t &remote_part) const |
|
bool | associated_with_counterpart (const DCPS::GUID_t &remote_part) const |
|
bool | pending_association_with_counterpart (const DCPS::GUID_t &remote_part) const |
|
bool | associated_with_counterpart_if_not_pending (const DCPS::GUID_t &remote_part) const |
|
RcHandle< DCPS::BitSubscriber > | get_builtin_subscriber_proxy () const |
|
void | use_datalink (const GUID_t &remote_id, const DataLink_rch &link) |
|
| TransportClient () |
|
virtual | ~TransportClient () |
|
void | enable_transport (bool reliable, bool durable) |
|
void | enable_transport_using_config (bool reliable, bool durable, const TransportConfig_rch &tc) |
|
bool | swap_bytes () const |
|
bool | cdr_encapsulation () const |
|
const TransportLocatorSeq & | connection_info () const |
|
void | populate_connection_info () |
|
bool | is_reliable () const |
|
bool | associate (const AssociationData &peer, bool active) |
|
void | disassociate (const GUID_t &peerId) |
|
void | stop_associating () |
|
void | stop_associating (const GUID_t *repos, CORBA::ULong length) |
|
void | send_final_acks () |
|
void | transport_stop () |
|
void | register_for_reader (const GUID_t &participant, const GUID_t &writerid, const GUID_t &readerid, const TransportLocatorSeq &locators, OpenDDS::DCPS::DiscoveryListener *listener) |
|
void | unregister_for_reader (const GUID_t &participant, const GUID_t &writerid, const GUID_t &readerid) |
|
void | register_for_writer (const GUID_t &participant, const GUID_t &readerid, const GUID_t &writerid, const TransportLocatorSeq &locators, DiscoveryListener *listener) |
|
void | unregister_for_writer (const GUID_t &participant, const GUID_t &readerid, const GUID_t &writerid) |
|
void | update_locators (const GUID_t &remote, const TransportLocatorSeq &locators) |
|
WeakRcHandle< ICE::Endpoint > | get_ice_endpoint () |
|
bool | send_response (const GUID_t &peer, const DataSampleHeader &header, Message_Block_Ptr payload) |
|
void | send (SendStateDataSampleList send_list, ACE_UINT64 transaction_id=0) |
|
SendControlStatus | send_w_control (SendStateDataSampleList send_list, const DataSampleHeader &header, Message_Block_Ptr msg, const GUID_t &destination) |
|
SendControlStatus | send_control (const DataSampleHeader &header, Message_Block_Ptr msg) |
|
SendControlStatus | send_control_to (const DataSampleHeader &header, Message_Block_Ptr msg, const GUID_t &destination) |
|
bool | remove_sample (const DataSampleElement *sample) |
|
bool | remove_all_msgs () |
|
virtual void | add_link (const DataLink_rch &link, const GUID_t &peer) |
|
void | terminate_send_if_suspended () |
|
bool | associated_with (const GUID_t &remote) const |
|
bool | pending_association_with (const GUID_t &remote) const |
|
GUID_t | repo_id () const |
|
void | data_acked (const GUID_t &remote) |
|
bool | is_leading (const GUID_t &reader_id) const |
|
Definition at line 607 of file Sedp.h.
Implements OpenDDS::DCPS::TransportReceiveListener.
Definition at line 4109 of file Sedp.cpp.
References ACE_DEBUG, ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::LogGuid::c_str(), OpenDDS::DCPS::ReceivedDataSample::data(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::DISPOSE_INSTANCE, OpenDDS::DCPS::DISPOSE_UNREGISTER_INSTANCE, OpenDDS::STUN::encoding(), OpenDDS::DCPS::GUID_t::entityId, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_WRITER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_STATELESS_WRITER, OpenDDS::RTPS::ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_PUBLICATIONS_WRITER, OpenDDS::RTPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_WRITER, OpenDDS::RTPS::ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_WRITER, OpenDDS::DCPS::ENTITYID_TL_SVC_REPLY_WRITER, OpenDDS::RTPS::ENTITYID_TL_SVC_REPLY_WRITER_SECURE, OpenDDS::DCPS::ENTITYID_TL_SVC_REQ_WRITER, OpenDDS::RTPS::ENTITYID_TL_SVC_REQ_WRITER_SECURE, OpenDDS::XTypes::extensibility(), OpenDDS::DCPS::FINAL, OpenDDS::DCPS::ReceivedDataSample::header_, OpenDDS::DCPS::DataSampleHeader::key_fields_only_, LM_DEBUG, LM_ERROR, OpenDDS::DCPS::DataSampleHeader::message_id_, OpenDDS::DCPS::MUTABLE, OpenDDS::DCPS::DataSampleHeader::publication_id_, OpenDDS::DCPS::SAMPLE_DATA, OpenDDS::RTPS::Sedp::Endpoint::shutting_down_, OpenDDS::DCPS::to_string(), and OpenDDS::DCPS::UNREGISTER_INSTANCE.
4116 ACE_DEBUG((LM_DEBUG,
"(%P|%t) Sedp::Reader::data_received: from %C\n",
4117 DCPS::LogGuid(sample.header_.publication_id_).c_str()));
4128 const DCPS::EntityId_t entity_id = sample.header_.publication_id_.entityId;
4129 const bool full_message = !sample.header_.key_fields_only_;
4132 const bool is_mutable =
4134 #ifdef OPENDDS_SECURITY 4138 #ifdef OPENDDS_SECURITY 4143 const bool is_final =
4145 #ifdef OPENDDS_SECURITY
4152 #ifdef OPENDDS_SECURITY 4157 if (is_mutable == is_final) {
4159 ACE_ERROR((LM_ERROR,
"(%P|%t) ERROR: Sedp::Reader::data_received: " 4160 "entity id extensibility error over %C: both is_final and is_mutable are %d\n",
4161 to_string(entity_id).c_str(), is_mutable));
4171 Serializer ser(payload.get(),
encoding);
4172 DCPS::EncapsulationHeader encap;
4173 if (!(ser >> encap)) {
4175 ACE_TEXT(
"failed to deserialize encapsulation header\n")));
4178 if (!encap.to_encoding(encoding, extensibility)) {
4181 ser.encoding(encoding);
const EntityId_t ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_SECURE_WRITER
DCPS::TransportMessageBlockAllocator mb_alloc_
const EntityId_t ENTITYID_TL_SVC_REQ_WRITER
const EntityId_t ENTITYID_TL_SVC_REQ_WRITER_SECURE
MessageId
One byte message id (<256)
virtual void data_received_i(const DCPS::ReceivedDataSample &sample, const DCPS::EntityId_t &entity_id, DCPS::Serializer &ser, DCPS::Extensibility extensibility)=0
const EntityId_t ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_SECURE_WRITER
unique_ptr< ACE_Message_Block, Message_Block_Deleter > Message_Block_Ptr
const EntityId_t ENTITYID_TL_SVC_REPLY_WRITER_SECURE
const EntityId_t ENTITYID_TL_SVC_REPLY_WRITER
const EntityId_t ENTITYID_SEDP_BUILTIN_PUBLICATIONS_WRITER
const EntityId_t ENTITYID_P2P_BUILTIN_PARTICIPANT_STATELESS_WRITER
AtomicBool shutting_down_
const EntityId_t ENTITYID_P2P_BUILTIN_PARTICIPANT_VOLATILE_SECURE_WRITER
const EntityId_t ENTITYID_SEDP_BUILTIN_PUBLICATIONS_SECURE_WRITER
const EntityId_t ENTITYID_SEDP_BUILTIN_SUBSCRIPTIONS_WRITER
OpenDDS_Dcps_Export unsigned int DCPS_debug_level
const char * to_string(MessageId value)
const EntityId_t ENTITYID_SPDP_RELIABLE_BUILTIN_PARTICIPANT_SECURE_WRITER
const EntityId_t ENTITYID_P2P_BUILTIN_PARTICIPANT_MESSAGE_WRITER
const DCPS::Encoding encoding(DCPS::Encoding::KIND_UNALIGNED_CDR, DCPS::ENDIAN_BIG)
extensibility(MUTABLE) struct TypeLookup_getTypes_In