OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter

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

Collaboration diagram for OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter:


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< SingleSendBuffer >	send_buff_
SequenceNumber	expected_
SnToTqeMap	elems_not_acked_
SnToTqeMap	to_deliver_
bool	durable_

Detailed Description

Definition at line 206 of file RtpsUdpDataLink.h.

Constructor & Destructor Documentation

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

Definition at line 216 of file RtpsUdpDataLink.h.

00216 : durable_(false) {}

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

Definition at line 2473 of file RtpsUdpDataLink.cpp.

References elems_not_acked_, and to_deliver_.

02474 {
02475   if (!to_deliver_.empty()) {
02476     ACE_DEBUG((LM_WARNING, "(%P|%t) WARNING: RtpsWriter::~RtpsWriter - deleting with %d elements left to deliver\n", to_deliver_.size()));
02477   }
02478   if (!elems_not_acked_.empty()) {
02479     ACE_DEBUG((LM_WARNING, "(%P|%t) WARNING: RtpsWriter::~RtpsWriter - deleting with %d elements left not fully acknowledged\n", elems_not_acked_.size()));
02480   }
02481 }

Member Function Documentation

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

Definition at line 2494 of file RtpsUdpDataLink.cpp.

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

02495 {
02496   elems_not_acked_.insert(SnToTqeMap::value_type(element->sequence(), element));
02497 }

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

Definition at line 2484 of file RtpsUdpDataLink.cpp.

References send_buff_.

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

02485 {
02486   const SequenceNumber durable_max =
02487     ri.durable_data_.empty() ? 0 : ri.durable_data_.rbegin()->first;
02488   const SequenceNumber data_max =
02489     send_buff_.is_nil() ? 0 : (send_buff_->empty() ? 0 : send_buff_->high());
02490   return std::max(durable_max, data_max);
02491 }