OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter Struct Reference

Collaboration diagram for OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter:
Collaboration graph
[legend]

List of all members.

Public Member Functions

typedef OPENDDS_MULTIMAP (SequenceNumber, TransportQueueElement *) SnToTqeMap
 RtpsWriter ()
 ~RtpsWriter ()
SequenceNumber heartbeat_high (const ReaderInfo &) const
void add_elem_awaiting_ack (TransportQueueElement *element)

Public Attributes

ReaderInfoMap remote_readers_
RcHandle< SingleSendBuffersend_buff_
SequenceNumber expected_
SnToTqeMap elems_not_acked_
SnToTqeMap to_deliver_
bool durable_

Detailed Description

Definition at line 232 of file RtpsUdpDataLink.h.


Constructor & Destructor Documentation

OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::RtpsWriter (  )  [inline]

Definition at line 242 of file RtpsUdpDataLink.h.

00242 : durable_(false) {}

OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::~RtpsWriter (  ) 

Definition at line 2720 of file RtpsUdpDataLink.cpp.

References elems_not_acked_, LM_WARNING, and to_deliver_.

02721 {
02722   if (!to_deliver_.empty()) {
02723     ACE_DEBUG((LM_WARNING, "(%P|%t) WARNING: RtpsWriter::~RtpsWriter - deleting with %d elements left to deliver\n", to_deliver_.size()));
02724   }
02725   if (!elems_not_acked_.empty()) {
02726     ACE_DEBUG((LM_WARNING, "(%P|%t) WARNING: RtpsWriter::~RtpsWriter - deleting with %d elements left not fully acknowledged\n", elems_not_acked_.size()));
02727   }
02728 }


Member Function Documentation

void OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::add_elem_awaiting_ack ( TransportQueueElement element  ) 

Definition at line 2741 of file RtpsUdpDataLink.cpp.

References elems_not_acked_, and OpenDDS::DCPS::TransportQueueElement::sequence().

02742 {
02743   elems_not_acked_.insert(SnToTqeMap::value_type(element->sequence(), element));
02744 }

Here is the call graph for this function:

SequenceNumber OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::heartbeat_high ( const ReaderInfo ri  )  const

Definition at line 2731 of file RtpsUdpDataLink.cpp.

References OpenDDS::DCPS::RcHandle< T >::is_nil(), and send_buff_.

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

02732 {
02733   const SequenceNumber durable_max =
02734     ri.durable_data_.empty() ? 0 : ri.durable_data_.rbegin()->first;
02735   const SequenceNumber data_max =
02736     send_buff_.is_nil() ? 0 : (send_buff_->empty() ? 0 : send_buff_->high());
02737   return std::max(durable_max, data_max);
02738 }

Here is the call graph for this function:

Here is the caller graph for this function:

typedef OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::OPENDDS_MULTIMAP ( SequenceNumber  ,
TransportQueueElement  
)

Member Data Documentation

Definition at line 235 of file RtpsUdpDataLink.h.

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


The documentation for this struct was generated from the following files:
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Defines

Generated on 10 Aug 2018 for OpenDDS by  doxygen 1.6.1