OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo Struct Reference

Collaboration diagram for OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo:

Public Member Functions
	OPENDDS_VECTOR (RTPS::SequenceNumberSet) requested_changes_
	OPENDDS_MAP (SequenceNumber, RTPS::FragmentNumberSet) requested_frags_
	OPENDDS_MAP (SequenceNumber, TransportQueueElement *) durable_data_
	ReaderInfo ()
	~ReaderInfo ()
void	expire_durable_data ()
bool	expecting_durable_data () const
Public Attributes
CORBA::Long	acknack_recvd_count_
CORBA::Long	nackfrag_recvd_count_
SequenceNumber	cur_cumulative_ack_
bool	handshake_done_
bool	durable_
ACE_Time_Value	durable_timestamp_

Detailed Description

Definition at line 210 of file RtpsUdpDataLink.h.

Constructor & Destructor Documentation

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

Definition at line 219 of file RtpsUdpDataLink.h.

00220       : acknack_recvd_count_(0)
00221       , nackfrag_recvd_count_(0)
00222       , handshake_done_(false)
00223       , durable_(false)
00224     {}

OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::~ReaderInfo ( )

Definition at line 2698 of file RtpsUdpDataLink.cpp.

References expire_durable_data().

02699 {
02700   expire_durable_data();
02701 }

Here is the call graph for this function:

Member Function Documentation

bool OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::expecting_durable_data ( ) const

Definition at line 2713 of file RtpsUdpDataLink.cpp.

References durable_, durable_timestamp_, and ACE_Time_Value::zero.

02714 {
02715   return durable_ &&
02716     (durable_timestamp_ == ACE_Time_Value::zero // DW hasn't resent yet
02717      || !durable_data_.empty());                // DW resent, not sent to reader
02718 }

void OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::expire_durable_data ( )

Definition at line 2704 of file RtpsUdpDataLink.cpp.

References OPENDDS_MAP().

Referenced by ~ReaderInfo().

02705 {
02706   typedef OPENDDS_MAP(SequenceNumber, TransportQueueElement*)::iterator iter_t;
02707   for (iter_t it = durable_data_.begin(); it != durable_data_.end(); ++it) {
02708     it->second->data_dropped();
02709   }
02710 }

Here is the call graph for this function: