OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo

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

Constructor & Destructor Documentation

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

Definition at line 193 of file RtpsUdpDataLink.h.

00194       : acknack_recvd_count_(0)
00195       , nackfrag_recvd_count_(0)
00196       , handshake_done_(false)
00197       , durable_(false)
00198     {}

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

Definition at line 2451 of file RtpsUdpDataLink.cpp.

References expire_durable_data().

02452 {
02453   expire_durable_data();
02454 }

Member Function Documentation

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

Definition at line 2466 of file RtpsUdpDataLink.cpp.

References durable_, and durable_timestamp_.

02467 {
02468   return durable_ &&
02469     (durable_timestamp_ == ACE_Time_Value::zero // DW hasn't resent yet
02470      || !durable_data_.empty());                // DW resent, not sent to reader
02471 }

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

Definition at line 2457 of file RtpsUdpDataLink.cpp.

References OPENDDS_MAP().

Referenced by ~ReaderInfo().

02458 {
02459   typedef OPENDDS_MAP(SequenceNumber, TransportQueueElement*)::iterator iter_t;
02460   for (iter_t it = durable_data_.begin(); it != durable_data_.end(); ++it) {
02461     it->second->data_dropped();
02462   }
02463 }