#include <ReceivedDataStrategy.h>
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 22 of file ReceivedDataStrategy.h.
OpenDDS::DCPS::ReceivedDataStrategy::ReceivedDataStrategy | ( | ReceivedDataElementList & | rcvd_samples | ) | [explicit] |
Definition at line 87 of file ReceivedDataStrategy.cpp.
00089 : rcvd_samples_(rcvd_samples) 00090 {}
OpenDDS::DCPS::ReceivedDataStrategy::~ReceivedDataStrategy | ( | ) | [virtual] |
Definition at line 92 of file ReceivedDataStrategy.cpp.
void OpenDDS::DCPS::ReceivedDataStrategy::accept_coherent | ( | PublicationId & | writer, | |
RepoId & | publisher | |||
) | [virtual] |
Definition at line 103 of file ReceivedDataStrategy.cpp.
References OpenDDS::DCPS::ReceivedDataElementList::apply_all(), and rcvd_samples_.
00105 { 00106 CoherentFilter filter = CoherentFilter(writer, publisher); 00107 AcceptCoherent operation = AcceptCoherent(writer, publisher); 00108 this->rcvd_samples_.apply_all(filter, operation); 00109 }
void OpenDDS::DCPS::ReceivedDataStrategy::add | ( | ReceivedDataElement * | data_sample | ) | [virtual] |
Reimplemented in OpenDDS::DCPS::SourceDataStrategy.
Definition at line 96 of file ReceivedDataStrategy.cpp.
References OpenDDS::DCPS::ReceivedDataElementList::add(), and rcvd_samples_.
00097 { 00098 this->rcvd_samples_.add(data_sample); 00099 }
void OpenDDS::DCPS::ReceivedDataStrategy::reject_coherent | ( | PublicationId & | writer, | |
RepoId & | publisher | |||
) | [virtual] |
Definition at line 112 of file ReceivedDataStrategy.cpp.
References rcvd_samples_, and OpenDDS::DCPS::ReceivedDataElementList::remove().
00114 { 00115 CoherentFilter filter = CoherentFilter(writer, publisher); 00116 this->rcvd_samples_.remove(filter, true); 00117 }
Definition at line 38 of file ReceivedDataStrategy.h.
Referenced by accept_coherent(), OpenDDS::DCPS::SourceDataStrategy::add(), add(), and reject_coherent().