#include <MultiTopicDataReader_T.h>

Inheritance diagram for OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >:

[legend]

Collaboration diagram for OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >:

[legend]

Classes
struct	Contains

struct	GenericData

struct	SampleWithInfo

Public Types
typedef TAO::DCPS::ZeroCopyDataSeq< Sample >	SampleSeq

Public Types inherited from OpenDDS::DCPS::LocalObject< TypedDataReader::Interface >
typedef TypedDataReader::Interface ::_ptr_type	_ptr_type

typedef TypedDataReader::Interface ::_var_type	_var_type

Public Types inherited from CORBA::LocalObject
typedef LocalObject_ptr	_ptr_type

typedef LocalObject_var	_var_type

typedef LocalObject_out	_out_type

Public Types inherited from CORBA::Object
typedef Object_ptr	_ptr_type

typedef Object_var	_var_type

typedef Object_out	_out_type

Public Types inherited from OpenDDS::DCPS::LocalObject< DataReaderEx >
typedef DataReaderEx ::_ptr_type	_ptr_type

typedef DataReaderEx ::_var_type	_var_type

Public Member Functions
	MultiTopicDataReader_T ()

void	init_typed (DataReaderEx *dr)

const MetaStruct &	getResultingMeta ()

void	incoming_sample (void sample, const DDS::SampleInfo &info, const char topic, const MetaStruct &meta)

DDS::ReturnCode_t	read (SampleSeq &received_data, DDS::SampleInfoSeq &info_seq, CORBA::Long max_samples, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)

DDS::ReturnCode_t	take (SampleSeq &received_data, DDS::SampleInfoSeq &info_seq, CORBA::Long max_samples, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)

DDS::ReturnCode_t	read_w_condition (SampleSeq &data_values, DDS::SampleInfoSeq &sample_infos, CORBA::Long max_samples, DDS::ReadCondition_ptr a_condition)

DDS::ReturnCode_t	take_w_condition (SampleSeq &data_values, DDS::SampleInfoSeq &sample_infos, CORBA::Long max_samples, DDS::ReadCondition_ptr a_condition)

DDS::ReturnCode_t	read_next_sample (Sample &received_data, DDS::SampleInfo &sample_info)

DDS::ReturnCode_t	take_next_sample (Sample &received_data, DDS::SampleInfo &sample_info)

DDS::ReturnCode_t	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)

DDS::ReturnCode_t	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)

DDS::ReturnCode_t	read_instance_w_condition (SampleSeq &data_values, DDS::SampleInfoSeq &sample_infos, CORBA::Long max_samples, DDS::InstanceHandle_t handle, DDS::ReadCondition_ptr a_condition)

DDS::ReturnCode_t	take_instance_w_condition (SampleSeq &data_values, DDS::SampleInfoSeq &sample_infos, CORBA::Long max_samples, DDS::InstanceHandle_t handle, DDS::ReadCondition_ptr a_condition)

DDS::ReturnCode_t	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)

DDS::ReturnCode_t	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)

DDS::ReturnCode_t	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)

DDS::ReturnCode_t	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)

DDS::ReturnCode_t	return_loan (SampleSeq &received_data, DDS::SampleInfoSeq &info_seq)

DDS::ReturnCode_t	get_key_value (Sample &key_holder, DDS::InstanceHandle_t handle)

DDS::InstanceHandle_t	lookup_instance (const Sample &instance_data)

Public Member Functions inherited from OpenDDS::DCPS::LocalObjectBase
virtual void	_add_ref ()

virtual void	_remove_ref ()

virtual CORBA::ULong	_refcount_value () const

Public Member Functions inherited from CORBA::LocalObject
virtual	~LocalObject (void)

virtual CORBA::Boolean	_non_existent (void)

virtual char *	_repository_id (void)

virtual CORBA::InterfaceDef_ptr	_get_interface (void)

virtual CORBA::Object_ptr	_get_component (void)

virtual void	_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)

virtual void	_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)

virtual CORBA::Request_ptr	_request (const char *operation)

CORBA::Policy_ptr	_get_policy (CORBA::PolicyType type)

CORBA::Policy_ptr	_get_cached_policy (TAO_Cached_Policy_Type type)

CORBA::Object_ptr	_set_policy_overrides (const CORBA::PolicyList &policies, CORBA::SetOverrideType set_add)

CORBA::PolicyList *	_get_policy_overrides (const CORBA::PolicyTypeSeq &types)

CORBA::Boolean	_validate_connection (CORBA::PolicyList_out inconsistent_policies)

virtual CORBA::ULong	_hash (CORBA::ULong maximum)

virtual CORBA::Boolean	_is_equivalent (CORBA::Object_ptr other_obj)

virtual CORBA::ORB_ptr	_get_orb (void)

virtual TAO::ObjectKey *	_key (void)

Public Member Functions inherited from CORBA::Object
virtual	~Object (void)

virtual TAO_Abstract_ServantBase *	_servant (void) const

virtual CORBA::Boolean	_is_collocated (void) const

virtual CORBA::Boolean	_is_local (void) const

	Object (TAO_Stub p, CORBA::Boolean collocated=false, TAO_Abstract_ServantBase servant=0, TAO_ORB_Core *orb_core=0)

	Object (IOP::IOR ior, TAO_ORB_Core orb_core)

virtual TAO_Stub *	_stubobj (void) const

virtual TAO_Stub *	_stubobj (void)

virtual void	_proxy_broker (TAO::Object_Proxy_Broker *proxy_broker)

virtual CORBA::Boolean	marshal (TAO_OutputCDR &cdr)

CORBA::Boolean	is_evaluated (void) const

TAO_ORB_Core *	orb_core (void) const

IOP::IOR *	steal_ior (void)

const IOP::IOR &	ior (void) const

virtual bool	can_convert_to_ior (void) const

virtual char *	convert_to_ior (bool use_omg_ior_format, const char *ior_prefix) const

void	_decr_refcount (void)

virtual CORBA::Boolean	_is_a (const char *logical_type_id)

virtual const char *	_interface_repository_id (void) const

CORBA::Policy_ptr	_get_policy (CORBA::PolicyType type)

CORBA::Policy_ptr	_get_cached_policy (TAO_Cached_Policy_Type type)

CORBA::Object_ptr	_set_policy_overrides (const CORBA::PolicyList &policies, CORBA::SetOverrideType set_add)

CORBA::PolicyList *	_get_policy_overrides (const CORBA::PolicyTypeSeq &types)

CORBA::Boolean	_validate_connection (CORBA::PolicyList_out inconsistent_policies)

Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()

long	ref_count () const

WeakObject *	_get_weak_object () const

Public Member Functions inherited from OpenDDS::DCPS::MultiTopicDataReaderBase
	MultiTopicDataReaderBase ()

void	init (const DDS::DataReaderQos &dr_qos, DDS::DataReaderListener_ptr a_listener, DDS::StatusMask mask, SubscriberImpl parent, MultiTopicImpl multitopic)

void	data_available (DDS::DataReader_ptr reader)

void	set_status_changed_flag (DDS::StatusKind status, bool flag)

bool	have_sample_states (DDS::SampleStateMask sample_states) const

void	cleanup ()

DDS::InstanceHandle_t	get_instance_handle ()

DDS::ReturnCode_t	enable ()

DDS::StatusCondition_ptr	get_statuscondition ()

DDS::StatusMask	get_status_changes ()

DDS::ReadCondition_ptr	create_readcondition (DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)

DDS::QueryCondition_ptr	create_querycondition (DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states, const char *query_expression, const DDS::StringSeq &query_parameters)

DDS::ReturnCode_t	delete_readcondition (DDS::ReadCondition_ptr a_condition)

DDS::ReturnCode_t	delete_contained_entities ()

DDS::ReturnCode_t	set_qos (const DDS::DataReaderQos &qos)

DDS::ReturnCode_t	get_qos (DDS::DataReaderQos &qos)

DDS::ReturnCode_t	set_listener (DDS::DataReaderListener_ptr a_listener, DDS::StatusMask mask)

DDS::DataReaderListener_ptr	get_listener ()

DDS::TopicDescription_ptr	get_topicdescription ()

DDS::Subscriber_ptr	get_subscriber ()

DDS::ReturnCode_t	get_sample_rejected_status (DDS::SampleRejectedStatus &status)

DDS::ReturnCode_t	get_liveliness_changed_status (DDS::LivelinessChangedStatus &status)

DDS::ReturnCode_t	get_requested_deadline_missed_status (DDS::RequestedDeadlineMissedStatus &status)

DDS::ReturnCode_t	get_requested_incompatible_qos_status (DDS::RequestedIncompatibleQosStatus &status)

DDS::ReturnCode_t	get_subscription_matched_status (DDS::SubscriptionMatchedStatus &status)

DDS::ReturnCode_t	get_sample_lost_status (DDS::SampleLostStatus &status)

DDS::ReturnCode_t	wait_for_historical_data (const DDS::Duration_t &max_wait)

DDS::ReturnCode_t	get_matched_publications (DDS::InstanceHandleSeq &publication_handles)

DDS::ReturnCode_t	get_matched_publication_data (DDS::PublicationBuiltinTopicData &publication_data, DDS::InstanceHandle_t publication_handle)

void	get_latency_stats (LatencyStatisticsSeq &stats)

void	reset_latency_stats ()
	Clear any intermediate statistical values. More...

CORBA::Boolean	statistics_enabled ()

void	statistics_enabled (CORBA::Boolean statistics_enabled)

Public Member Functions inherited from OpenDDS::DCPS::DataReaderEx
void	get_latency_stats (inout LatencyStatisticsSeq stats)
	Obtain a sequence of statistics summaries. More...

Public Member Functions inherited from DDS::DataReader
ReadCondition	create_readcondition (in SampleStateMask sample_states, in ViewStateMask view_states, in InstanceStateMask instance_states)

QueryCondition	create_querycondition (in SampleStateMask sample_states, in ViewStateMask view_states, in InstanceStateMask instance_states, in string query_expression, in StringSeq query_parameters)

ReturnCode_t	delete_readcondition (in ReadCondition a_condition)

ReturnCode_t	set_qos (in DataReaderQos qos)

ReturnCode_t	get_qos (inout DataReaderQos qos)

ReturnCode_t	set_listener (in DataReaderListener a_listener, in StatusMask mask)

ReturnCode_t	get_sample_rejected_status (inout SampleRejectedStatus status)

ReturnCode_t	get_liveliness_changed_status (inout LivelinessChangedStatus status)

ReturnCode_t	get_requested_deadline_missed_status (inout RequestedDeadlineMissedStatus status)

ReturnCode_t	get_requested_incompatible_qos_status (inout RequestedIncompatibleQosStatus status)

ReturnCode_t	get_subscription_matched_status (inout SubscriptionMatchedStatus status)

ReturnCode_t	get_sample_lost_status (inout SampleLostStatus status)

ReturnCode_t	wait_for_historical_data (in Duration_t max_wait)

ReturnCode_t	get_matched_publications (inout InstanceHandleSeq publication_handles)

ReturnCode_t	get_matched_publication_data (inout PublicationBuiltinTopicData publication_data, in InstanceHandle_t publication_handle)

Private Types
typedef std::vector< SampleWithInfo >	SampleVec

typedef std::set< OPENDDS_STRING >	TopicSet

Private Member Functions
void	assign_fields (Sample &resulting, void *incoming, const QueryPlan &qp, const MetaStruct &meta)

DDS::ReturnCode_t	process_joins (OPENDDS_MAP(TopicSet, SampleVec)&partial_results, SampleVec starting, const TopicSet &seen, const QueryPlan &qp)

bool	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)

DDS::ReturnCode_t	cross_join (OPENDDS_MAP(TopicSet, SampleVec)&partial_results, const TopicSet &seen, const QueryPlan &qp)

void	combine (SampleVec &resulting, const SampleVec &other, const std::vector< OPENDDS_STRING > &key_names, const TopicSet &other_topics)

void	assign_resulting_fields (Sample &target, const Sample &source, const TopicSet &other_topics)

Private Attributes
TypedDataReader::Interface::_var_type	typed_reader_

Additional Inherited Members
Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< TypedDataReader::Interface >
static _ptr_type	_narrow (CORBA::Object_ptr obj)

Static Public Member Functions inherited from CORBA::LocalObject
static LocalObject_ptr	_duplicate (LocalObject_ptr obj)

static LocalObject_ptr	_nil (void)

static LocalObject_ptr	_narrow (CORBA::Object_ptr obj)

Static Public Member Functions inherited from CORBA::Object
static CORBA::Boolean	marshal (const Object_ptr x, TAO_OutputCDR &cdr)

static void	_tao_any_destructor (void *)

static CORBA::Boolean	is_nil_i (CORBA::Object_ptr obj)

static void	tao_object_initialize (Object *)

static CORBA::Object_ptr	_duplicate (CORBA::Object_ptr obj)

static CORBA::Object_ptr	_nil (void)

static CORBA::Object_ptr	_narrow (CORBA::Object_ptr obj)

Static Public Member Functions inherited from OpenDDS::DCPS::LocalObject< DataReaderEx >
static _ptr_type	_narrow (CORBA::Object_ptr obj)

Public Attributes inherited from OpenDDS::DCPS::DataReaderEx
attribute boolean	statistics_enabled
	Statistics gathering enable state. More...

Protected Types inherited from OpenDDS::DCPS::MultiTopicDataReaderBase
typedef MultiTopicImpl::SubjectFieldSpec	SubjectFieldSpec

Protected Member Functions inherited from CORBA::LocalObject
	LocalObject (void)

Protected Member Functions inherited from CORBA::Object
	Object (int dummy=0)

TAO::Object_Proxy_Broker *	proxy_broker () const

Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Protected Member Functions inherited from OpenDDS::DCPS::MultiTopicDataReaderBase
OPENDDS_STRING	topicNameFor (DDS::DataReader_ptr dr)

const MetaStruct &	metaStructFor (DDS::DataReader_ptr dr)

	OPENDDS_MAP (OPENDDS_STRING, QueryPlan) query_plans_

Protected Attributes inherited from CORBA::Object
ACE_Atomic_Op< TAO_SYNCH_MUTEX, unsigned long >	refcount_

Protected Attributes inherited from OpenDDS::DCPS::MultiTopicDataReaderBase
ACE_RW_Thread_Mutex	qp_lock_

Detailed Description

template<typename Sample, typename TypedDataReader>
class OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >

Definition at line 25 of file MultiTopicDataReader_T.h.

Member Typedef Documentation

◆ SampleSeq

template<typename Sample , typename TypedDataReader >

typedef TAO::DCPS::ZeroCopyDataSeq<Sample> OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::SampleSeq

Definition at line 29 of file MultiTopicDataReader_T.h.

◆ SampleVec

template<typename Sample , typename TypedDataReader >

typedef std::vector<SampleWithInfo> OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::SampleVec

private

Definition at line 125 of file MultiTopicDataReader_T.h.

◆ TopicSet

template<typename Sample , typename TypedDataReader >

typedef std::set<OPENDDS_STRING> OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::TopicSet

private

Definition at line 126 of file MultiTopicDataReader_T.h.

Constructor & Destructor Documentation

◆ MultiTopicDataReader_T()

template<typename Sample , typename TypedDataReader >

OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T ( )

inline

Definition at line 31 of file MultiTopicDataReader_T.h.

31 {}

Member Function Documentation

◆ assign_fields()

template<typename Sample , typename TypedDataReader >

void OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::assign_fields	(	Sample &	resulting,
		void *	incoming,
		const QueryPlan &	qp,
		const MetaStruct &	meta
	)

private

Definition at line 38 of file MultiTopicDataReader_T.cpp.

References OpenDDS::DCPS::MetaStruct::assign(), OpenDDS::DCPS::MultiTopicDataReaderBase::QueryPlan::keys_projected_out_, and OpenDDS::DCPS::MultiTopicDataReaderBase::QueryPlan::projection_.

 {
   using namespace std;
   const vector<SubjectFieldSpec>& proj = qp.projection_;
   const MetaStruct& resulting_meta = getResultingMeta();
 
   typedef vector<SubjectFieldSpec>::const_iterator iter_t;
   for (iter_t iter = proj.begin(); iter != proj.end(); ++iter) {
     resulting_meta.assign(&resulting, iter->resulting_name_.c_str(),
                           incoming, iter->incoming_name_.c_str(), meta);
   }
 
   const vector<OPENDDS_STRING>& proj_out = qp.keys_projected_out_;
   for (vector<OPENDDS_STRING>::const_iterator iter = proj_out.begin();
        iter != proj_out.end(); ++iter) {
     resulting_meta.assign(&resulting, iter->c_str(),
                           incoming, iter->c_str(), meta);
   }
 }

◆ assign_resulting_fields()

template<typename Sample , typename TypedDataReader >

void OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::assign_resulting_fields	(	Sample &	target,
		const Sample &	source,
		const TopicSet &	other_topics
	)

private

Definition at line 61 of file MultiTopicDataReader_T.cpp.

References OpenDDS::DCPS::MetaStruct::assign().

 {
   using namespace std;
   const MetaStruct& resulting_meta = getResultingMeta();
 
   for (TopicSet::const_iterator iterTopic = other_topics.begin();
        iterTopic != other_topics.end(); ++iterTopic) {
     const vector<SubjectFieldSpec>& proj = query_plans_[*iterTopic].projection_;
     typedef vector<SubjectFieldSpec>::const_iterator iter_t;
     for (iter_t iter = proj.begin(); iter != proj.end(); ++iter) {
       resulting_meta.assign(&target, iter->resulting_name_.c_str(),
                             &source, iter->resulting_name_.c_str(), resulting_meta);
     }
   }
 }

◆ combine()

template<typename Sample , typename TypedDataReader >

void OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::combine	(	SampleVec &	resulting,
		const SampleVec &	other,
		const std::vector< OPENDDS_STRING > &	key_names,
		const TopicSet &	other_topics
	)

private

Definition at line 159 of file MultiTopicDataReader_T.cpp.

References OpenDDS::DCPS::MetaStruct::compare().

 {
   const MetaStruct& meta = getResultingMeta();
   SampleVec new_data;
   for (typename SampleVec::iterator it_res = resulting.begin();
        it_res != resulting.end(); /*incremented in loop*/) {
     bool found_one_match = false;
     for (typename SampleVec::const_iterator it_other = other.begin();
          it_other != other.end(); ++it_other) {
       bool match = true;
       for (size_t i = 0; match && i < key_names.size(); ++i) {
         if (!meta.compare(&*it_res, &*it_other, key_names[i].c_str())) {
           match = false;
         }
       }
       if (!match) {
         continue;
       }
       if (found_one_match) {
         new_data.push_back(*it_res);
         new_data.back().combine(*it_other);
         assign_resulting_fields(new_data.back().sample_, it_other->sample_, other_topics);
       } else {
         found_one_match = true;
         it_res->combine(*it_other);
         assign_resulting_fields(it_res->sample_, it_other->sample_, other_topics);
       }
     }
     if (found_one_match) {
       ++it_res;
     } else {
       // no match found in 'other' so data must not appear in result set
       it_res = resulting.erase(it_res);
     }
   }
   resulting.insert(resulting.end(), new_data.begin(), new_data.end());
 }

◆ cross_join()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::cross_join	(	OPENDDS_MAP(TopicSet, SampleVec)&	partial_results,
		const TopicSet &	seen,
		const QueryPlan &	qp
	)

private

Definition at line 304 of file MultiTopicDataReader_T.cpp.

References OpenDDS::DCPS::MultiTopicDataReaderBase::QueryPlan::data_reader_, DDS::RETCODE_ERROR, and DDS::RETCODE_OK.

 {
   using namespace std;
   const MetaStruct& other_meta = metaStructFor(qp.data_reader_);
   vector<OPENDDS_STRING> no_keys;
   for (typename std::map<TopicSet, SampleVec>::iterator it_pr = partial_results.begin();
        it_pr != partial_results.end(); ++it_pr) {
     SampleVec resulting;
     for (typename SampleVec::iterator i = it_pr->second.begin(); i != it_pr->second.end(); ++i) {
       if (!join(resulting, *i, no_keys, 0, qp.data_reader_, other_meta)) {
         return DDS::RETCODE_ERROR;
       }
     }
     resulting.swap(it_pr->second);
   }
 
   TopicSet with_join(seen);
   with_join.insert(topicNameFor(qp.data_reader_));
   partial_results[with_join].swap(partial_results[seen]);
   partial_results.erase(seen);
   const DDS::ReturnCode_t ret = process_joins(partial_results, partial_results[with_join],
                                               with_join, qp);
   if (ret != DDS::RETCODE_OK) {
     partial_results.erase(with_join);
     return ret;
   }
 
   return DDS::RETCODE_OK;
 }

◆ get_key_value()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::get_key_value	(	Sample &	key_holder,
		DDS::InstanceHandle_t	handle
	)

Definition at line 554 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->get_key_value(key_holder, handle);
 }

◆ getResultingMeta()

template<typename Sample , typename TypedDataReader >

const MetaStruct & OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::getResultingMeta ( )

virtual

Implements OpenDDS::DCPS::MultiTopicDataReaderBase.

Definition at line 31 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return getMetaStruct<Sample>();
 }

◆ incoming_sample()

template<typename Sample , typename TypedDataReader >

void OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::incoming_sample	(	void *	sample,
		const DDS::SampleInfo &	info,
		const char *	topic,
		const MetaStruct &	meta
	)

virtual

Implements OpenDDS::DCPS::MultiTopicDataReaderBase.

Definition at line 338 of file MultiTopicDataReader_T.cpp.

References ACE_ERROR, ACE_TEXT(), DDS::HANDLE_NIL, LM_ERROR, and DDS::RETCODE_OK.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   using namespace std;
   using namespace DDS;
   const QueryPlan& qp = query_plans_[topic];
 
   // Track results of joins along multiple paths through the MultiTopic keys.
   std::map<TopicSet, SampleVec> partial_results;
   TopicSet seen;
   seen.insert(topic);
   partial_results[seen].push_back(SampleWithInfo(topic, info));
   assign_fields(partial_results[seen].back().sample_, sample, qp, meta);
 
   DDS::ReturnCode_t ret = process_joins(partial_results, partial_results[seen], seen, qp);
   if (ret != DDS::RETCODE_OK) {
     return;
   }
 
   // Any topic we haven't seen needs to be cross-joined
   for (std::map<OPENDDS_STRING, QueryPlan>::iterator iter = query_plans_.begin();
        iter != query_plans_.end(); ++iter) {
     typename std::map<TopicSet, SampleVec>::iterator found =
       find_if(partial_results.begin(), partial_results.end(), Contains(iter->first));
     if (found == partial_results.end()) {
       ret = cross_join(partial_results, seen, iter->second);
       if (ret != DDS::RETCODE_OK) {
         return;
       }
     }
   }
 
   TypedDataReader* tdr = dynamic_cast<TypedDataReader*>(typed_reader_.in());
   if (!tdr) {
     ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: MultiTopicDataReader_T::incoming_sample:")
                ACE_TEXT(" Failed to get TypedDataReader.\n")));
     return;
   }
 
   for (typename std::map<TopicSet, SampleVec>::iterator it_pr = partial_results.begin();
        it_pr != partial_results.end(); ++it_pr) {
     for (typename SampleVec::iterator i = it_pr->second.begin(); i != it_pr->second.end(); ++i) {
       InstanceHandle_t ih = tdr->store_synthetic_data(i->sample_, i->view_);
       if (ih != HANDLE_NIL) {
         typedef std::map<OPENDDS_STRING, InstanceHandle_t>::iterator mapiter_t;
         for (mapiter_t it_map = i->info_.begin(); it_map != i->info_.end(); ++it_map) {
           query_plans_[it_map->first].instances_.insert(make_pair(it_map->second, ih));
         }
       }
     }
   }
 }

◆ init_typed()

template<typename Sample , typename TypedDataReader >

void OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::init_typed ( DataReaderEx * dr )

virtual

Implements OpenDDS::DCPS::MultiTopicDataReaderBase.

Definition at line 24 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   typed_reader_ = TypedDataReader::Interface::_narrow(dr);
 }

◆ join()

template<typename Sample , typename TypedDataReader >

bool OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::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
	)

private

Definition at line 80 of file MultiTopicDataReader_T.cpp.

References ACE_ERROR, ACE_TEXT(), DDS::ALIVE_INSTANCE_STATE, DDS::ANY_VIEW_STATE, OpenDDS::DCPS::MetaStruct::compare(), OpenDDS::DCPS::DataReaderImpl::get_topicdescription(), DDS::HANDLE_NIL, TAO::String_var< charT >::in(), DDS::SampleInfo::instance_handle, LM_ERROR, LM_NOTICE, OpenDDS::DCPS::log_level, OpenDDS::DCPS::DataReaderImpl::lookup_instance_generic(), OpenDDS::DCPS::LogLevel::Notice, OpenDDS::DCPS::MetaStruct::numDcpsKeys(), OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::GenericData::ptr_, OpenDDS::DCPS::DataReaderImpl::read_instance_generic(), OpenDDS::DCPS::DataReaderImpl::read_next_instance_generic(), DDS::READ_SAMPLE_STATE, DDS::RETCODE_NO_DATA, DDS::RETCODE_OK, OpenDDS::DCPS::retcode_to_string(), and DDS::SampleInfo::valid_data.

 {
   using namespace DDS;
   DataReaderImpl* other_dri = dynamic_cast<DataReaderImpl*>(other_dr);
   if (!other_dri) {
     ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: MultiTopicDataReader_T::join: ")
       ACE_TEXT("Failed to get DataReaderImpl.\n")));
     return false;
   }
 
   TopicDescription_var other_td = other_dri->get_topicdescription();
   CORBA::String_var other_topic = other_td->get_name();
   const QueryPlan& other_qp = query_plans_[other_topic.in()];
   const size_t n_keys = key_names.size();
 
   if (n_keys > 0 && other_meta.numDcpsKeys() == n_keys) { // complete key
     InstanceHandle_t ih = other_dri->lookup_instance_generic(key_data);
     if (ih != HANDLE_NIL) {
       GenericData other_data(other_meta, false);
       SampleInfo info;
       const ReturnCode_t ret = other_dri->read_instance_generic(other_data.ptr_,
         info, ih, READ_SAMPLE_STATE, ANY_VIEW_STATE, ALIVE_INSTANCE_STATE);
       if (ret != DDS::RETCODE_OK && ret != DDS::RETCODE_NO_DATA) {
         if (log_level >= LogLevel::Notice) {
           ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: MultiTopicDataReader_T::join: read_instance_generic"
                      " for topic %C returns %C\n", other_topic.in(), retcode_to_string(ret)));
         }
         return false;
       }
       if (ret == DDS::RETCODE_NO_DATA || !info.valid_data) {
         return false;
       }
 
       resulting.push_back(prototype);
       resulting.back().combine(SampleWithInfo(other_topic.in(), info));
       assign_fields(resulting.back().sample_, other_data.ptr_, other_qp, other_meta);
     }
   } else { // incomplete key or cross-join (0 key fields)
     ReturnCode_t ret = RETCODE_OK;
     for (InstanceHandle_t ih = HANDLE_NIL; ret != RETCODE_NO_DATA;) {
       GenericData other_data(other_meta, false);
       SampleInfo info;
       const ReturnCode_t ret = other_dri->read_next_instance_generic(other_data.ptr_,
         info, ih, READ_SAMPLE_STATE, ANY_VIEW_STATE, ALIVE_INSTANCE_STATE);
       if (ret != RETCODE_OK && ret != RETCODE_NO_DATA) {
         if (log_level >= LogLevel::Notice) {
           ACE_ERROR((LM_NOTICE, "(%P|%t) NOTICE: MultiTopicDataReader_T::join:"
                      " read_next_instance_generic for topic %C returns %C\n",
                      other_topic.in(), retcode_to_string(ret)));
         }
         return false;
       }
       if (ret == RETCODE_NO_DATA || !info.valid_data) {
         break;
       }
       ih = info.instance_handle;
 
       bool match = true;
       for (size_t i = 0; match && i < key_names.size(); ++i) {
         if (!other_meta.compare(key_data, other_data.ptr_, key_names[i].c_str())) {
           match = false;
         }
       }
 
       if (match) {
         resulting.push_back(prototype);
         resulting.back().combine(SampleWithInfo(other_topic.in(), info));
         assign_fields(resulting.back().sample_, other_data.ptr_, other_qp, other_meta);
       }
     }
   }
   return true;
 }

◆ lookup_instance()

template<typename Sample , typename TypedDataReader >

DDS::InstanceHandle_t OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::lookup_instance ( const Sample & instance_data )

Definition at line 562 of file MultiTopicDataReader_T.cpp.

References OPENDDS_END_VERSIONED_NAMESPACE_DECL.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->lookup_instance(instance_data);
 }

◆ process_joins()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::process_joins	(	OPENDDS_MAP(TopicSet, SampleVec)&	partial_results,
		SampleVec	starting,
		const TopicSet &	seen,
		const QueryPlan &	qp
	)

private

Two constituent topics are joinable directly if they have some common join keys, or indirectly via a third topic which has common join keys with each of them. The constituent topics form one or more groups of connected topics. In each groups, topics are connected. But any two groups are not connected (otherwise, they would have been a single group). And so groups are cross-joined with each other. Within a group, topics are joined using process_joins(). Starting from an incoming sample of a given topic, it computes partial resulting samples from the samples of the constituent topics in the same group that are already received, in a DFS manner. contains entries for sets of topics, each corresponding to a path of topics which have been visited, starting from the incoming topic. For example, if the graph of visited topics looks like this A (incoming topic) / \ B C / / | \ D E F G / . . . H . . . . . . . then partial_results contains entries for topic sets: {A,B,D,H}, {A,C,E}, {A,C,F}, {A,C,G}. When traverse a path, if the next adjacent topic appears on a different path, i.e., there is an entry corresponding to that path in partial_results that has it in its topic set, then the two entries are combined into a new entry which contains topics from both of them. For example, if we are traversing path (A,C,G) and the next adjacent topic to G is B, which appears in path (A,B,D,H), then entries keyed by (A,C,G) and (A,B,D,H) are combined into a single entry with key (A,B,C,D,G,H). Entries (A,C,G) and (A,B,D,H) are removed from partial_results.

Definition at line 231 of file MultiTopicDataReader_T.cpp.

References ACE_GUARD_RETURN, OpenDDS::DCPS::MultiTopicDataReaderBase::QueryPlan::adjacent_joins_, OpenDDS::DCPS::MetaStruct::assign(), OpenDDS::DCPS::MultiTopicDataReaderBase::QueryPlan::data_reader_, OPENDDS_STRING, OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::GenericData::ptr_, DDS::RETCODE_ERROR, DDS::RETCODE_OK, and DDS::RETCODE_OUT_OF_RESOURCES.

 {
   using namespace std;
   const MetaStruct& resulting_meta = getResultingMeta();
   OPENDDS_STRING this_topic;
   {
     ACE_GUARD_RETURN(ACE_RW_Thread_Mutex, read_guard, qp_lock_, DDS::RETCODE_OUT_OF_RESOURCES);
     this_topic = topicNameFor(qp.data_reader_);
   }
   typedef multimap<OPENDDS_STRING, OPENDDS_STRING>::const_iterator iter_t;
   for (iter_t iter = qp.adjacent_joins_.begin(); iter != qp.adjacent_joins_.end();) {
     // for each topic we're joining
     const OPENDDS_STRING& other_topic = iter->first;
     iter_t range_end = qp.adjacent_joins_.upper_bound(other_topic);
     const QueryPlan& other_qp = query_plans_[other_topic];
     DDS::DataReader_ptr other_dr = other_qp.data_reader_;
     const MetaStruct& other_meta = metaStructFor(other_dr);
 
     vector<OPENDDS_STRING> keys;
     for (; iter != range_end; ++iter) { // for each key in common w/ this topic
       keys.push_back(iter->second);
     }
 
     typename std::map<TopicSet, SampleVec>::iterator found =
       find_if(partial_results.begin(), partial_results.end(), Contains(other_topic));
 
     if (found == partial_results.end()) { // haven't seen this topic yet
       partial_results.erase(seen);
       TopicSet with_join(seen);
       with_join.insert(other_topic);
       SampleVec& join_result = partial_results[with_join];
       for (size_t i = 0; i < starting.size(); ++i) {
         GenericData other_keys(other_meta);
         for (size_t j = 0; j < keys.size(); ++j) {
           other_meta.assign(other_keys.ptr_, keys[j].c_str(),
                             &starting[i], keys[j].c_str(), resulting_meta);
         }
         if (!join(join_result, starting[i], keys, other_keys.ptr_, other_dr, other_meta)) {
           return DDS::RETCODE_ERROR;
         }
       }
 
       if (!join_result.empty() && !seen.count(other_topic)) {
         // Recursively join with topics that are adjacent to other_topic.
         const DDS::ReturnCode_t ret = process_joins(partial_results, join_result,
                                                     with_join, other_qp);
         if (ret != DDS::RETCODE_OK) {
           return ret;
         }
       }
     } else if (!found->first.count(this_topic) /*avoid looping back*/) {
       // We have partialResults for this topic, use them instead of recursing.
       // Combine the partial samples for the TopicSet seen and found->first.
       // Store the result into a new entry keyed with all topics in seen and found->first.
       // The existing two entries are removed since they are not needed anymore.
       combine(starting, found->second, keys, found->first);
       TopicSet new_topics(seen);
       for (set<OPENDDS_STRING>::const_iterator it = found->first.begin(); it != found->first.end(); ++it) {
         new_topics.insert(*it);
       }
 
       partial_results.erase(found);
       partial_results.erase(seen);
       partial_results[new_topics] = starting;
     }
   }
   return DDS::RETCODE_OK;
 }

◆ read()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::read	(	SampleSeq &	received_data,
		DDS::SampleInfoSeq &	info_seq,
		CORBA::Long	max_samples,
		DDS::SampleStateMask	sample_states,
		DDS::ViewStateMask	view_states,
		DDS::InstanceStateMask	instance_states
	)

Definition at line 396 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->read(received_data, info_seq, max_samples,
     sample_states, view_states, instance_states);
 }

◆ read_instance()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t 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
	)

Definition at line 454 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->read_instance(received_data, info_seq, max_samples,
     a_handle, sample_states, view_states, instance_states);
 }

◆ read_instance_w_condition()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t 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
	)

Definition at line 478 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->read_instance_w_condition(data_values,
     sample_infos, max_samples, handle, a_condition);
 }

◆ read_next_instance()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t 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
	)

Definition at line 500 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->read_next_instance(received_data, info_seq, max_samples,
     a_handle, sample_states, view_states, instance_states);
 }

◆ read_next_instance_w_condition()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t 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
	)

Definition at line 524 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->read_next_instance_w_condition(data_values,
     sample_infos, max_samples, previous_handle, a_condition);
 }

◆ read_next_sample()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::read_next_sample	(	Sample &	received_data,
		DDS::SampleInfo &	sample_info
	)

Definition at line 438 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->read_next_sample(received_data, sample_info);
 }

◆ read_w_condition()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t 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
	)

Definition at line 418 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->read_w_condition(data_values, sample_infos,
     max_samples, a_condition);
 }

◆ return_loan()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::return_loan	(	SampleSeq &	received_data,
		DDS::SampleInfoSeq &	info_seq
	)

Definition at line 546 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->return_loan(received_data, info_seq);
 }

◆ take()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::take	(	SampleSeq &	received_data,
		DDS::SampleInfoSeq &	info_seq,
		CORBA::Long	max_samples,
		DDS::SampleStateMask	sample_states,
		DDS::ViewStateMask	view_states,
		DDS::InstanceStateMask	instance_states
	)

Definition at line 407 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->take(received_data, info_seq, max_samples,
     sample_states, view_states, instance_states);
 }

◆ take_instance()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t 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
	)

Definition at line 466 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->take_instance(received_data, info_seq, max_samples,
     a_handle, sample_states, view_states, instance_states);
 }

◆ take_instance_w_condition()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t 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
	)

Definition at line 489 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->take_instance_w_condition(data_values,
     sample_infos, max_samples, handle, a_condition);
 }

◆ take_next_instance()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t 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
	)

Definition at line 512 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->take_next_instance(received_data, info_seq, max_samples,
     a_handle, sample_states, view_states, instance_states);
 }

◆ take_next_instance_w_condition()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t 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
	)

Definition at line 535 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->take_next_instance_w_condition(data_values,
     sample_infos, max_samples, previous_handle, a_condition);
 }

◆ take_next_sample()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::take_next_sample	(	Sample &	received_data,
		DDS::SampleInfo &	sample_info
	)

Definition at line 446 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->take_next_sample(received_data, sample_info);
 }

◆ take_w_condition()

template<typename Sample , typename TypedDataReader >

DDS::ReturnCode_t 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
	)

Definition at line 428 of file MultiTopicDataReader_T.cpp.

Referenced by OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::MultiTopicDataReader_T().

 {
   return typed_reader_->take_w_condition(data_values, sample_infos,
     max_samples, a_condition);
 }

Member Data Documentation

◆ typed_reader_

template<typename Sample , typename TypedDataReader >

TypedDataReader::Interface::_var_type OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >::typed_reader_

private

Definition at line 188 of file MultiTopicDataReader_T.h.

The documentation for this class was generated from the following files:

Classes

Public Types

Public Member Functions

Private Types

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

template<typename Sample, typename TypedDataReader> class OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >

Member Typedef Documentation

◆ SampleSeq

◆ SampleVec

◆ TopicSet

Constructor & Destructor Documentation

◆ MultiTopicDataReader_T()

Member Function Documentation

◆ assign_fields()

◆ assign_resulting_fields()

◆ combine()

◆ cross_join()

◆ get_key_value()

◆ getResultingMeta()

◆ incoming_sample()

◆ init_typed()

◆ join()

◆ lookup_instance()

◆ process_joins()

◆ read()

◆ read_instance()

◆ read_instance_w_condition()

◆ read_next_instance()

◆ read_next_instance_w_condition()

◆ read_next_sample()

◆ read_w_condition()

◆ return_loan()

◆ take()

◆ take_instance()

◆ take_instance_w_condition()

◆ take_next_instance()

◆ take_next_instance_w_condition()

◆ take_next_sample()

◆ take_w_condition()

Member Data Documentation

◆ typed_reader_

template<typename Sample, typename TypedDataReader>
class OpenDDS::DCPS::MultiTopicDataReader_T< Sample, TypedDataReader >