Inheritance diagram for OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo:

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

[legend]

Public Member Functions
	OPENDDS_MAP (SequenceNumber, TransportQueueElement *) durable_data_

	ReaderInfo (const GUID_t &id, bool durable, const MonotonicTime_t &participant_discovered_at, ACE_CDR::ULong participant_flags, const SequenceNumber &start_sn)

	~ReaderInfo ()

void	swap_durable_data (OPENDDS_MAP(SequenceNumber, TransportQueueElement *)&dd)

void	expunge_durable_data ()

bool	expecting_durable_data () const

SequenceNumber	acked_sn () const

bool	reflects_heartbeat_count () const

Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()

virtual void	_add_ref ()

virtual void	_remove_ref ()

long	ref_count () const

WeakObject *	_get_weak_object () const

Public Attributes
const GUID_t	id_

const MonotonicTime_t	participant_discovered_at_

CORBA::Long	acknack_recvd_count_

CORBA::Long	nackfrag_recvd_count_

DisjointSequence	requests_

RequestedFragSeqMap	requested_frags_

SequenceNumber	cur_cumulative_ack_

const bool	durable_

const ACE_CDR::ULong	participant_flags_

ACE_CDR::Long	required_acknack_count_

MonotonicTimePoint	durable_timestamp_

const SequenceNumber	start_sn_

SequenceNumber	max_pvs_sn_

DisjointSequence	pvs_outstanding_

Additional Inherited Members
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Detailed Description

Definition at line 343 of file RtpsUdpDataLink.h.

Constructor & Destructor Documentation

◆ ReaderInfo()

OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::ReaderInfo	(	const GUID_t &	id,
		bool	durable,
		const MonotonicTime_t &	participant_discovered_at,
		ACE_CDR::ULong	participant_flags,
		const SequenceNumber &	start_sn
	)

inline

Definition at line 361 of file RtpsUdpDataLink.h.

References OpenDDS::ICE::OPENDDS_MAP().

       : id_(id)
       , participant_discovered_at_(participant_discovered_at)
       , acknack_recvd_count_(0)
       , nackfrag_recvd_count_(0)
       , cur_cumulative_ack_(SequenceNumber::ZERO()) // Starting at zero instead of unknown makes the logic cleaner.
       , durable_(durable)
       , participant_flags_(participant_flags)
       , required_acknack_count_(0)
       , start_sn_(start_sn)
 #ifdef OPENDDS_SECURITY
       , max_pvs_sn_(SequenceNumber::ZERO())
 #endif
     {}

◆ ~ReaderInfo()

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

Definition at line 4411 of file RtpsUdpDataLink.cpp.

 {
   expunge_durable_data();
 }

Member Function Documentation

◆ acked_sn()

SequenceNumber OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::acked_sn ( ) const

inline

Definition at line 383 of file RtpsUdpDataLink.h.

References OpenDDS::DCPS::SequenceNumber::previous().

383 { return cur_cumulative_ack_.previous(); }

OpenDDS::DCPS::SequenceNumber::previous

SequenceNumber previous() const

Definition: SequenceNumber.h:60

OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::cur_cumulative_ack_

SequenceNumber cur_cumulative_ack_

Definition: RtpsUdpDataLink.h:349

◆ expecting_durable_data()

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

Definition at line 4432 of file RtpsUdpDataLink.cpp.

 {
   return durable_ &&
     (durable_timestamp_.is_zero() // DW hasn't resent yet
      || !durable_data_.empty()); // DW resent, not sent to reader
 }

◆ expunge_durable_data()

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

Definition at line 4423 of file RtpsUdpDataLink.cpp.

References OpenDDS::DCPS::RtpsUdpDataLink::OPENDDS_MAP().

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

◆ OPENDDS_MAP()

OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::OPENDDS_MAP	(	SequenceNumber	,
		TransportQueueElement *
	)

◆ reflects_heartbeat_count()

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

Definition at line 4440 of file RtpsUdpDataLink.cpp.

References OpenDDS::RTPS::PFLAGS_REFLECT_HEARTBEAT_COUNT.

 {
   return participant_flags_ & RTPS::PFLAGS_REFLECT_HEARTBEAT_COUNT;
 }

◆ swap_durable_data()

void OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::swap_durable_data ( OPENDDS_MAP(SequenceNumber, TransportQueueElement *)& dd )

Definition at line 4417 of file RtpsUdpDataLink.cpp.

 {
   durable_data_.swap(dd);
 }

Member Data Documentation

◆ acknack_recvd_count_

CORBA::Long OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::acknack_recvd_count_

Definition at line 346 of file RtpsUdpDataLink.h.

◆ cur_cumulative_ack_

SequenceNumber OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::cur_cumulative_ack_

Definition at line 349 of file RtpsUdpDataLink.h.

◆ durable_

const bool OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::durable_

Definition at line 350 of file RtpsUdpDataLink.h.

◆ durable_timestamp_

MonotonicTimePoint OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::durable_timestamp_

Definition at line 354 of file RtpsUdpDataLink.h.

◆ id_

const GUID_t OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::id_

Definition at line 344 of file RtpsUdpDataLink.h.

◆ max_pvs_sn_

SequenceNumber OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::max_pvs_sn_

Definition at line 357 of file RtpsUdpDataLink.h.

◆ nackfrag_recvd_count_

CORBA::Long OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::nackfrag_recvd_count_

Definition at line 346 of file RtpsUdpDataLink.h.

◆ participant_discovered_at_

const MonotonicTime_t OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::participant_discovered_at_

Definition at line 345 of file RtpsUdpDataLink.h.

◆ participant_flags_

const ACE_CDR::ULong OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::participant_flags_

Definition at line 351 of file RtpsUdpDataLink.h.

◆ pvs_outstanding_

DisjointSequence OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::pvs_outstanding_

Definition at line 358 of file RtpsUdpDataLink.h.

◆ requested_frags_

RequestedFragSeqMap OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::requested_frags_

Definition at line 348 of file RtpsUdpDataLink.h.

◆ requests_

DisjointSequence OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::requests_

Definition at line 347 of file RtpsUdpDataLink.h.

◆ required_acknack_count_

ACE_CDR::Long OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::required_acknack_count_

Definition at line 352 of file RtpsUdpDataLink.h.

◆ start_sn_

const SequenceNumber OpenDDS::DCPS::RtpsUdpDataLink::ReaderInfo::start_sn_

Definition at line 355 of file RtpsUdpDataLink.h.

The documentation for this struct was generated from the following files:

Public Member Functions

Public Attributes

Additional Inherited Members