OpenDDS::DCPS::ReceivedDataElementList Class Reference

#include <ReceivedDataElementList.h>

Collaboration diagram for OpenDDS::DCPS::ReceivedDataElementList:

[legend]

List of all members.

Public Member Functions
	ReceivedDataElementList (InstanceState *instance_state=0)
	~ReceivedDataElementList ()
void	apply_all (ReceivedDataFilter &match, ReceivedDataOperation &func)
void	add (ReceivedDataElement *data_sample)
bool	remove (ReceivedDataElement *data_sample)
bool	remove (ReceivedDataFilter &match, bool eval_all)
ReceivedDataElement *	remove_head ()
ReceivedDataElement *	remove_tail ()
Public Attributes
ReceivedDataElement *	head_
	The first element of the list.
ReceivedDataElement *	tail_
	The last element of the list.
ssize_t	size_
	Number of elements in the list.
Private Attributes
InstanceState *	instance_state_

---

Detailed Description

Definition at line 173 of file ReceivedDataElementList.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::ReceivedDataElementList::ReceivedDataElementList

(

InstanceState *

instance_state = 0

)

Definition at line 55 of file ReceivedDataElementList.cpp.

  : head_(0), tail_(0), size_(0), instance_state_(instance_state)
{
}

OpenDDS::DCPS::ReceivedDataElementList::~ReceivedDataElementList

(

)

Definition at line 60 of file ReceivedDataElementList.cpp.

{
  // The memory pointed to by instance_state_ is owned by
  // another object.
}

---

Member Function Documentation

ACE_INLINE void OpenDDS::DCPS::ReceivedDataElementList::add

(

ReceivedDataElement *

data_sample

)

Definition at line 13 of file ReceivedDataElementList.inl.

References OpenDDS::DCPS::InstanceState::empty(), head_, instance_state_, OpenDDS::DCPS::ReceivedDataElement::next_data_sample_, OpenDDS::DCPS::ReceivedDataElement::previous_data_sample_, size_, and tail_.

Referenced by OpenDDS::DCPS::SourceDataStrategy::add(), and OpenDDS::DCPS::ReceivedDataStrategy::add().

{
  // The default action is to simply add to the
  // tail - in the future we may want to add
  // to the middle of the list based on sequence
  // number and/or source timestamp

  data_sample->previous_data_sample_ = 0;
  data_sample->next_data_sample_ = 0;

  ++size_ ;

  if (!head_) {
    // First sample in the list.
    head_ = tail_ = data_sample ;

  } else {
    // Add to existing list.
    tail_->next_data_sample_ = data_sample ;
    data_sample->previous_data_sample_ = tail_;
    tail_ = data_sample;
  }

  if (instance_state_) {
    instance_state_->empty(false);
  }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void OpenDDS::DCPS::ReceivedDataElementList::apply_all	(	ReceivedDataFilter &	match,
		ReceivedDataOperation &	func
	)

Definition at line 67 of file ReceivedDataElementList.cpp.

References head_, and OpenDDS::DCPS::ReceivedDataElement::next_data_sample_.

Referenced by OpenDDS::DCPS::ReceivedDataStrategy::accept_coherent().

{
  for (ReceivedDataElement* it = head_;
       it != 0 ; it = it->next_data_sample_) {
    if (match(it)) {
      op(it);
    }
  }
}

Here is the caller graph for this function:

bool OpenDDS::DCPS::ReceivedDataElementList::remove	(	ReceivedDataFilter &	match,
		bool	eval_all
	)

Definition at line 80 of file ReceivedDataElementList.cpp.

References OpenDDS::DCPS::InstanceState::empty(), head_, instance_state_, item(), OpenDDS::DCPS::ReceivedDataElement::next_data_sample_, OpenDDS::DCPS::ReceivedDataElement::previous_data_sample_, size_, and tail_.

{
  if (!head_) {
    return false;
  }

  bool released = false;

  for (ReceivedDataElement* item = head_ ; item != 0 ;
       item = item->next_data_sample_) {
    if (match(item)) {
      size_-- ;

      if (item == head_) {
        if (head_ == tail_) {
          head_ = tail_ = 0;

        } else {
          head_ = item->next_data_sample_ ;

          if (head_) {
            head_->previous_data_sample_ = 0 ;
          }
        }

      } else if (item == tail_) {
        tail_ = item->previous_data_sample_ ;

        if (tail_) {
          tail_->next_data_sample_ = 0 ;
        }

      } else {
        item->previous_data_sample_->next_data_sample_ =
          item->next_data_sample_ ;
        item->next_data_sample_->previous_data_sample_ =
          item->previous_data_sample_ ;
      }

      if (instance_state_ && size_ == 0) {
        // let the instance know it is empty
        released = released || instance_state_->empty(true);
      }

      if (!eval_all) break;
    }
  }

  return released;
}

Here is the call graph for this function:

bool OpenDDS::DCPS::ReceivedDataElementList::remove

(

ReceivedDataElement *

data_sample

)

Definition at line 134 of file ReceivedDataElementList.cpp.

Referenced by OpenDDS::DCPS::RakeResults< SampleSeq >::copy_into(), and OpenDDS::DCPS::ReceivedDataStrategy::reject_coherent().

{
  IdentityFilter match(data_sample);
  return remove(match, false); // short-circuit evaluation
}

Here is the caller graph for this function:

ACE_INLINE OpenDDS::DCPS::ReceivedDataElement * OpenDDS::DCPS::ReceivedDataElementList::remove_head

(

)

Definition at line 43 of file ReceivedDataElementList.inl.

References head_, and size_.

{
  if (!size_) {
    return 0 ;
  }

  OpenDDS::DCPS::ReceivedDataElement *ptr = head_ ;

  remove(head_) ;

  return ptr ;
}

ACE_INLINE OpenDDS::DCPS::ReceivedDataElement * OpenDDS::DCPS::ReceivedDataElementList::remove_tail

(

)

Definition at line 58 of file ReceivedDataElementList.inl.

References size_, and tail_.

{
  if (!size_) {
    return 0 ;
  }

  OpenDDS::DCPS::ReceivedDataElement *ptr = tail_ ;

  remove(tail_) ;

  return ptr ;
}

---

Member Data Documentation

ReceivedDataElement* OpenDDS::DCPS::ReceivedDataElementList::head_

The first element of the list.

Definition at line 194 of file ReceivedDataElementList.h.

Referenced by OpenDDS::DCPS::SourceDataStrategy::add(), add(), apply_all(), OpenDDS::DCPS::DataReaderImpl::contains_sample(), OpenDDS::DCPS::DataReaderImpl_T< MessageType >::contains_sample_filtered(), remove(), and remove_head().

InstanceState* OpenDDS::DCPS::ReceivedDataElementList::instance_state_ [private]

Definition at line 203 of file ReceivedDataElementList.h.

Referenced by add(), and remove().

ssize_t OpenDDS::DCPS::ReceivedDataElementList::size_

Number of elements in the list.

Definition at line 200 of file ReceivedDataElementList.h.

Referenced by OpenDDS::DCPS::SourceDataStrategy::add(), add(), remove(), remove_head(), and remove_tail().

ReceivedDataElement* OpenDDS::DCPS::ReceivedDataElementList::tail_

The last element of the list.

Definition at line 197 of file ReceivedDataElementList.h.

Referenced by add(), OpenDDS::DCPS::RakeResults< SampleSeq >::copy_into(), remove(), and remove_tail().

---

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

• ReceivedDataElementList.h
• ReceivedDataElementList.cpp
• ReceivedDataElementList.inl