::DDS_TEST class | OpenDDS::DCPS::WriteDataContainer | [friend] |
acked_sequences_ | OpenDDS::DCPS::WriteDataContainer | [private] |
condition_ | OpenDDS::DCPS::WriteDataContainer | [private] |
copy_and_append(SendStateDataSampleList &list, const SendStateDataSampleList &appended, const RepoId &reader_id, const DDS::LifespanQosPolicy &lifespan, const OPENDDS_STRING &filterClassName, const FilterEvaluator *eval, const DDS::StringSeq ¶ms) | 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] |
depth_ | OpenDDS::DCPS::WriteDataContainer | [private] |
dispose(DDS::InstanceHandle_t handle, DataSample *®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 | |
get_handle_instance(DDS::InstanceHandle_t handle) | OpenDDS::DCPS::WriteDataContainer | |
get_instance_handles(InstanceHandleVec &instance_handles) | OpenDDS::DCPS::WriteDataContainer | |
get_resend_data() | OpenDDS::DCPS::WriteDataContainer | |
get_unsent_data(SendStateDataSampleList &list) | OpenDDS::DCPS::WriteDataContainer | |
instances_ | OpenDDS::DCPS::WriteDataContainer | [private] |
lock_ | OpenDDS::DCPS::WriteDataContainer | [private] |
log_send_state_lists(OPENDDS_STRING description) | OpenDDS::DCPS::WriteDataContainer | [private] |
max_blocking_time_ | OpenDDS::DCPS::WriteDataContainer | [private] |
max_num_instances_ | OpenDDS::DCPS::WriteDataContainer | [private] |
max_num_samples_ | 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_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 | |
persist_data() | OpenDDS::DCPS::WriteDataContainer | |
publication_id_ | OpenDDS::DCPS::WriteDataContainer | [private] |
reenqueue_all(const RepoId &reader_id, const DDS::LifespanQosPolicy &lifespan, const OPENDDS_STRING &filterClassName, const FilterEvaluator *eval, const DDS::StringSeq ¶ms) | OpenDDS::DCPS::WriteDataContainer | |
register_instance(DDS::InstanceHandle_t &instance_handle, DataSample *®istered_sample) | OpenDDS::DCPS::WriteDataContainer | |
release_buffer(DataSampleElement *element) | OpenDDS::DCPS::WriteDataContainer | |
remove_oldest_historical_sample(InstanceDataSampleList &instance_list, bool &released) | OpenDDS::DCPS::WriteDataContainer | [private] |
remove_oldest_sample(InstanceDataSampleList &instance_list, bool &released) | OpenDDS::DCPS::WriteDataContainer | [private] |
reschedule_deadline() | OpenDDS::DCPS::WriteDataContainer | |
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 | |
shutdown_ | OpenDDS::DCPS::WriteDataContainer | [private] |
topic_name_ | OpenDDS::DCPS::WriteDataContainer | [private] |
transaction_id_ | OpenDDS::DCPS::WriteDataContainer | [private] |
transport_customized_element_allocator_ | OpenDDS::DCPS::WriteDataContainer | [private] |
transport_send_element_allocator_ | OpenDDS::DCPS::WriteDataContainer | [private] |
type_name_ | OpenDDS::DCPS::WriteDataContainer | [private] |
unregister(DDS::InstanceHandle_t handle, DataSample *®istered_sample, bool dup_registered_sample=true) | OpenDDS::DCPS::WriteDataContainer | |
unregister_all() | OpenDDS::DCPS::WriteDataContainer | |
unsent_data_ | OpenDDS::DCPS::WriteDataContainer | [private] |
wait_ack_of_seq(const ACE_Time_Value &abs_deadline, const SequenceNumber &sequence) | OpenDDS::DCPS::WriteDataContainer | |
wait_pending() | 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] |
WriteDataContainer(DataWriterImpl *writer, CORBA::Long depth,::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) | OpenDDS::DCPS::WriteDataContainer | |
WriteDataContainer(WriteDataContainer const &) | OpenDDS::DCPS::WriteDataContainer | [private] |
writer_ | OpenDDS::DCPS::WriteDataContainer | [private] |
~WriteDataContainer() | OpenDDS::DCPS::WriteDataContainer | |