OpenDDS::DCPS::DataWriterImpl Member List

This is the complete list of members for OpenDDS::DCPS::DataWriterImpl, including all inherited members.

::DDS_TEST classOpenDDS::DCPS::DataWriterImpl [friend]
_narrow(CORBA::Object_ptr obj)OpenDDS::DCPS::LocalObject< DDS::Entity > [inline, static]
_ptr_type typedefOpenDDS::DCPS::LocalObject< DDS::Entity >
_var_type typedefOpenDDS::DCPS::LocalObject< DDS::Entity >
add_association(const RepoId &yourId, const ReaderAssociation &reader, bool active)OpenDDS::DCPS::DataWriterImpl [virtual]
add_link(const DataLink_rch &link, const RepoId &peer)OpenDDS::DCPS::TransportClient [protected, virtual]
assert_liveliness()OpenDDS::DCPS::DataWriterImpl [virtual]
assert_liveliness_by_participant()OpenDDS::DCPS::DataWriterImpl [virtual]
ASSOC_ACTIVE enum valueOpenDDS::DCPS::TransportClient
assoc_complete_readers_OpenDDS::DCPS::DataWriterImpl [private]
ASSOC_OK enum valueOpenDDS::DCPS::TransportClient
associate(const AssociationData &peer, bool active)OpenDDS::DCPS::TransportClient [protected]
association_chunk_multiplier_OpenDDS::DCPS::DataWriterImpl [protected]
association_complete(const RepoId &remote_id)OpenDDS::DCPS::DataWriterImpl [virtual]
association_complete_i(const RepoId &remote_id)OpenDDS::DCPS::DataWriterImpl [private]
available_data_list_OpenDDS::DCPS::DataWriterImpl [private]
begin_coherent_changes()OpenDDS::DCPS::DataWriterImpl
cancel_timer_OpenDDS::DCPS::DataWriterImpl [private]
cdr_encapsulation() const OpenDDS::DCPS::TransportClient [inline, protected]
check_transport_qos(const TransportInst &inst)OpenDDS::DCPS::DataWriterImpl [virtual]
cleanup()OpenDDS::DCPS::DataWriterImpl
coherent_OpenDDS::DCPS::DataWriterImpl [private]
coherent_changes_pending()OpenDDS::DCPS::DataWriterImpl
coherent_samples_OpenDDS::DCPS::DataWriterImpl [private]
connection_info() const OpenDDS::DCPS::TransportClient [inline, protected]
control_delivered(ACE_Message_Block *sample)OpenDDS::DCPS::DataWriterImpl [virtual]
control_dropped(ACE_Message_Block *sample, bool dropped_by_transport)OpenDDS::DCPS::DataWriterImpl [virtual]
controlTrackerOpenDDS::DCPS::DataWriterImpl
create_ack_token(DDS::Duration_t max_wait) const OpenDDS::DCPS::DataWriterImpl
create_control_message(MessageId message_id, DataSampleHeader &header, ACE_Message_Block *data, const DDS::Time_t &source_timestamp)OpenDDS::DCPS::DataWriterImpl [private]
create_sample_data_message(DataSample *data, DDS::InstanceHandle_t instance_handle, DataSampleHeader &header_data, ACE_Message_Block *&message, const DDS::Time_t &source_timestamp, bool content_filter)OpenDDS::DCPS::DataWriterImpl
data_container_OpenDDS::DCPS::DataWriterImpl [private]
data_delivered(const DataSampleElement *sample)OpenDDS::DCPS::DataWriterImpl [virtual]
data_delivered_count_OpenDDS::DCPS::DataWriterImpl
data_dropped(const DataSampleElement *element, bool dropped_by_transport)OpenDDS::DCPS::DataWriterImpl [virtual]
data_dropped_count_OpenDDS::DCPS::DataWriterImpl
DataWriterCallbacks()OpenDDS::DCPS::DataWriterCallbacks [inline]
DataWriterImpl()OpenDDS::DCPS::DataWriterImpl
db_allocator_OpenDDS::DCPS::DataWriterImpl [private]
db_lock_pool_OpenDDS::DCPS::DataWriterImpl [private]
disassociate(const RepoId &peerId)OpenDDS::DCPS::TransportClient [protected]
dispose(DDS::InstanceHandle_t handle, const DDS::Time_t &source_timestamp)OpenDDS::DCPS::DataWriterImpl
dispose_and_unregister(DDS::InstanceHandle_t handle, const DDS::Time_t &timestamp)OpenDDS::DCPS::DataWriterImpl [private]
domain_id() const OpenDDS::DCPS::DataWriterImpl [inline, private, virtual]
domain_id_OpenDDS::DCPS::DataWriterImpl [private]
dw_local_objref_OpenDDS::DCPS::DataWriterImpl [private]
enable()OpenDDS::DCPS::DataWriterImpl [virtual]
enable_specific()=0OpenDDS::DCPS::DataWriterImpl [protected, pure virtual]
enable_transport(bool reliable, bool durable)OpenDDS::DCPS::TransportClient [protected]
enable_transport_using_config(bool reliable, bool durable, const TransportConfig_rch &tc)OpenDDS::DCPS::TransportClient [protected]
enabled_OpenDDS::DCPS::EntityImpl [protected]
end_coherent_changes(const GroupCoherentSamples &group_samples)OpenDDS::DCPS::DataWriterImpl
entity_deleted_OpenDDS::DCPS::EntityImpl [protected]
EntityImpl()OpenDDS::DCPS::EntityImpl
filter_out(const DataSampleElement &elt, const OPENDDS_STRING &filterClassName, const FilterEvaluator &evaluator, const DDS::StringSeq &expression_params) const OpenDDS::DCPS::DataWriterImpl
get_db_lock()OpenDDS::DCPS::DataWriterImpl [inline]
get_deleted()OpenDDS::DCPS::EntityImpl [virtual]
get_dp_id()OpenDDS::DCPS::DataWriterImpl
get_handle_instance(DDS::InstanceHandle_t handle)OpenDDS::DCPS::DataWriterImpl [protected]
get_instance_handle()OpenDDS::DCPS::DataWriterImpl [virtual]
get_instance_handles(InstanceHandleVec &instance_handles)OpenDDS::DCPS::DataWriterImpl
get_listener()OpenDDS::DCPS::DataWriterImpl [virtual]
get_liveliness_lost_status(DDS::LivelinessLostStatus &status)OpenDDS::DCPS::DataWriterImpl [virtual]
DDS::DataWriter::get_liveliness_lost_status(inout LivelinessLostStatus status)DDS::DataWriter
get_lock()OpenDDS::DCPS::DataWriterImpl [inline]
get_matched_subscription_data(DDS::SubscriptionBuiltinTopicData &subscription_data, DDS::InstanceHandle_t subscription_handle)OpenDDS::DCPS::DataWriterImpl [virtual]
DDS::DataWriter::get_matched_subscription_data(inout SubscriptionBuiltinTopicData subscription_data, in InstanceHandle_t subscription_handle)DDS::DataWriter
get_matched_subscriptions(DDS::InstanceHandleSeq &subscription_handles)OpenDDS::DCPS::DataWriterImpl [virtual]
DDS::DataWriter::get_matched_subscriptions(inout InstanceHandleSeq subscription_handles)DDS::DataWriter
get_next_handle()OpenDDS::DCPS::DataWriterImpl
get_offered_deadline_missed_status(DDS::OfferedDeadlineMissedStatus &status)OpenDDS::DCPS::DataWriterImpl [virtual]
DDS::DataWriter::get_offered_deadline_missed_status(inout OfferedDeadlineMissedStatus status)DDS::DataWriter
get_offered_incompatible_qos_status(DDS::OfferedIncompatibleQosStatus &status)OpenDDS::DCPS::DataWriterImpl [virtual]
DDS::DataWriter::get_offered_incompatible_qos_status(inout OfferedIncompatibleQosStatus status)DDS::DataWriter
get_priority_value(const AssociationData &) const OpenDDS::DCPS::DataWriterImpl [inline, private, virtual]
get_publication_id()OpenDDS::DCPS::DataWriterImpl
get_publication_matched_status(DDS::PublicationMatchedStatus &status)OpenDDS::DCPS::DataWriterImpl [virtual]
DDS::DataWriter::get_publication_matched_status(inout PublicationMatchedStatus status)DDS::DataWriter
get_publisher()OpenDDS::DCPS::DataWriterImpl [virtual]
get_qos(DDS::DataWriterQos &qos)OpenDDS::DCPS::DataWriterImpl [virtual]
DDS::DataWriter::get_qos(inout DataWriterQos qos)DDS::DataWriter
get_readers(RepoIdSet &readers)OpenDDS::DCPS::DataWriterImpl
get_repo_id() const OpenDDS::DCPS::DataWriterImpl [inline, private, virtual]
get_resend_data()OpenDDS::DCPS::DataWriterImpl [inline]
DDS::get_status_changes()DDS::Entity
OpenDDS::DCPS::EntityImpl::get_status_changes()OpenDDS::DCPS::EntityImpl [virtual]
DDS::get_statuscondition()DDS::Entity
OpenDDS::DCPS::EntityImpl::get_statuscondition()OpenDDS::DCPS::EntityImpl [virtual]
get_topic()OpenDDS::DCPS::DataWriterImpl [virtual]
get_topic_name()OpenDDS::DCPS::DataWriterImpl
get_type_name() const OpenDDS::DCPS::DataWriterImpl
get_unsent_data(SendStateDataSampleList &list)OpenDDS::DCPS::DataWriterImpl [inline]
handle_close(ACE_HANDLE, ACE_Reactor_Mask)OpenDDS::DCPS::DataWriterImpl [virtual]
handle_timeout(const ACE_Time_Value &tv, const void *arg)OpenDDS::DCPS::DataWriterImpl [virtual]
header_allocator_OpenDDS::DCPS::DataWriterImpl [private]
id_to_handle_map_OpenDDS::DCPS::DataWriterImpl [private]
inconsistent_topic()OpenDDS::DCPS::DataWriterImpl [virtual]
init(DDS::Topic_ptr topic, TopicImpl *topic_servant, const DDS::DataWriterQos &qos, DDS::DataWriterListener_ptr a_listener, const DDS::StatusMask &mask, OpenDDS::DCPS::DomainParticipantImpl *participant_servant, OpenDDS::DCPS::PublisherImpl *publisher_servant, DDS::DataWriter_ptr dw_local)OpenDDS::DCPS::DataWriterImpl [virtual]
initialized_OpenDDS::DCPS::DataWriterImpl [private]
is_bit_OpenDDS::DCPS::DataWriterImpl [private]
is_enabled() const OpenDDS::DCPS::EntityImpl
last_deadline_missed_total_count_OpenDDS::DCPS::DataWriterImpl [private]
last_liveliness_activity_time_OpenDDS::DCPS::DataWriterImpl [private]
last_liveliness_check_time_OpenDDS::DCPS::DataWriterImpl [private]
listener_OpenDDS::DCPS::DataWriterImpl [private]
listener_for(DDS::StatusKind kind)OpenDDS::DCPS::DataWriterImpl
listener_mask_OpenDDS::DCPS::DataWriterImpl [private]
liveliness_asserted_OpenDDS::DCPS::DataWriterImpl [private]
liveliness_check_interval(DDS::LivelinessQosPolicyKind kind)OpenDDS::DCPS::DataWriterImpl
liveliness_check_interval_OpenDDS::DCPS::DataWriterImpl [private]
liveliness_lost_OpenDDS::DCPS::DataWriterImpl [private]
liveliness_lost_status_OpenDDS::DCPS::DataWriterImpl [private]
lock_OpenDDS::DCPS::DataWriterImpl [private]
lookup_instance_handles(const ReaderIdSeq &ids, DDS::InstanceHandleSeq &hdls)OpenDDS::DCPS::DataWriterImpl [private]
max_suspended_transaction_id_OpenDDS::DCPS::DataWriterImpl [private]
mb_allocator_OpenDDS::DCPS::DataWriterImpl [private]
min_suspended_transaction_id_OpenDDS::DCPS::DataWriterImpl [private]
monitor_OpenDDS::DCPS::DataWriterImpl [private]
n_chunks_OpenDDS::DCPS::DataWriterImpl [protected]
need_sequence_repair()OpenDDS::DCPS::DataWriterImpl [private]
need_sequence_repair_i() const OpenDDS::DCPS::DataWriterImpl [private]
notify_connection_deleted(const RepoId &peerId)OpenDDS::DCPS::DataWriterImpl [virtual]
notify_publication_disconnected(const ReaderIdSeq &subids)OpenDDS::DCPS::DataWriterImpl [virtual]
notify_publication_lost(const ReaderIdSeq &subids)OpenDDS::DCPS::DataWriterImpl [virtual]
notify_publication_lost(const DDS::InstanceHandleSeq &handles)OpenDDS::DCPS::DataWriterImpl [private]
notify_publication_reconnected(const ReaderIdSeq &subids)OpenDDS::DCPS::DataWriterImpl [virtual]
notify_status_condition()OpenDDS::DCPS::EntityImpl
num_samples(DDS::InstanceHandle_t handle, size_t &size)OpenDDS::DCPS::DataWriterImpl
offered_deadline_missed_status_OpenDDS::DCPS::DataWriterImpl [private]
offered_incompatible_qos_status_OpenDDS::DCPS::DataWriterImpl [private]
on_notification_of_connection_deletion(const RepoId &peerId)OpenDDS::DCPS::TransportClient [protected]
OPENDDS_MAP_CMP(RepoId, SequenceNumber, GUID_tKeyLessThan) RepoIdToSequenceMapOpenDDS::DCPS::DataWriterImpl
OPENDDS_MAP_CMP(RepoId, ReaderInfo, GUID_tKeyLessThan) RepoIdToReaderInfoMapOpenDDS::DCPS::DataWriterImpl [protected]
OPENDDS_MAP_CMP(RepoId, DDS::InstanceHandle_t, GUID_tKeyLessThan) RepoIdToHandleMapOpenDDS::DCPS::DataWriterImpl [private]
OPENDDS_VECTOR(DDS::InstanceHandle_t) InstanceHandleVecOpenDDS::DCPS::DataWriterImpl
parent() const OpenDDS::DCPS::DataWriterImpl [virtual]
participant_liveliness_activity_after(const ACE_Time_Value &tv)OpenDDS::DCPS::DataWriterImpl
participant_servant_OpenDDS::DCPS::DataWriterImpl [protected]
pending_control()OpenDDS::DCPS::DataWriterImpl [protected]
pending_readers_OpenDDS::DCPS::DataWriterImpl [private]
periodic_monitor_OpenDDS::DCPS::DataWriterImpl [private]
persist_data()OpenDDS::DCPS::DataWriterImpl
prepare_to_delete()OpenDDS::DCPS::DataWriterImpl [protected]
publication_id_OpenDDS::DCPS::DataWriterImpl [private]
publication_match_status_OpenDDS::DCPS::DataWriterImpl [private]
publisher_servant_OpenDDS::DCPS::DataWriterImpl [private]
PublisherImpl classOpenDDS::DCPS::DataWriterImpl [friend]
qos_OpenDDS::DCPS::DataWriterImpl [protected]
reactor_OpenDDS::DCPS::DataWriterImpl [private]
reader_info_OpenDDS::DCPS::DataWriterImpl [protected]
reader_info_lock_OpenDDS::DCPS::DataWriterImpl [protected]
readers_OpenDDS::DCPS::DataWriterImpl [private]
register_for_reader(const RepoId &participant, const RepoId &writerid, const RepoId &readerid, const TransportLocatorSeq &locators, DiscoveryListener *listener)OpenDDS::DCPS::DataWriterImpl [virtual]
register_for_writer(const RepoId &participant, const RepoId &readerid, const RepoId &writerid, const TransportLocatorSeq &locators, DiscoveryListener *listener)OpenDDS::DCPS::TransportClient [protected]
register_instance_from_durable_data(DDS::InstanceHandle_t &handle, DataSample *data, const DDS::Time_t &source_timestamp)OpenDDS::DCPS::DataWriterImpl
register_instance_i(DDS::InstanceHandle_t &handle, DataSample *data, const DDS::Time_t &source_timestamp)OpenDDS::DCPS::DataWriterImpl
remove_all_associations()OpenDDS::DCPS::DataWriterImpl
remove_all_msgs()OpenDDS::DCPS::TransportClient [protected]
remove_associations(const ReaderIdSeq &readers, bool callback)OpenDDS::DCPS::DataWriterImpl [virtual]
OpenDDS::DCPS::DataWriterCallbacks::remove_associations(const ReaderIdSeq &readers, CORBA::Boolean callback)=0OpenDDS::DCPS::DataWriterCallbacks [pure virtual]
remove_sample(const DataSampleElement *sample)OpenDDS::DCPS::TransportClient [protected]
reschedule_deadline()OpenDDS::DCPS::DataWriterImpl
retrieve_inline_qos_data(TransportSendListener::InlineQosData &qos_data) const OpenDDS::DCPS::DataWriterImpl [virtual]
send(SendStateDataSampleList send_list, ACE_UINT64 transaction_id=0)OpenDDS::DCPS::TransportClient [protected]
send_all_to_flush_control(ACE_Guard< ACE_Recursive_Thread_Mutex > &guard)OpenDDS::DCPS::DataWriterImpl
send_control(const DataSampleHeader &header, ACE_Message_Block *msg)OpenDDS::DCPS::DataWriterImpl [protected, virtual]
send_control_customized(const DataLinkSet_rch &links, const DataSampleHeader &header, ACE_Message_Block *msg, void *extra)OpenDDS::DCPS::TransportSendListener [virtual]
send_control_to(const DataSampleHeader &header, ACE_Message_Block *msg, const RepoId &destination)OpenDDS::DCPS::TransportClient [protected]
send_end_historic_samples(const RepoId &readerId)OpenDDS::DCPS::DataWriterImpl [private]
send_final_acks()OpenDDS::DCPS::TransportClient [protected]
send_liveliness(const ACE_Time_Value &now)OpenDDS::DCPS::DataWriterImpl [private]
send_response(const RepoId &peer, const DataSampleHeader &header, ACE_Message_Block *payload)OpenDDS::DCPS::TransportClient [protected]
send_suspended_data()OpenDDS::DCPS::DataWriterImpl
send_w_control(SendStateDataSampleList send_list, const DataSampleHeader &header, ACE_Message_Block *msg, const RepoId &destination)OpenDDS::DCPS::TransportClient [protected]
sequence_number_OpenDDS::DCPS::DataWriterImpl [private]
set_deleted(bool state)OpenDDS::DCPS::EntityImpl [virtual]
set_enabled()OpenDDS::DCPS::EntityImpl [virtual]
set_listener(DDS::DataWriterListener_ptr a_listener, DDS::StatusMask mask)OpenDDS::DCPS::DataWriterImpl [virtual]
DDS::DataWriter::set_listener(in DataWriterListener a_listener, in StatusMask mask)DDS::DataWriter
set_qos(const DDS::DataWriterQos &qos)OpenDDS::DCPS::DataWriterImpl [virtual]
DDS::DataWriter::set_qos(in DataWriterQos qos)DDS::DataWriter
set_status_changed_flag(DDS::StatusKind status, bool status_changed_flag)OpenDDS::DCPS::EntityImpl
should_ack() const OpenDDS::DCPS::DataWriterImpl
stop_associating()OpenDDS::DCPS::TransportClient [protected]
stop_associating(const GUID_t *repos, CORBA::ULong length)OpenDDS::DCPS::TransportClient [protected]
swap_bytes() const OpenDDS::DCPS::TransportClient [inline, protected]
sync_unreg_rem_assocs_lock_OpenDDS::DCPS::DataWriterImpl [private]
topic_id_OpenDDS::DCPS::DataWriterImpl [private]
topic_name_OpenDDS::DCPS::DataWriterImpl [private]
topic_objref_OpenDDS::DCPS::DataWriterImpl [private]
topic_servant_OpenDDS::DCPS::DataWriterImpl [private]
track_sequence_number(GUIDSeq *filter_out)OpenDDS::DCPS::DataWriterImpl [private]
transport_assoc_done(int flags, const RepoId &remote_id)OpenDDS::DCPS::DataWriterImpl [virtual]
transport_config(const TransportConfig_rch &cfg)OpenDDS::DCPS::EntityImpl [virtual]
transport_config() const OpenDDS::DCPS::EntityImpl
TransportClient()OpenDDS::DCPS::TransportClient [protected]
TransportSendListener()OpenDDS::DCPS::TransportSendListener [protected]
type_name_OpenDDS::DCPS::DataWriterImpl [protected]
unregister_all()OpenDDS::DCPS::DataWriterImpl
unregister_for_reader(const RepoId &participant, const RepoId &writerid, const RepoId &readerid)OpenDDS::DCPS::DataWriterImpl [virtual]
unregister_for_writer(const RepoId &participant, const RepoId &readerid, const RepoId &writerid)OpenDDS::DCPS::TransportClient [protected]
unregister_instance_i(DDS::InstanceHandle_t handle, const DDS::Time_t &source_timestamp)OpenDDS::DCPS::DataWriterImpl
unregister_instances(const DDS::Time_t &source_timestamp)OpenDDS::DCPS::DataWriterImpl
unregistered(DDS::InstanceHandle_t instance_handle)=0OpenDDS::DCPS::DataWriterImpl [pure virtual]
update_incompatible_qos(const IncompatibleQosStatus &status)OpenDDS::DCPS::DataWriterImpl [virtual]
update_subscription_params(const RepoId &readerId, const DDS::StringSeq &params)OpenDDS::DCPS::DataWriterImpl [virtual]
use_datalink(const RepoId &remote_id, const DataLink_rch &link)OpenDDS::DCPS::TransportClient
wait_control_pending()OpenDDS::DCPS::DataWriterImpl
wait_for_acknowledgments(const DDS::Duration_t &max_wait)OpenDDS::DCPS::DataWriterImpl [virtual]
DDS::DataWriter::wait_for_acknowledgments(in Duration_t max_wait)DDS::DataWriter
wait_for_specific_ack(const AckToken &token)OpenDDS::DCPS::DataWriterImpl [protected]
wait_pending()OpenDDS::DCPS::DataWriterImpl
watchdog_OpenDDS::DCPS::DataWriterImpl [private]
write(DataSample *sample, DDS::InstanceHandle_t handle, const DDS::Time_t &source_timestamp, GUIDSeq *filter_out)OpenDDS::DCPS::DataWriterImpl
WriteDataContainer classOpenDDS::DCPS::DataWriterImpl [friend]
~DataWriterCallbacks()OpenDDS::DCPS::DataWriterCallbacks [inline, virtual]
~DataWriterImpl()OpenDDS::DCPS::DataWriterImpl [virtual]
~EntityImpl()OpenDDS::DCPS::EntityImpl [virtual]
~TransportClient()OpenDDS::DCPS::TransportClient [protected, virtual]
~TransportSendListener()OpenDDS::DCPS::TransportSendListener [virtual]


Generated on Fri Feb 12 20:06:14 2016 for OpenDDS by  doxygen 1.4.7