OpenDDS  Snapshot(2023/04/28-20:55)
OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > Member List

This is the complete list of members for OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >, including all inherited members.

_add_ref()OpenDDS::DCPS::LocalObjectBaseinlinevirtual
_create_request(CORBA::Context_ptr ctx, const char *operation, CORBA::NVList_ptr arg_list, CORBA::NamedValue_ptr result, CORBA::Request_ptr &request, CORBA::Flags req_flags)CORBA::LocalObjectvirtual
_create_request(CORBA::Context_ptr ctx, const char *operation, CORBA::NVList_ptr arg_list, CORBA::NamedValue_ptr result, CORBA::ExceptionList_ptr exclist, CORBA::ContextList_ptr ctxtlist, CORBA::Request_ptr &request, CORBA::Flags req_flags)CORBA::LocalObjectvirtual
_decr_refcount(void)CORBA::Object
_duplicate(LocalObject_ptr obj)CORBA::LocalObjectstatic
CORBA::Object::_duplicate(CORBA::Object_ptr obj)CORBA::Objectstatic
_get_cached_policy(TAO_Cached_Policy_Type type)CORBA::LocalObject
_get_component(void)CORBA::LocalObjectvirtual
_get_interface(void)CORBA::LocalObjectvirtual
_get_orb(void)CORBA::LocalObjectvirtual
_get_policy(CORBA::PolicyType type)CORBA::LocalObject
_get_policy_overrides(const CORBA::PolicyTypeSeq &types)CORBA::LocalObject
_get_weak_object() constOpenDDS::DCPS::RcObjectinline
_hash(CORBA::ULong maximum)CORBA::LocalObjectvirtual
_interface_repository_id(void) constCORBA::Objectvirtual
_is_a(const char *logical_type_id)CORBA::Objectvirtual
_is_collocated(void) constCORBA::Objectvirtual
_is_equivalent(CORBA::Object_ptr other_obj)CORBA::LocalObjectvirtual
_is_local(void) constCORBA::Objectvirtual
_key(void)CORBA::LocalObjectvirtual
LocalObject< TypedDataReader::_narrow(CORBA::Object_ptr obj)OpenDDS::DCPS::LocalObject< TypedDataReader::Interface >inlinestatic
OpenDDS::DCPS::MultiTopicDataReaderBase::_narrow(CORBA::Object_ptr obj)OpenDDS::DCPS::LocalObject< DataReaderEx >inlinestatic
_nil(void)CORBA::LocalObjectstatic
_non_existent(void)CORBA::LocalObjectvirtual
_out_type typedefCORBA::LocalObject
_proxy_broker(TAO::Object_Proxy_Broker *proxy_broker)CORBA::Objectvirtual
LocalObject< TypedDataReader::_ptr_type typedefOpenDDS::DCPS::LocalObject< TypedDataReader::Interface >
OpenDDS::DCPS::MultiTopicDataReaderBase::_ptr_type typedefOpenDDS::DCPS::LocalObject< DataReaderEx >
_refcount_value() constOpenDDS::DCPS::LocalObjectBaseinlinevirtual
_remove_ref()OpenDDS::DCPS::LocalObjectBaseinlinevirtual
_repository_id(void)CORBA::LocalObjectvirtual
_request(const char *operation)CORBA::LocalObjectvirtual
_servant(void) constCORBA::Objectvirtual
_set_policy_overrides(const CORBA::PolicyList &policies, CORBA::SetOverrideType set_add)CORBA::LocalObject
_stubobj(void) constCORBA::Objectvirtual
_stubobj(void)CORBA::Objectvirtual
_tao_any_destructor(void *)CORBA::Objectstatic
_validate_connection(CORBA::PolicyList_out inconsistent_policies)CORBA::LocalObject
LocalObject< TypedDataReader::_var_type typedefOpenDDS::DCPS::LocalObject< TypedDataReader::Interface >
OpenDDS::DCPS::MultiTopicDataReaderBase::_var_type typedefOpenDDS::DCPS::LocalObject< DataReaderEx >
assign_fields(Sample &resulting, void *incoming, 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
can_convert_to_ior(void) constCORBA::Objectvirtual
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
convert_to_ior(bool use_omg_ior_format, const char *ior_prefix) constCORBA::Objectvirtual
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
LocalObject< DataReaderEx >::create_querycondition(in SampleStateMask sample_states, in ViewStateMask view_states, in InstanceStateMask instance_states, in string query_expression, in StringSeq query_parameters)DDS::DataReader
create_readcondition(DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)OpenDDS::DCPS::MultiTopicDataReaderBase
LocalObject< DataReaderEx >::create_readcondition(in SampleStateMask sample_states, in ViewStateMask view_states, in InstanceStateMask instance_states)DDS::DataReader
cross_join(OPENDDS_MAP(TopicSet, SampleVec)&partial_results, 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
LocalObject< DataReaderEx >::delete_readcondition(in ReadCondition a_condition)DDS::DataReader
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
LocalObject< DataReaderEx >::get_latency_stats(inout LatencyStatisticsSeq stats)OpenDDS::DCPS::DataReaderEx
get_listener()OpenDDS::DCPS::MultiTopicDataReaderBase
get_liveliness_changed_status(DDS::LivelinessChangedStatus &status)OpenDDS::DCPS::MultiTopicDataReaderBase
LocalObject< DataReaderEx >::get_liveliness_changed_status(inout LivelinessChangedStatus status)DDS::DataReader
get_matched_publication_data(DDS::PublicationBuiltinTopicData &publication_data, DDS::InstanceHandle_t publication_handle)OpenDDS::DCPS::MultiTopicDataReaderBase
LocalObject< DataReaderEx >::get_matched_publication_data(inout PublicationBuiltinTopicData publication_data, in InstanceHandle_t publication_handle)DDS::DataReader
get_matched_publications(DDS::InstanceHandleSeq &publication_handles)OpenDDS::DCPS::MultiTopicDataReaderBase
LocalObject< DataReaderEx >::get_matched_publications(inout InstanceHandleSeq publication_handles)DDS::DataReader
get_qos(DDS::DataReaderQos &qos)OpenDDS::DCPS::MultiTopicDataReaderBase
LocalObject< DataReaderEx >::get_qos(inout DataReaderQos qos)DDS::DataReader
get_requested_deadline_missed_status(DDS::RequestedDeadlineMissedStatus &status)OpenDDS::DCPS::MultiTopicDataReaderBase
LocalObject< DataReaderEx >::get_requested_deadline_missed_status(inout RequestedDeadlineMissedStatus status)DDS::DataReader
get_requested_incompatible_qos_status(DDS::RequestedIncompatibleQosStatus &status)OpenDDS::DCPS::MultiTopicDataReaderBase
LocalObject< DataReaderEx >::get_requested_incompatible_qos_status(inout RequestedIncompatibleQosStatus status)DDS::DataReader
get_sample_lost_status(DDS::SampleLostStatus &status)OpenDDS::DCPS::MultiTopicDataReaderBase
LocalObject< DataReaderEx >::get_sample_lost_status(inout SampleLostStatus status)DDS::DataReader
get_sample_rejected_status(DDS::SampleRejectedStatus &status)OpenDDS::DCPS::MultiTopicDataReaderBase
LocalObject< DataReaderEx >::get_sample_rejected_status(inout SampleRejectedStatus status)DDS::DataReader
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
LocalObject< DataReaderEx >::get_subscription_matched_status(inout SubscriptionMatchedStatus status)DDS::DataReader
get_topicdescription()OpenDDS::DCPS::MultiTopicDataReaderBase
getResultingMeta()OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >virtual
have_sample_states(DDS::SampleStateMask sample_states) constOpenDDS::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
ior(void) constCORBA::Object
is_evaluated(void) constCORBA::Object
is_nil_i(CORBA::Object_ptr obj)CORBA::Objectstatic
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
LocalObject(void)CORBA::LocalObjectprotected
lookup_instance(const Sample &instance_data)OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >
marshal(TAO_OutputCDR &cdr)CORBA::Objectvirtual
marshal(const Object_ptr x, TAO_OutputCDR &cdr)CORBA::Objectstatic
metaStructFor(DDS::DataReader_ptr dr)OpenDDS::DCPS::MultiTopicDataReaderBaseprotected
MultiTopicDataReader_T()OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >inline
MultiTopicDataReaderBase()OpenDDS::DCPS::MultiTopicDataReaderBaseinline
Object(TAO_Stub *p, CORBA::Boolean collocated=false, TAO_Abstract_ServantBase *servant=0, TAO_ORB_Core *orb_core=0)CORBA::Object
Object(IOP::IOR *ior, TAO_ORB_Core *orb_core)CORBA::Object
Object(int dummy=0)CORBA::Objectprotected
OPENDDS_MAP(OPENDDS_STRING, QueryPlan) query_plans_OpenDDS::DCPS::MultiTopicDataReaderBaseprotected
orb_core(void) constCORBA::Object
process_joins(OPENDDS_MAP(TopicSet, SampleVec)&partial_results, SampleVec starting, const TopicSet &seen, const QueryPlan &qp)OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >private
proxy_broker() constCORBA::Objectprotected
qp_lock_OpenDDS::DCPS::MultiTopicDataReaderBasemutableprotected
RcObject()OpenDDS::DCPS::RcObjectinlineprotected
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_instance_w_condition(SampleSeq &data_values, DDS::SampleInfoSeq &sample_infos, CORBA::Long max_samples, DDS::InstanceHandle_t handle, DDS::ReadCondition_ptr a_condition)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 >
ref_count() constOpenDDS::DCPS::RcObjectinline
refcount_CORBA::Objectprotected
reset_latency_stats()OpenDDS::DCPS::MultiTopicDataReaderBase
return_loan(SampleSeq &received_data, DDS::SampleInfoSeq &info_seq)OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >
SampleSeq typedefOpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >
SampleVec typedefOpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >private
set_listener(DDS::DataReaderListener_ptr a_listener, DDS::StatusMask mask)OpenDDS::DCPS::MultiTopicDataReaderBase
LocalObject< DataReaderEx >::set_listener(in DataReaderListener a_listener, in StatusMask mask)DDS::DataReader
set_qos(const DDS::DataReaderQos &qos)OpenDDS::DCPS::MultiTopicDataReaderBase
LocalObject< DataReaderEx >::set_qos(in DataReaderQos qos)DDS::DataReader
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
LocalObject< DataReaderEx >::statistics_enabledOpenDDS::DCPS::DataReaderEx
steal_ior(void)CORBA::Object
SubjectFieldSpec typedefOpenDDS::DCPS::MultiTopicDataReaderBaseprotected
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_instance_w_condition(SampleSeq &data_values, DDS::SampleInfoSeq &sample_infos, CORBA::Long max_samples, DDS::InstanceHandle_t handle, DDS::ReadCondition_ptr a_condition)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 >
tao_object_initialize(Object *)CORBA::Objectstatic
topicNameFor(DDS::DataReader_ptr dr)OpenDDS::DCPS::MultiTopicDataReaderBaseprotected
TopicSet typedefOpenDDS::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
LocalObject< DataReaderEx >::wait_for_historical_data(in Duration_t max_wait)DDS::DataReader
~LocalObject(void)CORBA::LocalObjectvirtual
~Object(void)CORBA::Objectvirtual
~RcObject()OpenDDS::DCPS::RcObjectinlinevirtual