OpenDDS  Snapshot(2023/04/28-20:55)
OpenDDS::DCPS::WriteDataContainer Member List

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

::DDS_TEST classOpenDDS::DCPS::WriteDataContainerfriend
_add_ref()OpenDDS::DCPS::RcObjectinlinevirtual
_get_weak_object() constOpenDDS::DCPS::RcObjectinline
_remove_ref()OpenDDS::DCPS::RcObjectinlinevirtual
acked_sequences_OpenDDS::DCPS::WriteDataContainerprivate
add_reader_acks(const GUID_t &reader, const SequenceNumber &base)OpenDDS::DCPS::WriteDataContainerprivate
cached_cumulative_ack_OpenDDS::DCPS::WriteDataContainerprivate
cached_cumulative_ack_valid_OpenDDS::DCPS::WriteDataContainerprivate
cancel_deadline(const PublicationInstance_rch &instance)OpenDDS::DCPS::WriteDataContainerprivate
condition_OpenDDS::DCPS::WriteDataContainerprivate
ConditionVariableType typedefOpenDDS::DCPS::WriteDataContainerprivate
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 &params, ssize_t &max_resend_samples)OpenDDS::DCPS::WriteDataContainerprivate
data_delivered(const DataSampleElement *sample)OpenDDS::DCPS::WriteDataContainer
data_dropped(const DataSampleElement *element, bool dropped_by_transport)OpenDDS::DCPS::WriteDataContainer
data_holder_OpenDDS::DCPS::WriteDataContainerprivate
DataWriterImpl classOpenDDS::DCPS::WriteDataContainerfriend
deadline_last_total_count_OpenDDS::DCPS::WriteDataContainerprivate
deadline_map_OpenDDS::DCPS::WriteDataContainerprivate
deadline_period_OpenDDS::DCPS::WriteDataContainerprivate
deadline_status_OpenDDS::DCPS::WriteDataContainerprivate
deadline_status_lock_OpenDDS::DCPS::WriteDataContainerprivate
deadline_task_OpenDDS::DCPS::WriteDataContainerprivate
dispose(DDS::InstanceHandle_t handle, Message_Block_Ptr &registered_sample, bool dup_registered_sample=true)OpenDDS::DCPS::WriteDataContainer
domain_id_OpenDDS::DCPS::WriteDataContainerprivate
durability_cache_OpenDDS::DCPS::WriteDataContainerprivate
durability_service_OpenDDS::DCPS::WriteDataContainerprivate
empty_condition_OpenDDS::DCPS::WriteDataContainerprivate
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::WriteDataContainerprivate
get_cumulative_ack()OpenDDS::DCPS::WriteDataContainerprivate
get_handle_instance(DDS::InstanceHandle_t handle)OpenDDS::DCPS::WriteDataContainer
get_instance_handles(InstanceHandleVec &instance_handles)OpenDDS::DCPS::WriteDataContainer
get_last_ack()OpenDDS::DCPS::WriteDataContainerprivate
get_resend_data()OpenDDS::DCPS::WriteDataContainer
get_unsent_data(SendStateDataSampleList &list)OpenDDS::DCPS::WriteDataContainer
history_depth_OpenDDS::DCPS::WriteDataContainerprivate
instances_OpenDDS::DCPS::WriteDataContainerprivate
lock_OpenDDS::DCPS::WriteDataContainermutableprivate
log_send_state_lists(OPENDDS_STRING description)OpenDDS::DCPS::WriteDataContainerprivate
max_blocking_time_OpenDDS::DCPS::WriteDataContainerprivate
max_durable_per_instance_OpenDDS::DCPS::WriteDataContainerprivate
max_num_instances_OpenDDS::DCPS::WriteDataContainerprivate
max_num_samples_OpenDDS::DCPS::WriteDataContainerprivate
max_samples_per_instance_OpenDDS::DCPS::WriteDataContainerprivate
n_chunks_OpenDDS::DCPS::WriteDataContainerprivate
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) AckedSequenceMapOpenDDS::DCPS::WriteDataContainerprivate
OPENDDS_MULTIMAP(MonotonicTimePoint, PublicationInstance_rch) DeadlineMapTypeOpenDDS::DCPS::WriteDataContainerprivate
OPENDDS_VECTOR(DDS::InstanceHandle_t) InstanceHandleVecOpenDDS::DCPS::WriteDataContainer
operator=(WriteDataContainer const &)OpenDDS::DCPS::WriteDataContainerprivate
orphaned_to_transport_OpenDDS::DCPS::WriteDataContainerprivate
pending_data()OpenDDS::DCPS::WriteDataContainerprivate
persist_data()OpenDDS::DCPS::WriteDataContainer
process_deadlines(const MonotonicTimePoint &now)OpenDDS::DCPS::WriteDataContainerprivate
publication_id_OpenDDS::DCPS::WriteDataContainerprivate
RcObject()OpenDDS::DCPS::RcObjectinlineprotected
reenqueue_all(const GUID_t &reader_id, const DDS::LifespanQosPolicy &lifespan, const OPENDDS_STRING &filterClassName, const FilterEvaluator *eval, const DDS::StringSeq &params)OpenDDS::DCPS::WriteDataContainer
ref_count() constOpenDDS::DCPS::RcObjectinline
register_instance(DDS::InstanceHandle_t &instance_handle, Message_Block_Ptr &registered_sample)OpenDDS::DCPS::WriteDataContainer
release_buffer(DataSampleElement *element)OpenDDS::DCPS::WriteDataContainer
remove_excess_durable()OpenDDS::DCPS::WriteDataContainerprivate
remove_instance(PublicationInstance_rch instance, Message_Block_Ptr &registered_sample, bool dup_registered_sample)OpenDDS::DCPS::WriteDataContainerprivate
remove_oldest_sample(InstanceDataSampleList &instance_list, bool &released)OpenDDS::DCPS::WriteDataContainerprivate
remove_reader_acks(const GUID_t &reader)OpenDDS::DCPS::WriteDataContainerprivate
resend_data_OpenDDS::DCPS::WriteDataContainerprivate
sample_list_element_allocator_OpenDDS::DCPS::WriteDataContainerprivate
sending_data_OpenDDS::DCPS::WriteDataContainerprivate
sent_data_OpenDDS::DCPS::WriteDataContainerprivate
sequence_acknowledged(const SequenceNumber &sequence)OpenDDS::DCPS::WriteDataContainer
sequence_acknowledged_i(const SequenceNumber &sequence)OpenDDS::DCPS::WriteDataContainerprivate
set_deadline_period(const TimeDuration &deadline_period)OpenDDS::DCPS::WriteDataContainerprivate
shutdown_OpenDDS::DCPS::WriteDataContainerprivate
topic_name_OpenDDS::DCPS::WriteDataContainerprivate
transaction_id_OpenDDS::DCPS::WriteDataContainerprivate
type_name_OpenDDS::DCPS::WriteDataContainerprivate
unregister(DDS::InstanceHandle_t handle, Message_Block_Ptr &registered_sample, bool dup_registered_sample=true)OpenDDS::DCPS::WriteDataContainer
unregister_all()OpenDDS::DCPS::WriteDataContainer
unsent_data_OpenDDS::DCPS::WriteDataContainerprivate
update_acked(const SequenceNumber &seq, const GUID_t &id=GUID_UNKNOWN)OpenDDS::DCPS::WriteDataContainerprivate
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::WriteDataContainerprivate
wakeup_blocking_writers(DataSampleElement *stale)OpenDDS::DCPS::WriteDataContainerprivate
wfa_condition_OpenDDS::DCPS::WriteDataContainerprivate
wfa_lock_OpenDDS::DCPS::WriteDataContainerprivate
WfaConditionVariableType typedefOpenDDS::DCPS::WriteDataContainerprivate
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::WriteDataContainerprivate
writer_OpenDDS::DCPS::WriteDataContainerprivate
~RcObject()OpenDDS::DCPS::RcObjectinlinevirtual
~WriteDataContainer()OpenDDS::DCPS::WriteDataContainer