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::LocalObjectBase [inline, virtual]
_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::LocalObject [virtual]
_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::LocalObject [virtual]
_decr_refcount(void)CORBA::Object
_duplicate(LocalObject_ptr obj)CORBA::LocalObject [static]
_get_component(void)CORBA::LocalObject [virtual]
_get_interface(void)CORBA::LocalObject [virtual]
_get_orb(void)CORBA::LocalObject [virtual]
_get_weak_object() const OpenDDS::DCPS::RcObject [inline]
_hash(CORBA::ULong maximum)CORBA::LocalObject [virtual]
_interface_repository_id(void) const CORBA::Object [virtual]
_is_a(const char *logical_type_id)CORBA::Object [virtual]
_is_collocated(void) const CORBA::Object [virtual]
_is_equivalent(CORBA::Object_ptr other_obj)CORBA::LocalObject [virtual]
CORBA::Object::_is_equivalent(CORBA::Object_ptr other_obj)CORBA::Object [virtual]
_is_local(void) const CORBA::Object [virtual]
_key(void)CORBA::LocalObject [virtual]
LocalObject< TypedDataReader::_narrow(CORBA::Object_ptr obj)OpenDDS::DCPS::LocalObject< TypedDataReader::Interface > [inline, static]
LocalObject< TypedDataReader::CORBA::Object::_narrow(CORBA::Object_ptr obj)CORBA::Object [static]
OpenDDS::DCPS::MultiTopicDataReaderBase::_narrow(CORBA::Object_ptr obj)OpenDDS::DCPS::LocalObject< DataReaderEx > [inline, static]
_nil(void)CORBA::LocalObject [static]
_non_existent(void)CORBA::LocalObject [virtual]
_out_type typedefCORBA::LocalObject
_proxy_broker(TAO::Object_Proxy_Broker *proxy_broker)CORBA::Object [virtual]
LocalObject< TypedDataReader::_ptr_type typedefOpenDDS::DCPS::LocalObject< TypedDataReader::Interface >
OpenDDS::DCPS::MultiTopicDataReaderBase::_ptr_type typedefOpenDDS::DCPS::LocalObject< DataReaderEx >
_refcount_value(void) const CORBA::Object [virtual]
_remove_ref()OpenDDS::DCPS::LocalObjectBase [inline, virtual]
_repository_id(void)CORBA::LocalObject [virtual]
_request(const char *operation)CORBA::LocalObject [virtual]
_servant(void) const CORBA::Object [virtual]
_stubobj(void) const CORBA::Object [virtual]
_stubobj(void)CORBA::Object [virtual]
_tao_any_destructor(void *)CORBA::Object [static]
LocalObject< TypedDataReader::_var_type typedefOpenDDS::DCPS::LocalObject< TypedDataReader::Interface >
OpenDDS::DCPS::MultiTopicDataReaderBase::_var_type typedefOpenDDS::DCPS::LocalObject< DataReaderEx >
assign_fields(void *incoming, Sample &resulting, const QueryPlan &qp, const MetaStruct &meta)OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > [inline, private]
assign_resulting_fields(Sample &target, const Sample &source, const TopicSet &other_topics)OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > [inline, private]
can_convert_to_ior(void) const CORBA::Object [virtual]
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 > [inline, private]
convert_to_ior(bool use_omg_ior_format, const char *ior_prefix) const CORBA::Object [virtual]
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)&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
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 > [inline]
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 > [inline, 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 > [inline, 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 > [inline, virtual]
ior(void) const CORBA::Object
is_evaluated(void) const CORBA::Object
is_nil_i(CORBA::Object_ptr obj)CORBA::Object [static]
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 > [inline, private]
LocalObject(void)CORBA::LocalObject [protected]
lookup_instance(const Sample &instance_data)OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > [inline]
marshal(TAO_OutputCDR &cdr)CORBA::Object [virtual]
marshal(const Object_ptr x, TAO_OutputCDR &cdr)CORBA::Object [static]
metaStructFor(DDS::DataReader_ptr dr)OpenDDS::DCPS::MultiTopicDataReaderBase [protected]
MultiTopicDataReader_T()OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > [inline]
MultiTopicDataReaderBase()OpenDDS::DCPS::MultiTopicDataReaderBase [inline]
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::Object [protected]
OPENDDS_MAP(OPENDDS_STRING, QueryPlan) query_plans_OpenDDS::DCPS::MultiTopicDataReaderBase [protected]
orb_core(void) const CORBA::Object
process_joins(OPENDDS_MAP(TopicSet, SampleVec)&partialResults, SampleVec starting, const TopicSet &seen, const QueryPlan &qp)OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > [private]
proxy_broker() const CORBA::Object [protected]
RcObject()OpenDDS::DCPS::RcObject [inline, protected]
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 > [inline]
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 > [inline]
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 > [inline]
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 > [inline]
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 > [inline]
read_next_sample(Sample &received_data, DDS::SampleInfo &sample_info)OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > [inline]
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 > [inline]
ref_count() const OpenDDS::DCPS::RcObject [inline]
refcount_CORBA::Object [protected]
reset_latency_stats()OpenDDS::DCPS::MultiTopicDataReaderBase
return_loan(SampleSeq &received_data, DDS::SampleInfoSeq &info_seq)OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > [inline]
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::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 > [inline]
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 > [inline]
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 > [inline]
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 > [inline]
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 > [inline]
take_next_sample(Sample &received_data, DDS::SampleInfo &sample_info)OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader > [inline]
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 > [inline]
tao_object_initialize(Object *)CORBA::Object [static]
topicNameFor(DDS::DataReader_ptr dr)OpenDDS::DCPS::MultiTopicDataReaderBase [protected]
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::LocalObject [virtual]
~Object(void)CORBA::Object [virtual]
~RcObject()OpenDDS::DCPS::RcObject [inline, virtual]
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Defines

Generated on 10 Aug 2018 for OpenDDS by  doxygen 1.6.1