| OpenDDS::_narrow(CORBA::Object_ptr obj) | OpenDDS::DCPS::LocalObject< TypedDataReader::Interface > | [inline, static] |
| OpenDDS::DCPS::MultiTopicDataReaderBase::_narrow(CORBA::Object_ptr obj) | OpenDDS::DCPS::LocalObject< Stub > | [inline, static] |
| OpenDDS::_ptr_type typedef | OpenDDS::DCPS::LocalObject< TypedDataReader::Interface > | |
| OpenDDS::DCPS::MultiTopicDataReaderBase::_ptr_type typedef | OpenDDS::DCPS::LocalObject< Stub > | |
| OpenDDS::_var_type typedef | OpenDDS::DCPS::LocalObject< TypedDataReader::Interface > | |
| OpenDDS::DCPS::MultiTopicDataReaderBase::_var_type typedef | OpenDDS::DCPS::LocalObject< Stub > | |
| assign_fields(void *incoming, Sample &resulting, const QueryPlan &qp, const MetaStruct &meta) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | [private] |
| assign_resulting_fields(Sample &target, const Sample &source, const TopicSet &other_topics) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | [private] |
| cleanup() | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| combine(SampleVec &resulting, const SampleVec &other, const std::vector< OPENDDS_STRING > &key_names, const TopicSet &other_topics) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | [private] |
| create_querycondition(DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states, const char *query_expression, const DDS::StringSeq &query_parameters) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| create_readcondition(DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| cross_join(OPENDDS_MAP(TopicSet, SampleVec)&partialResults, const TopicSet &seen, const QueryPlan &qp) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | [private] |
| data_available(DDS::DataReader_ptr reader) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| delete_contained_entities() | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| delete_readcondition(DDS::ReadCondition_ptr a_condition) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| enable() | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_instance_handle() | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_key_value(Sample &key_holder, DDS::InstanceHandle_t handle) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| get_latency_stats(LatencyStatisticsSeq &stats) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_listener() | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_liveliness_changed_status(DDS::LivelinessChangedStatus &status) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_matched_publication_data(DDS::PublicationBuiltinTopicData &publication_data, DDS::InstanceHandle_t publication_handle) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_matched_publications(DDS::InstanceHandleSeq &publication_handles) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_qos(DDS::DataReaderQos &qos) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_requested_deadline_missed_status(DDS::RequestedDeadlineMissedStatus &status) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_requested_incompatible_qos_status(DDS::RequestedIncompatibleQosStatus &status) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_sample_lost_status(DDS::SampleLostStatus &status) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_sample_rejected_status(DDS::SampleRejectedStatus &status) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_status_changes() | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_statuscondition() | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_subscriber() | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_subscription_matched_status(DDS::SubscriptionMatchedStatus &status) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| get_topicdescription() | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| getResultingMeta() | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | [virtual] |
| have_sample_states(DDS::SampleStateMask sample_states) const | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| incoming_sample(void *sample, const DDS::SampleInfo &info, const char *topic, const MetaStruct &meta) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | [virtual] |
| init(const DDS::DataReaderQos &dr_qos, DDS::DataReaderListener_ptr a_listener, DDS::StatusMask mask, SubscriberImpl *parent, MultiTopicImpl *multitopic) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| init_typed(DataReaderEx *dr) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | [virtual] |
| join(SampleVec &resulting, const SampleWithInfo &prototype, const std::vector< OPENDDS_STRING > &key_names, const void *key_data, DDS::DataReader_ptr other_dr, const MetaStruct &other_meta) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | [private] |
| lookup_instance(const Sample &instance_data) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| metaStructFor(DDS::DataReader_ptr dr) | OpenDDS::DCPS::MultiTopicDataReaderBase | [protected] |
| MultiTopicDataReader_T() | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | [inline] |
| MultiTopicDataReaderBase() | OpenDDS::DCPS::MultiTopicDataReaderBase | [inline] |
| OPENDDS_MAP(OPENDDS_STRING, QueryPlan) query_plans_ | OpenDDS::DCPS::MultiTopicDataReaderBase | [protected] |
| process_joins(OPENDDS_MAP(TopicSet, SampleVec)&partialResults, SampleVec starting, const TopicSet &seen, const QueryPlan &qp) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | [private] |
| read(SampleSeq &received_data, DDS::SampleInfoSeq &info_seq, CORBA::Long max_samples, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| read_instance(SampleSeq &received_data, DDS::SampleInfoSeq &info_seq, CORBA::Long max_samples, DDS::InstanceHandle_t a_handle, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| read_next_instance(SampleSeq &received_data, DDS::SampleInfoSeq &info_seq, CORBA::Long max_samples, DDS::InstanceHandle_t a_handle, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| read_next_instance_w_condition(SampleSeq &data_values, DDS::SampleInfoSeq &sample_infos, CORBA::Long max_samples, DDS::InstanceHandle_t previous_handle, DDS::ReadCondition_ptr a_condition) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| read_next_sample(Sample &received_data, DDS::SampleInfo &sample_info) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| read_w_condition(SampleSeq &data_values, DDS::SampleInfoSeq &sample_infos, CORBA::Long max_samples, DDS::ReadCondition_ptr a_condition) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| reset_latency_stats() | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| return_loan(SampleSeq &received_data, DDS::SampleInfoSeq &info_seq) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| SampleSeq typedef | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| SampleVec typedef | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | [private] |
| set_listener(DDS::DataReaderListener_ptr a_listener, DDS::StatusMask mask) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| set_qos(const DDS::DataReaderQos &qos) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| set_status_changed_flag(DDS::StatusKind status, bool flag) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| statistics_enabled() | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| statistics_enabled(CORBA::Boolean statistics_enabled) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
| SubjectFieldSpec typedef | OpenDDS::DCPS::MultiTopicDataReaderBase | [protected] |
| take(SampleSeq &received_data, DDS::SampleInfoSeq &info_seq, CORBA::Long max_samples, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| take_instance(SampleSeq &received_data, DDS::SampleInfoSeq &info_seq, CORBA::Long max_samples, DDS::InstanceHandle_t a_handle, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| take_next_instance(SampleSeq &received_data, DDS::SampleInfoSeq &info_seq, CORBA::Long max_samples, DDS::InstanceHandle_t a_handle, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| take_next_instance_w_condition(SampleSeq &data_values, DDS::SampleInfoSeq &sample_infos, CORBA::Long max_samples, DDS::InstanceHandle_t previous_handle, DDS::ReadCondition_ptr a_condition) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| take_next_sample(Sample &received_data, DDS::SampleInfo &sample_info) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| take_w_condition(SampleSeq &data_values, DDS::SampleInfoSeq &sample_infos, CORBA::Long max_samples, DDS::ReadCondition_ptr a_condition) | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | |
| topicNameFor(DDS::DataReader_ptr dr) | OpenDDS::DCPS::MultiTopicDataReaderBase | [protected] |
| TopicSet typedef | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | [private] |
| typed_reader_ | OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > | [private] |
| wait_for_historical_data(const DDS::Duration_t &max_wait) | OpenDDS::DCPS::MultiTopicDataReaderBase | |
