#include <ReceivedDataStrategy.h>
Inheritance diagram for OpenDDS::DCPS::ReceivedDataStrategy:
Public Member Functions | |
ReceivedDataStrategy (ReceivedDataElementList &rcvd_samples) | |
virtual | ~ReceivedDataStrategy () |
virtual void | add (ReceivedDataElement *data_sample) |
virtual void | accept_coherent (PublicationId &writer, RepoId &publisher) |
virtual void | reject_coherent (PublicationId &writer, RepoId &publisher) |
Protected Attributes | |
ReceivedDataElementList & | rcvd_samples_ |
Definition at line 20 of file ReceivedDataStrategy.h.
OpenDDS::DCPS::ReceivedDataStrategy::ReceivedDataStrategy | ( | ReceivedDataElementList & | rcvd_samples | ) | [explicit] |
OpenDDS::DCPS::ReceivedDataStrategy::~ReceivedDataStrategy | ( | ) | [virtual] |
void OpenDDS::DCPS::ReceivedDataStrategy::accept_coherent | ( | PublicationId & | writer, | |
RepoId & | publisher | |||
) | [virtual] |
Definition at line 101 of file ReceivedDataStrategy.cpp.
References OpenDDS::DCPS::ReceivedDataElementList::apply_all(), and rcvd_samples_.
00103 { 00104 CoherentFilter filter = CoherentFilter(writer, publisher); 00105 AcceptCoherent operation = AcceptCoherent(writer, publisher); 00106 this->rcvd_samples_.apply_all(filter, operation); 00107 }
void OpenDDS::DCPS::ReceivedDataStrategy::add | ( | ReceivedDataElement * | data_sample | ) | [virtual] |
Reimplemented in OpenDDS::DCPS::SourceDataStrategy.
Definition at line 94 of file ReceivedDataStrategy.cpp.
References OpenDDS::DCPS::ReceivedDataElementList::add(), and rcvd_samples_.
Referenced by OpenDDS::DCPS::DataReaderImpl_T< MessageType >::store_instance_data().
00095 { 00096 this->rcvd_samples_.add(data_sample); 00097 }
void OpenDDS::DCPS::ReceivedDataStrategy::reject_coherent | ( | PublicationId & | writer, | |
RepoId & | publisher | |||
) | [virtual] |
Definition at line 110 of file ReceivedDataStrategy.cpp.
References rcvd_samples_, and OpenDDS::DCPS::ReceivedDataElementList::remove().
00112 { 00113 CoherentFilter filter = CoherentFilter(writer, publisher); 00114 this->rcvd_samples_.remove(filter, true); 00115 }
Definition at line 36 of file ReceivedDataStrategy.h.
Referenced by accept_coherent(), OpenDDS::DCPS::SourceDataStrategy::add(), add(), and reject_coherent().