#include <RakeResults_T.h>
Collaboration diagram for OpenDDS::DCPS::RakeResults< SampleSeq >:

Public Member Functions | |
| RakeResults (DataReaderImpl *reader, SampleSeq &received_data, DDS::SampleInfoSeq &info_seq, CORBA::Long max_samples, DDS::PresentationQosPolicy presentation, DDS::QueryCondition_ptr cond, Operation_t oper) | |
| bool | insert_sample (ReceivedDataElement *sample, SubscriptionInstance *i, size_t index_in_instance) |
| bool | copy_to_user () |
Private Types | |
| typedef std::multiset< RakeData, SortedSetCmp > | SortedSet |
| typedef std::vector< CORBA::ULong > | IndexList |
Private Member Functions | |
| template<class FwdIter> | |
| bool | copy_into (FwdIter begin, FwdIter end, typename SampleSeq::PrivateMemberAccess &received_data_p) |
| RakeResults (const RakeResults &) | |
| RakeResults & | operator= (const RakeResults &) |
Private Attributes | |
| DataReaderImpl * | reader_ |
| SampleSeq & | received_data_ |
| DDS::SampleInfoSeq & | info_seq_ |
| CORBA::ULong | max_samples_ |
| DDS::QueryCondition_ptr | cond_ |
| Operation_t | oper_ |
| bool | do_sort_ |
| bool | do_filter_ |
| SortedSet | sorted_ |
| std::vector< RakeData > | unsorted_ |
Classes | |
| struct | InstanceData |
| class | SortedSetCmp |
typedef std::vector<CORBA::ULong> OpenDDS::DCPS::RakeResults< SampleSeq >::IndexList [private] |
typedef std::multiset<RakeData, SortedSetCmp> OpenDDS::DCPS::RakeResults< SampleSeq >::SortedSet [private] |
| OpenDDS::DCPS::RakeResults< SampleSeq >::RakeResults | ( | DataReaderImpl * | reader, | |
| SampleSeq & | received_data, | |||
| DDS::SampleInfoSeq & | info_seq, | |||
| CORBA::Long | max_samples, | |||
| DDS::PresentationQosPolicy | presentation, | |||
| DDS::QueryCondition_ptr | cond, | |||
| Operation_t | oper | |||
| ) |
| OpenDDS::DCPS::RakeResults< SampleSeq >::RakeResults | ( | const RakeResults< SampleSeq > & | ) | [private] |
| bool OpenDDS::DCPS::RakeResults< SampleSeq >::copy_into | ( | FwdIter | begin, | |
| FwdIter | end, | |||
| typename SampleSeq::PrivateMemberAccess & | received_data_p | |||
| ) | [private] |
| bool OpenDDS::DCPS::RakeResults< SampleSeq >::copy_to_user | ( | ) |
| bool OpenDDS::DCPS::RakeResults< SampleSeq >::insert_sample | ( | ReceivedDataElement * | sample, | |
| SubscriptionInstance * | 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).
| RakeResults& OpenDDS::DCPS::RakeResults< SampleSeq >::operator= | ( | const RakeResults< SampleSeq > & | ) | [private] |
DDS::QueryCondition_ptr OpenDDS::DCPS::RakeResults< SampleSeq >::cond_ [private] |
bool OpenDDS::DCPS::RakeResults< SampleSeq >::do_filter_ [private] |
bool OpenDDS::DCPS::RakeResults< SampleSeq >::do_sort_ [private] |
DDS::SampleInfoSeq& OpenDDS::DCPS::RakeResults< SampleSeq >::info_seq_ [private] |
CORBA::ULong OpenDDS::DCPS::RakeResults< SampleSeq >::max_samples_ [private] |
Operation_t OpenDDS::DCPS::RakeResults< SampleSeq >::oper_ [private] |
DataReaderImpl* OpenDDS::DCPS::RakeResults< SampleSeq >::reader_ [private] |
SampleSeq& OpenDDS::DCPS::RakeResults< SampleSeq >::received_data_ [private] |
SortedSet OpenDDS::DCPS::RakeResults< SampleSeq >::sorted_ [private] |
std::vector<RakeData> OpenDDS::DCPS::RakeResults< SampleSeq >::unsorted_ [private] |
1.4.7