OpenDDS::DCPS::RtpsUdpDataLink::HeldDataDeliveryHandler Class Reference

Inheritance diagram for OpenDDS::DCPS::RtpsUdpDataLink::HeldDataDeliveryHandler:

[legend]

Collaboration diagram for OpenDDS::DCPS::RtpsUdpDataLink::HeldDataDeliveryHandler:

[legend]

List of all members.

Public Member Functions
	HeldDataDeliveryHandler (RtpsUdpDataLink *link)
int	handle_exception (ACE_HANDLE)
void	notify_delivery (const RepoId &readerId, WriterInfo &info)
virtual ACE_Event_Handler::Reference_Count	add_reference ()
virtual ACE_Event_Handler::Reference_Count	remove_reference ()
Private Types
typedef std::pair < ReceivedDataSample, RepoId >	HeldDataEntry
Private Member Functions
typedef	OPENDDS_VECTOR (HeldDataEntry) HeldData
Private Attributes
RtpsUdpDataLink *	link_
HeldData	held_data_

---

Detailed Description

Definition at line 512 of file RtpsUdpDataLink.h.

---

Member Typedef Documentation

typedef std::pair<ReceivedDataSample, RepoId> OpenDDS::DCPS::RtpsUdpDataLink::HeldDataDeliveryHandler::HeldDataEntry [private]

Definition at line 527 of file RtpsUdpDataLink.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::RtpsUdpDataLink::HeldDataDeliveryHandler::HeldDataDeliveryHandler

(

RtpsUdpDataLink *

link

)

[inline]

Definition at line 514 of file RtpsUdpDataLink.h.

      : link_(link) {
      }

---

Member Function Documentation

ACE_Event_Handler::Reference_Count OpenDDS::DCPS::RtpsUdpDataLink::HeldDataDeliveryHandler::add_reference

(

void

)

[virtual]

Reimplemented from OpenDDS::DCPS::RcEventHandler.

Definition at line 2847 of file RtpsUdpDataLink.cpp.

References OpenDDS::DCPS::RcEventHandler::add_reference(), and link_.

{
  return link_->add_reference();
}

Here is the call graph for this function:

int OpenDDS::DCPS::RtpsUdpDataLink::HeldDataDeliveryHandler::handle_exception

(

ACE_HANDLE

)

[virtual]

Reimplemented from ACE_Event_Handler.

Definition at line 2811 of file RtpsUdpDataLink.cpp.

References OpenDDS::DCPS::DataLink::data_received(), held_data_, link_, OpenDDS::DCPS::RtpsUdpDataLink::reactor_task_, and ACE_Thread::self().

{
  ACE_ASSERT(link_->reactor_task_->get_reactor_owner() == ACE_Thread::self());

  HeldData::iterator itr;
  for (itr = held_data_.begin(); itr != held_data_.end(); ++itr) {
    link_->data_received(itr->first, itr->second);
  }
  held_data_.clear();
  return 0;
}

Here is the call graph for this function:

void OpenDDS::DCPS::RtpsUdpDataLink::HeldDataDeliveryHandler::notify_delivery	(	const RepoId &	readerId,
		WriterInfo &	info
	)

Definition at line 2823 of file RtpsUdpDataLink.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DisjointSequence::cumulative_ack(), held_data_, link_, LM_DEBUG, OpenDDS::DCPS::OPENDDS_MAP(), OPENDDS_STRING, OpenDDS::DCPS::RtpsUdpDataLink::reactor_task_, OpenDDS::DCPS::RtpsUdpDataLink::WriterInfo::recvd_, ACE_Thread::self(), and OpenDDS::DCPS::Transport_debug_level.

Referenced by OpenDDS::DCPS::RtpsUdpDataLink::deliver_held_data().

{
  ACE_ASSERT(link_->reactor_task_->get_reactor_owner() == ACE_Thread::self());

  const SequenceNumber ca = info.recvd_.cumulative_ack();
  typedef OPENDDS_MAP(SequenceNumber, ReceivedDataSample)::iterator iter;
  const iter end = info.held_.upper_bound(ca);

  for (iter it = info.held_.begin(); it != end; /*increment in loop body*/) {
    if (Transport_debug_level > 5) {
      GuidConverter reader(readerId);
      ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) RtpsUdpDataLink::HeldDataDeliveryHandler::notify_delivery -")
                           ACE_TEXT(" deliver sequence: %q to %C\n"),
                           it->second.header_.sequence_.getValue(),
                           OPENDDS_STRING(reader).c_str()));
    }
    // The head_data_ is not protected by a mutex because it is always accessed from the reactor task thread.
    held_data_.push_back(HeldDataEntry(it->second, readerId));
    info.held_.erase(it++);
  }
  link_->reactor_task_->get_reactor()->notify(this);
}

Here is the call graph for this function:

Here is the caller graph for this function:

typedef OpenDDS::DCPS::RtpsUdpDataLink::HeldDataDeliveryHandler::OPENDDS_VECTOR

(

HeldDataEntry

)

[private]

ACE_Event_Handler::Reference_Count OpenDDS::DCPS::RtpsUdpDataLink::HeldDataDeliveryHandler::remove_reference

(

void

)

[virtual]

Reimplemented from OpenDDS::DCPS::RcEventHandler.

Definition at line 2853 of file RtpsUdpDataLink.cpp.

References link_, and OpenDDS::DCPS::RcEventHandler::remove_reference().

{
  return link_->remove_reference();
}

Here is the call graph for this function:

---

Member Data Documentation

HeldData OpenDDS::DCPS::RtpsUdpDataLink::HeldDataDeliveryHandler::held_data_ [private]

Definition at line 529 of file RtpsUdpDataLink.h.

Referenced by handle_exception(), and notify_delivery().

RtpsUdpDataLink* OpenDDS::DCPS::RtpsUdpDataLink::HeldDataDeliveryHandler::link_ [private]

Definition at line 526 of file RtpsUdpDataLink.h.

Referenced by add_reference(), handle_exception(), notify_delivery(), and remove_reference().

---

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

• RtpsUdpDataLink.h
• RtpsUdpDataLink.cpp