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_ |
Definition at line 232 of file RtpsUdpDataLink.h.
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 }
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 }
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 }
typedef OpenDDS::DCPS::RtpsUdpDataLink::RtpsWriter::OPENDDS_MULTIMAP | ( | SequenceNumber | , | |
TransportQueueElement * | ||||
) |
Definition at line 237 of file RtpsUdpDataLink.h.
Referenced by add_elem_awaiting_ack(), OpenDDS::DCPS::RtpsUdpDataLink::pre_stop_i(), OpenDDS::DCPS::RtpsUdpDataLink::process_acked_by_all_i(), OpenDDS::DCPS::RtpsUdpDataLink::release_reservations_i(), and ~RtpsWriter().
Definition at line 235 of file RtpsUdpDataLink.h.
Referenced by OpenDDS::DCPS::RtpsUdpDataLink::add_gap_submsg().
Definition at line 233 of file RtpsUdpDataLink.h.
Referenced by OpenDDS::DCPS::RtpsUdpDataLink::associated(), OpenDDS::DCPS::RtpsUdpDataLink::marshal_gaps(), OpenDDS::DCPS::RtpsUdpDataLink::process_acked_by_all_i(), OpenDDS::DCPS::RtpsUdpDataLink::send_nack_replies(), and OpenDDS::DCPS::RtpsUdpDataLink::send_nackfrag_replies().
Definition at line 234 of file RtpsUdpDataLink.h.
Referenced by heartbeat_high(), OpenDDS::DCPS::RtpsUdpDataLink::pre_stop_i(), OpenDDS::DCPS::RtpsUdpDataLink::process_acked_by_all_i(), OpenDDS::DCPS::RtpsUdpDataLink::process_requested_changes(), OpenDDS::DCPS::RtpsUdpDataLink::release_reservations_i(), OpenDDS::DCPS::RtpsUdpDataLink::send_directed_nack_replies(), OpenDDS::DCPS::RtpsUdpDataLink::send_nack_replies(), and OpenDDS::DCPS::RtpsUdpDataLink::send_nackfrag_replies().
Definition at line 239 of file RtpsUdpDataLink.h.
Referenced by OpenDDS::DCPS::RtpsUdpDataLink::pre_stop_i(), OpenDDS::DCPS::RtpsUdpDataLink::process_acked_by_all_i(), OpenDDS::DCPS::RtpsUdpDataLink::release_reservations_i(), and ~RtpsWriter().