OpenDDS::DCPS::GroupRakeData Class Reference

#include <GroupRakeData.h>

List of all members.

Classes
class	SortedSetCmp
Public Member Functions
	GroupRakeData ()
bool	insert_sample (ReceivedDataElement *sample, SubscriptionInstance_rch i, size_t index_in_instance)
void	get_datareaders (DDS::DataReaderSeq &readers)
bool	copy_to_user ()
void	reset ()
RakeData	get_data ()
Private Member Functions
	GroupRakeData (const GroupRakeData &)
GroupRakeData &	operator= (const GroupRakeData &)
typedef	OPENDDS_MULTISET_CMP (RakeData, SortedSetCmp) SortedSet
Private Attributes
SortedSet	sorted_
SortedSet::iterator	current_sample_

---

Detailed Description

Rake is an abbreviation for "read or take". This class manages the results from a read() or take() operation, which are the received_data and the info_seq sequences passed in by-reference from the user.

Definition at line 33 of file GroupRakeData.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::GroupRakeData::GroupRakeData

(

)

Definition at line 19 of file GroupRakeData.cpp.

{
}

OpenDDS::DCPS::GroupRakeData::GroupRakeData

(

const GroupRakeData &

)

[private]

---

Member Function Documentation

bool OpenDDS::DCPS::GroupRakeData::copy_to_user

(

)

RakeData OpenDDS::DCPS::GroupRakeData::get_data

(

)

Definition at line 64 of file GroupRakeData.cpp.

References current_sample_.

{
  RakeData data = *this->current_sample_;
  ++this->current_sample_;
  return data;
}

void OpenDDS::DCPS::GroupRakeData::get_datareaders

(

DDS::DataReaderSeq &

readers

)

Definition at line 41 of file GroupRakeData.cpp.

References sorted_.

Referenced by OpenDDS::DCPS::SubscriberImpl::get_datareaders().

{
  ACE_UNUSED_ARG(readers);
#ifndef OPENDDS_NO_OBJECT_MODEL_PROFILE
  readers.length(static_cast<CORBA::ULong>(this->sorted_.size()));
  CORBA::ULong i = 0;
  SortedSet::iterator itEnd = this->sorted_.end();
  for (SortedSet::iterator it = this->sorted_.begin(); it != itEnd; ++it) {
    readers[i++] =
      DDS::DataReader::_duplicate(it->si_->instance_state_.data_reader());
  }
#endif
}

Here is the caller graph for this function:

bool OpenDDS::DCPS::GroupRakeData::insert_sample	(	ReceivedDataElement *	sample,
		SubscriptionInstance_rch	i,
		size_t	index_in_instance
	)

Returns false if the sample will definitely not be part of the resulting dataset, however if this returns true it still may be excluded (due to sorting and max_samples).

Definition at line 24 of file GroupRakeData.cpp.

References current_sample_, OpenDDS::DCPS::ReceivedDataElement::registered_data_, and sorted_.

Referenced by OpenDDS::DCPS::DataReaderImpl::get_ordered_data().

{
  // Ignore DISPOSE and UNREGISTER messages in case they are sent
  // in the group coherent changes, but it shouldn't.
  if (!sample->registered_data_) return false;

  RakeData rd = {sample, instance, index_in_instance};
  this->sorted_.insert(rd);

  this->current_sample_ = this->sorted_.begin();
  return true;
}

Here is the caller graph for this function:

typedef OpenDDS::DCPS::GroupRakeData::OPENDDS_MULTISET_CMP	(	RakeData	,
		SortedSetCmp
	)			[private]

GroupRakeData& OpenDDS::DCPS::GroupRakeData::operator=

(

const GroupRakeData &

)

[private]

void OpenDDS::DCPS::GroupRakeData::reset

(

void

)

Definition at line 57 of file GroupRakeData.cpp.

References sorted_.

Referenced by OpenDDS::DCPS::DataReaderImpl::end_access().

{
  this->sorted_.clear();
}

Here is the caller graph for this function:

---

Member Data Documentation

SortedSet::iterator OpenDDS::DCPS::GroupRakeData::current_sample_ [private]

Definition at line 80 of file GroupRakeData.h.

Referenced by get_data(), and insert_sample().

SortedSet OpenDDS::DCPS::GroupRakeData::sorted_ [private]

Definition at line 78 of file GroupRakeData.h.

Referenced by get_datareaders(), insert_sample(), and reset().

---

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

• GroupRakeData.h
• GroupRakeData.cpp