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 258 of file RtpsUdpDataLink.h.

Constructor & Destructor Documentation

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

Definition at line 267 of file RtpsUdpDataLink.h.

00268       : ack_pending_(false), initial_hb_(true), heartbeat_recvd_count_(0),
00269         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 1236 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().

01237 {
01238   if (recvd_.disjoint() && recvd_.cumulative_ack() < hb_range_.second) {
01239     return true;
01240   }
01241   if (!recvd_.empty()) {
01242     return recvd_.high() < hb_range_.second;
01243   }
01244   return false;
01245 }