OpenDDS::DCPS::RtpsUdpDataLink::WriterInfo

OpenDDS::DCPS::RtpsUdpDataLink::WriterInfo Struct Reference

Collaboration diagram for OpenDDS::DCPS::RtpsUdpDataLink::WriterInfo:


Public Member Functions
	OPENDDS_MAP (SequenceNumber, ReceivedDataSample) held_
	OPENDDS_MAP (SequenceNumber, RTPS::FragmentNumber_t) frags_
	WriterInfo ()
bool	should_nack () const
Public Attributes
DisjointSequence	recvd_
SequenceRange	hb_range_
bool	ack_pending_
bool	initial_hb_
CORBA::Long	heartbeat_recvd_count_
CORBA::Long	hb_frag_recvd_count_
CORBA::Long	acknack_count_
CORBA::Long	nackfrag_count_

Detailed Description

Definition at line 232 of file RtpsUdpDataLink.h.

Constructor & Destructor Documentation

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

Definition at line 241 of file RtpsUdpDataLink.h.

00242       : ack_pending_(false), initial_hb_(true), heartbeat_recvd_count_(0),
00243         hb_frag_recvd_count_(0), acknack_count_(0), nackfrag_count_(0) {}

Member Function Documentation

OpenDDS::DCPS::RtpsUdpDataLink::WriterInfo::OPENDDS_MAP	(	SequenceNumber	,
		RTPS::FragmentNumber_t
	)

OpenDDS::DCPS::RtpsUdpDataLink::WriterInfo::OPENDDS_MAP	(	SequenceNumber	,
		ReceivedDataSample
	)

bool OpenDDS::DCPS::RtpsUdpDataLink::WriterInfo::should_nack ( ) const

Definition at line 1181 of file RtpsUdpDataLink.cpp.

References OpenDDS::DCPS::DisjointSequence::cumulative_ack(), OpenDDS::DCPS::DisjointSequence::disjoint(), OpenDDS::DCPS::DisjointSequence::empty(), hb_range_, OpenDDS::DCPS::DisjointSequence::high(), and recvd_.

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

01182 {
01183   if (recvd_.disjoint() && recvd_.cumulative_ack() < hb_range_.second) {
01184     return true;
01185   }
01186   if (!recvd_.empty()) {
01187     return recvd_.high() < hb_range_.second;
01188   }
01189   return false;
01190 }