OpenDDS::DCPS::SourceDataStrategy Class Reference

#include <ReceivedDataStrategy.h>

Inheritance diagram for OpenDDS::DCPS::SourceDataStrategy:

[legend]

Collaboration diagram for OpenDDS::DCPS::SourceDataStrategy:

[legend]

List of all members.

Public Member Functions
	SourceDataStrategy (ReceivedDataElementList &rcvd_samples)
	~SourceDataStrategy ()
virtual void	add (ReceivedDataElement *data_sample)

---

Detailed Description

Definition at line 49 of file ReceivedDataStrategy.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::SourceDataStrategy::SourceDataStrategy

(

ReceivedDataElementList &

rcvd_samples

)

[explicit]

Definition at line 128 of file ReceivedDataStrategy.cpp.

  : ReceivedDataStrategy(rcvd_samples)
{}

OpenDDS::DCPS::SourceDataStrategy::~SourceDataStrategy

(

)

Definition at line 133 of file ReceivedDataStrategy.cpp.

{}

---

Member Function Documentation

void OpenDDS::DCPS::SourceDataStrategy::add

(

ReceivedDataElement *

data_sample

)

[virtual]

Reimplemented from OpenDDS::DCPS::ReceivedDataStrategy.

Definition at line 137 of file ReceivedDataStrategy.cpp.

References OpenDDS::DCPS::ReceivedDataElementList::add(), OpenDDS::DCPS::ReceivedDataElementList::head_, OpenDDS::DCPS::ReceivedDataElement::next_data_sample_, OpenDDS::DCPS::ReceivedDataElement::previous_data_sample_, OpenDDS::DCPS::ReceivedDataStrategy::rcvd_samples_, OpenDDS::DCPS::ReceivedDataElementList::size_, and OpenDDS::DCPS::ReceivedDataElement::source_timestamp_.

{
  for (ReceivedDataElement* it = this->rcvd_samples_.head_;
       it != 0; it = it->next_data_sample_) {
    if (data_sample->source_timestamp_ < it->source_timestamp_) {
      data_sample->previous_data_sample_ = it->previous_data_sample_;
      data_sample->next_data_sample_ = it;

      // Are we replacing the head?
      if (it->previous_data_sample_ == 0) {
        this->rcvd_samples_.head_ = data_sample;

      } else {
        it->previous_data_sample_->next_data_sample_ = data_sample;
      }

      it->previous_data_sample_ = data_sample;

      ++this->rcvd_samples_.size_;

      return;
    }
  }

  this->rcvd_samples_.add(data_sample);
}

Here is the call graph for this function:

---

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

• ReceivedDataStrategy.h
• ReceivedDataStrategy.cpp