::DDS_TEST class | OpenDDS::DCPS::WriteDataContainer | friend |
_add_ref() | OpenDDS::DCPS::RcObject | inlinevirtual |
_get_weak_object() const | OpenDDS::DCPS::RcObject | inline |
_remove_ref() | OpenDDS::DCPS::RcObject | inlinevirtual |
acked_sequences_ | OpenDDS::DCPS::WriteDataContainer | private |
add_reader_acks(const GUID_t &reader, const SequenceNumber &base) | OpenDDS::DCPS::WriteDataContainer | private |
cached_cumulative_ack_ | OpenDDS::DCPS::WriteDataContainer | private |
cached_cumulative_ack_valid_ | OpenDDS::DCPS::WriteDataContainer | private |
cancel_deadline(const PublicationInstance_rch &instance) | OpenDDS::DCPS::WriteDataContainer | private |
condition_ | OpenDDS::DCPS::WriteDataContainer | private |
ConditionVariableType typedef | OpenDDS::DCPS::WriteDataContainer | private |
copy_and_prepend(SendStateDataSampleList &list, const SendStateDataSampleList &appended, const GUID_t &reader_id, const DDS::LifespanQosPolicy &lifespan, const OPENDDS_STRING &filterClassName, const FilterEvaluator *eval, const DDS::StringSeq ¶ms, ssize_t &max_resend_samples) | OpenDDS::DCPS::WriteDataContainer | private |
data_delivered(const DataSampleElement *sample) | OpenDDS::DCPS::WriteDataContainer | |
data_dropped(const DataSampleElement *element, bool dropped_by_transport) | OpenDDS::DCPS::WriteDataContainer | |
data_holder_ | OpenDDS::DCPS::WriteDataContainer | private |
DataWriterImpl class | OpenDDS::DCPS::WriteDataContainer | friend |
deadline_last_total_count_ | OpenDDS::DCPS::WriteDataContainer | private |
deadline_map_ | OpenDDS::DCPS::WriteDataContainer | private |
deadline_period_ | OpenDDS::DCPS::WriteDataContainer | private |
deadline_status_ | OpenDDS::DCPS::WriteDataContainer | private |
deadline_status_lock_ | OpenDDS::DCPS::WriteDataContainer | private |
deadline_task_ | OpenDDS::DCPS::WriteDataContainer | private |
dispose(DDS::InstanceHandle_t handle, Message_Block_Ptr ®istered_sample, bool dup_registered_sample=true) | OpenDDS::DCPS::WriteDataContainer | |
domain_id_ | OpenDDS::DCPS::WriteDataContainer | private |
durability_cache_ | OpenDDS::DCPS::WriteDataContainer | private |
durability_service_ | OpenDDS::DCPS::WriteDataContainer | private |
empty_condition_ | OpenDDS::DCPS::WriteDataContainer | private |
enqueue(DataSampleElement *sample, DDS::InstanceHandle_t instance) | OpenDDS::DCPS::WriteDataContainer | |
enqueue_control(DataSampleElement *control_sample) | OpenDDS::DCPS::WriteDataContainer | |
extend_deadline(const PublicationInstance_rch &instance) | OpenDDS::DCPS::WriteDataContainer | private |
get_cumulative_ack() | OpenDDS::DCPS::WriteDataContainer | private |
get_handle_instance(DDS::InstanceHandle_t handle) | OpenDDS::DCPS::WriteDataContainer | |
get_instance_handles(InstanceHandleVec &instance_handles) | OpenDDS::DCPS::WriteDataContainer | |
get_last_ack() | OpenDDS::DCPS::WriteDataContainer | private |
get_resend_data() | OpenDDS::DCPS::WriteDataContainer | |
get_unsent_data(SendStateDataSampleList &list) | OpenDDS::DCPS::WriteDataContainer | |
history_depth_ | OpenDDS::DCPS::WriteDataContainer | private |
instances_ | OpenDDS::DCPS::WriteDataContainer | private |
lock_ | OpenDDS::DCPS::WriteDataContainer | mutableprivate |
log_send_state_lists(OPENDDS_STRING description) | OpenDDS::DCPS::WriteDataContainer | private |
max_blocking_time_ | OpenDDS::DCPS::WriteDataContainer | private |
max_durable_per_instance_ | OpenDDS::DCPS::WriteDataContainer | private |
max_num_instances_ | OpenDDS::DCPS::WriteDataContainer | private |
max_num_samples_ | OpenDDS::DCPS::WriteDataContainer | private |
max_samples_per_instance_ | OpenDDS::DCPS::WriteDataContainer | private |
n_chunks_ | OpenDDS::DCPS::WriteDataContainer | private |
num_all_samples() | OpenDDS::DCPS::WriteDataContainer | |
num_samples(DDS::InstanceHandle_t handle, size_t &size) | OpenDDS::DCPS::WriteDataContainer | |
obtain_buffer(DataSampleElement *&element, DDS::InstanceHandle_t handle) | OpenDDS::DCPS::WriteDataContainer | |
obtain_buffer_for_control(DataSampleElement *&element) | OpenDDS::DCPS::WriteDataContainer | |
OPENDDS_MAP_CMP(GUID_t, DisjointSequence, GUID_tKeyLessThan) AckedSequenceMap | OpenDDS::DCPS::WriteDataContainer | private |
OPENDDS_MULTIMAP(MonotonicTimePoint, PublicationInstance_rch) DeadlineMapType | OpenDDS::DCPS::WriteDataContainer | private |
OPENDDS_VECTOR(DDS::InstanceHandle_t) InstanceHandleVec | OpenDDS::DCPS::WriteDataContainer | |
operator=(WriteDataContainer const &) | OpenDDS::DCPS::WriteDataContainer | private |
orphaned_to_transport_ | OpenDDS::DCPS::WriteDataContainer | private |
pending_data() | OpenDDS::DCPS::WriteDataContainer | private |
persist_data() | OpenDDS::DCPS::WriteDataContainer | |
process_deadlines(const MonotonicTimePoint &now) | OpenDDS::DCPS::WriteDataContainer | private |
publication_id_ | OpenDDS::DCPS::WriteDataContainer | private |
RcObject() | OpenDDS::DCPS::RcObject | inlineprotected |
reenqueue_all(const GUID_t &reader_id, const DDS::LifespanQosPolicy &lifespan, const OPENDDS_STRING &filterClassName, const FilterEvaluator *eval, const DDS::StringSeq ¶ms) | OpenDDS::DCPS::WriteDataContainer | |
ref_count() const | OpenDDS::DCPS::RcObject | inline |
register_instance(DDS::InstanceHandle_t &instance_handle, Message_Block_Ptr ®istered_sample) | OpenDDS::DCPS::WriteDataContainer | |
release_buffer(DataSampleElement *element) | OpenDDS::DCPS::WriteDataContainer | |
remove_excess_durable() | OpenDDS::DCPS::WriteDataContainer | private |
remove_instance(PublicationInstance_rch instance, Message_Block_Ptr ®istered_sample, bool dup_registered_sample) | OpenDDS::DCPS::WriteDataContainer | private |
remove_oldest_sample(InstanceDataSampleList &instance_list, bool &released) | OpenDDS::DCPS::WriteDataContainer | private |
remove_reader_acks(const GUID_t &reader) | OpenDDS::DCPS::WriteDataContainer | private |
resend_data_ | OpenDDS::DCPS::WriteDataContainer | private |
sample_list_element_allocator_ | OpenDDS::DCPS::WriteDataContainer | private |
sending_data_ | OpenDDS::DCPS::WriteDataContainer | private |
sent_data_ | OpenDDS::DCPS::WriteDataContainer | private |
sequence_acknowledged(const SequenceNumber &sequence) | OpenDDS::DCPS::WriteDataContainer | |
sequence_acknowledged_i(const SequenceNumber &sequence) | OpenDDS::DCPS::WriteDataContainer | private |
set_deadline_period(const TimeDuration &deadline_period) | OpenDDS::DCPS::WriteDataContainer | private |
shutdown_ | OpenDDS::DCPS::WriteDataContainer | private |
topic_name_ | OpenDDS::DCPS::WriteDataContainer | private |
transaction_id_ | OpenDDS::DCPS::WriteDataContainer | private |
type_name_ | OpenDDS::DCPS::WriteDataContainer | private |
unregister(DDS::InstanceHandle_t handle, Message_Block_Ptr ®istered_sample, bool dup_registered_sample=true) | OpenDDS::DCPS::WriteDataContainer | |
unregister_all() | OpenDDS::DCPS::WriteDataContainer | |
unsent_data_ | OpenDDS::DCPS::WriteDataContainer | private |
update_acked(const SequenceNumber &seq, const GUID_t &id=GUID_UNKNOWN) | OpenDDS::DCPS::WriteDataContainer | private |
wait_ack_of_seq(const MonotonicTimePoint &abs_deadline, bool deadline_is_infinite, const SequenceNumber &sequence) | OpenDDS::DCPS::WriteDataContainer | |
wait_pending(const MonotonicTimePoint &deadline) | OpenDDS::DCPS::WriteDataContainer | |
waiting_on_release_ | OpenDDS::DCPS::WriteDataContainer | private |
wakeup_blocking_writers(DataSampleElement *stale) | OpenDDS::DCPS::WriteDataContainer | private |
wfa_condition_ | OpenDDS::DCPS::WriteDataContainer | private |
wfa_lock_ | OpenDDS::DCPS::WriteDataContainer | private |
WfaConditionVariableType typedef | OpenDDS::DCPS::WriteDataContainer | private |
WriteDataContainer(DataWriterImpl *writer, CORBA::Long max_samples_per_instance, CORBA::Long history_depth, CORBA::Long max_durable_per_instance, DDS::Duration_t max_blocking_time, size_t n_chunks, DDS::DomainId_t domain_id, char const *topic_name, char const *type_name, DataDurabilityCache *durability_cache, DDS::DurabilityServiceQosPolicy const &durability_service, CORBA::Long max_instances, CORBA::Long max_total_samples, ACE_Recursive_Thread_Mutex &deadline_status_lock, DDS::OfferedDeadlineMissedStatus &deadline_status, CORBA::Long &deadline_last_total_count) | OpenDDS::DCPS::WriteDataContainer | |
WriteDataContainer(WriteDataContainer const &) | OpenDDS::DCPS::WriteDataContainer | private |
writer_ | OpenDDS::DCPS::WriteDataContainer | private |
~RcObject() | OpenDDS::DCPS::RcObject | inlinevirtual |
~WriteDataContainer() | OpenDDS::DCPS::WriteDataContainer | |