Keeps track of a DataWriter's liveliness for a DataReader. More...

#include <WriterInfo.h>

Inheritance diagram for OpenDDS::DCPS::WriterInfo:

Collaboration diagram for OpenDDS::DCPS::WriterInfo:

[legend]

Public Types
enum	WriterState { NOT_SET, ALIVE, DEAD }

enum	TimerState { NO_TIMER = -1 }

Public Member Functions
	WriterInfo (const WriterInfoListener_rch &reader, const GUID_t &writer_id, const DDS::DataWriterQos &writer_qos)

MonotonicTimePoint	check_activity (const MonotonicTimePoint &now)

void	received_activity (const MonotonicTimePoint &when)
	called when a sample or other activity is received from this writer. More...

WriterState	state () const
	returns 1 if the DataWriter is lively; 2 if dead; otherwise returns 0. More...

void	state (WriterState state)

DDS::InstanceHandle_t	handle () const

void	handle (DDS::InstanceHandle_t handle)

GUID_t	writer_id () const

CORBA::Long	writer_qos_ownership_strength () const

void	writer_qos_ownership_strength (const CORBA::Long writer_qos_ownership_strength)

bool	waiting_for_end_historic_samples () const

void	waiting_for_end_historic_samples (bool waiting_for_end_historic_samples)

SequenceNumber	last_historic_seq () const

void	last_historic_seq (const SequenceNumber &last_historic_seq)

const char *	get_state_str () const

void	removed ()
	update liveliness when remove_association is called. More...

Coherent_State	coherent_change_received ()

void	reset_coherent_info ()

void	set_group_info (const CoherentChangeControl &info)

void	add_coherent_samples (const SequenceNumber &seq)

void	coherent_change (bool group_coherent, const GUID_t &publisher_id)

bool	group_coherent () const

GUID_t	publisher_id () const

void	clear_owner_evaluated ()

void	set_owner_evaluated (DDS::InstanceHandle_t instance, bool flag)

bool	is_owner_evaluated (DDS::InstanceHandle_t instance)

void	schedule_historic_samples_timer (EndHistoricSamplesMissedSweeper *sweeper, const ACE_Time_Value &ten_seconds)

void	cancel_historic_samples_timer (EndHistoricSamplesMissedSweeper *sweeper)

bool	check_end_historic_samples (EndHistoricSamplesMissedSweeper *sweeper, OPENDDS_MAP(SequenceNumber, ReceivedDataSample)&to_deliver)

bool	check_historic (const SequenceNumber &seq, const ReceivedDataSample &sample, SequenceNumber &last_historic_seq)

void	finished_delivering_historic ()

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

Private Member Functions
	OPENDDS_MAP (SequenceNumber, ReceivedDataSample) historic_samples_

typedef	OPENDDS_MAP (DDS::InstanceHandle_t, bool) OwnerEvaluateFlags
	Is this writer evaluated for owner ? More...

Private Attributes
ACE_Thread_Mutex	mutex_

MonotonicTimePoint	last_liveliness_activity_time_
	Timestamp of last write/dispose/assert_liveliness from this DataWriter. More...

long	historic_samples_timer_

SequenceNumber	last_historic_seq_
	After receiving END_HISTORIC_SAMPLES, check for duplicates. More...

bool	waiting_for_end_historic_samples_

bool	delivering_historic_samples_

ConditionVariable< ACE_Thread_Mutex >	delivering_historic_samples_cv_

WriterState	state_
	State of the writer. More...

WeakRcHandle< WriterInfoListener >	reader_
	The DataReader owning this WriterInfo. More...

GUID_t	writer_id_
	DCPSInfoRepo ID of the DataWriter. More...

DDS::DataWriterQos	writer_qos_
	Writer qos. More...

DDS::InstanceHandle_t	handle_
	The publication entity instance handle. More...

Atomic< ACE_UINT32 >	coherent_samples_
	Number of received coherent changes in active change set. More...

OwnerEvaluateFlags	owner_evaluated_

bool	group_coherent_
	Data to support GROUP access scope. More...

GUID_t	publisher_id_

DisjointSequence	coherent_sample_sequence_

WriterCoherentSample	writer_coherent_samples_

GroupCoherentSamples	group_coherent_samples_

Friends
class	WriteInfoListner

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

Detailed Description

Keeps track of a DataWriter's liveliness for a DataReader.

Definition at line 81 of file WriterInfo.h.

Member Enumeration Documentation

◆ TimerState

enum OpenDDS::DCPS::WriterInfo::TimerState

Enumerator
NO_TIMER

Definition at line 86 of file WriterInfo.h.

86 { NO_TIMER = -1 };

OpenDDS::DCPS::WriterInfo::NO_TIMER

Definition: WriterInfo.h:86

◆ WriterState

enum OpenDDS::DCPS::WriterInfo::WriterState

Enumerator
NOT_SET
ALIVE
DEAD

Definition at line 85 of file WriterInfo.h.

85 { NOT_SET, ALIVE, DEAD };

OpenDDS::DCPS::WriterInfo::ALIVE

Definition: WriterInfo.h:85

OpenDDS::DCPS::WriterInfo::DEAD

Definition: WriterInfo.h:85

OpenDDS::DCPS::WriterInfo::NOT_SET

Definition: WriterInfo.h:85

Constructor & Destructor Documentation

◆ WriterInfo()

OpenDDS::DCPS::WriterInfo::WriterInfo	(	const WriterInfoListener_rch &	reader,
		const GUID_t &	writer_id,
		const DDS::DataWriterQos &	writer_qos
	)

Referenced by OpenDDS::DCPS::WriterInfoListener::writer_removed().

Member Function Documentation

◆ add_coherent_samples()

void OpenDDS::DCPS::WriterInfo::add_coherent_samples ( const SequenceNumber & seq )

Definition at line 165 of file WriterInfo.cpp.

Referenced by OpenDDS::DCPS::DataReaderImpl::writer_activity().

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   if (coherent_samples_ == 0) {
     static const SequenceNumber defaultSN;
     const SequenceRange resetRange(defaultSN, seq);
     coherent_sample_sequence_.reset();
     coherent_sample_sequence_.insert(resetRange);
   }
   else {
     coherent_sample_sequence_.insert(seq);
   }
 }

◆ cancel_historic_samples_timer()

void OpenDDS::DCPS::WriterInfo::cancel_historic_samples_timer ( EndHistoricSamplesMissedSweeper * sweeper )

Definition at line 111 of file WriterInfo.cpp.

References NO_TIMER, and OpenDDS::DCPS::ReactorInterceptor::reactor().

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   if (historic_samples_timer_ != WriterInfo::NO_TIMER) {
     sweeper->reactor()->cancel_timer(historic_samples_timer_);
     historic_samples_timer_ = WriterInfo::NO_TIMER;
   }
 }

◆ check_activity()

MonotonicTimePoint OpenDDS::DCPS::WriterInfo::check_activity ( const MonotonicTimePoint & now )

check to see if this writer is alive (called by handle_timeout).

Parameters

now	next monotonic time this DataWriter will become not active (not alive) if no sample or liveliness message is received.

Returns: montonic time when the Writer will become not active (if no activity) of MonotonicTimePoint::max_value if the writer is already or became not alive

Definition at line 220 of file WriterInfo.cpp.

References OpenDDS::DCPS::TimePoint_T< MonotonicClock >::max_value, and ACE_Guard< ACE_LOCK >::release().

 {
   MonotonicTimePoint expires_at(MonotonicTimePoint::max_value);
 
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
 
   WriterInfoListener_rch reader = reader_.lock();
 
   // We only need check the liveliness with the non-zero liveliness_lease_duration_.
   if (state_ == ALIVE && reader && !reader->liveliness_lease_duration_.is_zero()) {
     expires_at = last_liveliness_activity_time_ + reader->liveliness_lease_duration_;
 
     if (expires_at <= now) {
       // let all instances know this write is not alive.
       guard.release();
       reader->writer_became_dead(*this);
       expires_at = MonotonicTimePoint::max_value;
     }
   }
 
   return expires_at;
 }

◆ check_end_historic_samples()

bool OpenDDS::DCPS::WriterInfo::check_end_historic_samples	(	EndHistoricSamplesMissedSweeper *	sweeper,
		OPENDDS_MAP(SequenceNumber, ReceivedDataSample)&	to_deliver
	)

Definition at line 121 of file WriterInfo.cpp.

References OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::cancel_timer(), OpenDDS::DCPS::rchandle_from(), ACE_Guard< ACE_LOCK >::release(), and TheServiceParticipant.

Referenced by OpenDDS::DCPS::DataReaderImpl::resume_sample_processing().

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   while (delivering_historic_samples_) {
     delivering_historic_samples_cv_.wait(TheServiceParticipant->get_thread_status_manager());
   }
   if (waiting_for_end_historic_samples_) {
     bool result = false;
     RcHandle<WriterInfo> info = rchandle_from(this);
     if (!historic_samples_.empty()) {
       last_historic_seq_ = historic_samples_.rbegin()->first;
       delivering_historic_samples_ = true;
       to_deliver.swap(historic_samples_);
       result = true;
     }
     guard.release();
     sweeper->cancel_timer(info);
     return result;
   }
   return false;
 }

◆ check_historic()

bool OpenDDS::DCPS::WriterInfo::check_historic	(	const SequenceNumber &	seq,
		const ReceivedDataSample &	sample,
		SequenceNumber &	last_historic_seq
	)

Definition at line 144 of file WriterInfo.cpp.

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   last_historic_seq = last_historic_seq_;
   if (waiting_for_end_historic_samples_) {
     historic_samples_.insert(std::make_pair(seq, sample));
     return true;
   }
   return false;
 }

◆ clear_owner_evaluated()

void OpenDDS::DCPS::WriterInfo::clear_owner_evaluated ( )

Definition at line 190 of file WriterInfo.cpp.

Referenced by OpenDDS::DCPS::DataReaderImpl::writer_became_dead(), and OpenDDS::DCPS::DataReaderImpl::writer_removed().

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   owner_evaluated_.clear();
 }

◆ coherent_change()

void OpenDDS::DCPS::WriterInfo::coherent_change	(	bool	group_coherent,
		const GUID_t &	publisher_id
	)

Definition at line 180 of file WriterInfo.cpp.

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   group_coherent_ = group_coherent;
   publisher_id_ = publisher_id;
   ++coherent_samples_;
 }

◆ coherent_change_received()

Coherent_State OpenDDS::DCPS::WriterInfo::coherent_change_received ( )

Definition at line 256 of file WriterInfo.cpp.

References OpenDDS::DCPS::COMPLETED, OpenDDS::DCPS::NOT_COMPLETED_YET, and OpenDDS::DCPS::REJECTED.

Referenced by OpenDDS::DCPS::DataReaderImpl::verify_coherent_changes_completion().

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   if (writer_coherent_samples_.num_samples_ == 0) {
     return NOT_COMPLETED_YET;
   }
 
   if (!coherent_sample_sequence_.disjoint()
       && (coherent_sample_sequence_.high()
           == writer_coherent_samples_.last_sample_)) {
     return COMPLETED;
   }
 
   if (coherent_sample_sequence_.high() >
       writer_coherent_samples_.last_sample_) {
     return REJECTED;
   }
 
   return NOT_COMPLETED_YET;
 }

◆ finished_delivering_historic()

void OpenDDS::DCPS::WriterInfo::finished_delivering_historic ( )

Definition at line 156 of file WriterInfo.cpp.

Referenced by OpenDDS::DCPS::DataReaderImpl::resume_sample_processing().

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   delivering_historic_samples_ = false;
   delivering_historic_samples_cv_.notify_all();
 }

◆ get_state_str()

const char * OpenDDS::DCPS::WriterInfo::get_state_str ( ) const

Definition at line 84 of file WriterInfo.cpp.

References ACE_ERROR, ACE_TEXT(), and LM_ERROR.

Referenced by OpenDDS::DCPS::DataReaderImpl::writer_became_alive(), and OpenDDS::DCPS::DataReaderImpl::writer_became_dead().

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   switch (state_) {
   case NOT_SET:
     return "NOT_SET";
   case ALIVE:
     return "ALIVE";
   case DEAD:
     return "DEAD";
   default:
     ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) ERROR: WriterInfo::get_state_str: ")
       ACE_TEXT("%d is either invalid or not recognized.\n"),
       state_));
     return "Invalid state";
   }
 }

◆ group_coherent()

bool OpenDDS::DCPS::WriterInfo::group_coherent ( ) const

inline

Definition at line 181 of file WriterInfo.h.

Referenced by OpenDDS::DCPS::DataReaderImpl::verify_coherent_changes_completion().

                               {
     ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
     return group_coherent_;
   }

◆ handle() [1/2]

DDS::InstanceHandle_t OpenDDS::DCPS::WriterInfo::handle ( void ) const

inline

Definition at line 115 of file WriterInfo.h.

Referenced by OpenDDS::DCPS::DataReaderImpl::writer_became_alive(), OpenDDS::DCPS::DataReaderImpl::writer_became_dead(), and OpenDDS::DCPS::DataReaderImpl::writer_removed().

   {
     ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
     return handle_;
   }

◆ handle() [2/2]

void OpenDDS::DCPS::WriterInfo::handle ( DDS::InstanceHandle_t handle )

inline

Definition at line 121 of file WriterInfo.h.

   {
     ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
     handle_ = handle;
   };

◆ is_owner_evaluated()

bool OpenDDS::DCPS::WriterInfo::is_owner_evaluated ( DDS::InstanceHandle_t instance )

Definition at line 207 of file WriterInfo.cpp.

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   OwnerEvaluateFlags::iterator iter = owner_evaluated_.find(instance);
   if (iter == owner_evaluated_.end()) {
     owner_evaluated_.insert(OwnerEvaluateFlags::value_type(instance, false));
     return false;
   }
   else
     return iter->second;
 }

◆ last_historic_seq() [1/2]

SequenceNumber OpenDDS::DCPS::WriterInfo::last_historic_seq ( ) const

inline

Definition at line 157 of file WriterInfo.h.

   {
     ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
     return last_historic_seq_;
   }

◆ last_historic_seq() [2/2]

void OpenDDS::DCPS::WriterInfo::last_historic_seq ( const SequenceNumber & last_historic_seq )

inline

Definition at line 163 of file WriterInfo.h.

   {
     ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
     last_historic_seq_ = last_historic_seq;
   }

◆ OPENDDS_MAP() [1/2]

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

private

Temporary holding place for samples received before the END_HISTORIC_SAMPLES control message.

◆ OPENDDS_MAP() [2/2]

typedef OpenDDS::DCPS::WriterInfo::OPENDDS_MAP	(	DDS::InstanceHandle_t	,
		bool
	)

private

Is this writer evaluated for owner ?

◆ publisher_id()

GUID_t OpenDDS::DCPS::WriterInfo::publisher_id ( ) const

inline

Definition at line 186 of file WriterInfo.h.

References OpenDDS::DCPS::OPENDDS_MAP().

Referenced by OpenDDS::DCPS::DataReaderImpl::verify_coherent_changes_completion().

                               {
     ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
     return publisher_id_;
   }

◆ received_activity()

void OpenDDS::DCPS::WriterInfo::received_activity ( const MonotonicTimePoint & when )

inline

called when a sample or other activity is received from this writer.

Definition at line 260 of file WriterInfo.h.

References ACE_Guard< ACE_LOCK >::release().

Referenced by OpenDDS::DCPS::DataReaderImpl::writer_activity().

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
 
   last_liveliness_activity_time_ = when;
 
   if (state_ != ALIVE) { // NOT_SET || DEAD
     RcHandle<WriterInfoListener> reader = reader_.lock();
     guard.release();
     if (reader) {
       reader->writer_became_alive(*this, when);
     }
   }
 }

◆ removed()

void OpenDDS::DCPS::WriterInfo::removed ( )

update liveliness when remove_association is called.

Definition at line 244 of file WriterInfo.cpp.

References ACE_Guard< ACE_LOCK >::release().

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   WriterInfoListener_rch reader = reader_.lock();
   guard.release();
   if (reader) {
     reader->writer_removed(*this);
   }
 }

◆ reset_coherent_info()

void OpenDDS::DCPS::WriterInfo::reset_coherent_info ( )

Definition at line 278 of file WriterInfo.cpp.

References OpenDDS::DCPS::GUID_UNKNOWN.

Referenced by OpenDDS::DCPS::DataReaderImpl::verify_coherent_changes_completion().

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   coherent_samples_ = 0;
   group_coherent_ = false;
   publisher_id_ = GUID_UNKNOWN;
   coherent_sample_sequence_.reset();
   writer_coherent_samples_.reset();
   group_coherent_samples_.clear();
 }

◆ schedule_historic_samples_timer()

void OpenDDS::DCPS::WriterInfo::schedule_historic_samples_timer	(	EndHistoricSamplesMissedSweeper *	sweeper,
		const ACE_Time_Value &	ten_seconds
	)

Definition at line 103 of file WriterInfo.cpp.

References OpenDDS::DCPS::ReactorInterceptor::reactor().

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   const void* arg = reinterpret_cast<const void*>(this);
   historic_samples_timer_ = sweeper->reactor()->schedule_timer(sweeper, arg, ten_seconds);
 }

◆ set_group_info()

void OpenDDS::DCPS::WriterInfo::set_group_info ( const CoherentChangeControl & info )

Definition at line 291 of file WriterInfo.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::LogGuid::c_str(), OpenDDS::DCPS::CoherentChangeControl::coherent_samples_, OpenDDS::DCPS::CoherentChangeControl::group_coherent_, OpenDDS::DCPS::CoherentChangeControl::group_coherent_samples_, LM_ERROR, OPENDDS_END_VERSIONED_NAMESPACE_DECL, and OpenDDS::DCPS::CoherentChangeControl::publisher_id_.

Referenced by OpenDDS::DCPS::DataReaderImpl::data_received().

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   if (!(publisher_id_ == info.publisher_id_)
       || group_coherent_ != info.group_coherent_) {
     WriterInfoListener_rch reader = reader_.lock();
     ACE_ERROR((LM_ERROR,
                ACE_TEXT("(%P|%t) ERROR: WriterInfo::set_group_info()")
                ACE_TEXT(" reader %C writer %C incorrect coherent info !\n"),
                reader ? LogGuid(reader->subscription_id_).c_str() : "",
                LogGuid(writer_id_).c_str()));
   }
 
   writer_coherent_samples_ = info.coherent_samples_;
   group_coherent_samples_ = info.group_coherent_samples_;
 }

◆ set_owner_evaluated()

void OpenDDS::DCPS::WriterInfo::set_owner_evaluated	(	DDS::InstanceHandle_t	instance,
		bool	flag
	)

Definition at line 197 of file WriterInfo.cpp.

 {
   ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
   if (flag ||
       (!flag && owner_evaluated_.find(instance) != owner_evaluated_.end())) {
     owner_evaluated_[instance] = flag;
   }
 }

◆ state() [1/2]

WriterState OpenDDS::DCPS::WriterInfo::state ( void ) const

inline

returns 1 if the DataWriter is lively; 2 if dead; otherwise returns 0.

Definition at line 103 of file WriterInfo.h.

Referenced by OpenDDS::DCPS::DataReaderImpl::writer_became_alive(), OpenDDS::DCPS::DataReaderImpl::writer_became_dead(), and OpenDDS::DCPS::DataReaderImpl::writer_removed().

   {
     ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
     return state_;
   };

◆ state() [2/2]

void OpenDDS::DCPS::WriterInfo::state ( WriterState state )

inline

Definition at line 109 of file WriterInfo.h.

References state.

   {
     ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
     state_ = state;
   };

◆ waiting_for_end_historic_samples() [1/2]

bool OpenDDS::DCPS::WriterInfo::waiting_for_end_historic_samples ( ) const

inline

Definition at line 145 of file WriterInfo.h.

Referenced by OpenDDS::DCPS::DataReaderImpl::add_association(), OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::cancel_timer(), and OpenDDS::DCPS::EndHistoricSamplesMissedSweeper::schedule_timer().

   {
     ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
     return waiting_for_end_historic_samples_;
   }

◆ waiting_for_end_historic_samples() [2/2]

void OpenDDS::DCPS::WriterInfo::waiting_for_end_historic_samples ( bool waiting_for_end_historic_samples )

inline

Definition at line 151 of file WriterInfo.h.

   {
     ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
     waiting_for_end_historic_samples_ = waiting_for_end_historic_samples;
   }

◆ writer_id()

GUID_t OpenDDS::DCPS::WriterInfo::writer_id ( ) const

inline

Definition at line 127 of file WriterInfo.h.

Referenced by OpenDDS::DCPS::DataReaderImpl::verify_coherent_changes_completion(), OpenDDS::DCPS::DataReaderImpl::writer_became_alive(), OpenDDS::DCPS::DataReaderImpl::writer_became_dead(), and OpenDDS::DCPS::DataReaderImpl::writer_removed().

   {
     ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
     return writer_id_;
   }

◆ writer_qos_ownership_strength() [1/2]

CORBA::Long OpenDDS::DCPS::WriterInfo::writer_qos_ownership_strength ( ) const

inline

Definition at line 133 of file WriterInfo.h.

   {
     ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
     return writer_qos_.ownership_strength.value;
   }

◆ writer_qos_ownership_strength() [2/2]

void OpenDDS::DCPS::WriterInfo::writer_qos_ownership_strength ( const CORBA::Long writer_qos_ownership_strength )

inline

Definition at line 139 of file WriterInfo.h.

   {
     ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
     writer_qos_.ownership_strength.value = writer_qos_ownership_strength;
   }

Friends And Related Function Documentation

◆ WriteInfoListner

friend class WriteInfoListner

friend

Definition at line 82 of file WriterInfo.h.

Member Data Documentation

◆ coherent_sample_sequence_

DisjointSequence OpenDDS::DCPS::WriterInfo::coherent_sample_sequence_

private

Definition at line 251 of file WriterInfo.h.

◆ coherent_samples_

Atomic<ACE_UINT32> OpenDDS::DCPS::WriterInfo::coherent_samples_

private

Number of received coherent changes in active change set.

Definition at line 241 of file WriterInfo.h.

◆ delivering_historic_samples_

bool OpenDDS::DCPS::WriterInfo::delivering_historic_samples_

private

Definition at line 222 of file WriterInfo.h.

◆ delivering_historic_samples_cv_

ConditionVariable<ACE_Thread_Mutex> OpenDDS::DCPS::WriterInfo::delivering_historic_samples_cv_

private

Definition at line 223 of file WriterInfo.h.

◆ group_coherent_

bool OpenDDS::DCPS::WriterInfo::group_coherent_

private

Data to support GROUP access scope.

Definition at line 249 of file WriterInfo.h.

◆ group_coherent_samples_

GroupCoherentSamples OpenDDS::DCPS::WriterInfo::group_coherent_samples_

private

Definition at line 253 of file WriterInfo.h.

◆ handle_

DDS::InstanceHandle_t OpenDDS::DCPS::WriterInfo::handle_

private

The publication entity instance handle.

Definition at line 238 of file WriterInfo.h.

◆ historic_samples_timer_

long OpenDDS::DCPS::WriterInfo::historic_samples_timer_

private

Definition at line 211 of file WriterInfo.h.

◆ last_historic_seq_

SequenceNumber OpenDDS::DCPS::WriterInfo::last_historic_seq_

private

After receiving END_HISTORIC_SAMPLES, check for duplicates.

Definition at line 218 of file WriterInfo.h.

◆ last_liveliness_activity_time_

MonotonicTimePoint OpenDDS::DCPS::WriterInfo::last_liveliness_activity_time_

private

Timestamp of last write/dispose/assert_liveliness from this DataWriter.

Definition at line 208 of file WriterInfo.h.

◆ mutex_

ACE_Thread_Mutex OpenDDS::DCPS::WriterInfo::mutex_

mutableprivate

Definition at line 205 of file WriterInfo.h.

◆ owner_evaluated_

OwnerEvaluateFlags OpenDDS::DCPS::WriterInfo::owner_evaluated_

private

Definition at line 245 of file WriterInfo.h.

◆ publisher_id_

GUID_t OpenDDS::DCPS::WriterInfo::publisher_id_

private

Definition at line 250 of file WriterInfo.h.

◆ reader_

WeakRcHandle<WriterInfoListener> OpenDDS::DCPS::WriterInfo::reader_

private

The DataReader owning this WriterInfo.

Definition at line 229 of file WriterInfo.h.

◆ state_

WriterState OpenDDS::DCPS::WriterInfo::state_

private

State of the writer.

Definition at line 226 of file WriterInfo.h.

◆ waiting_for_end_historic_samples_

bool OpenDDS::DCPS::WriterInfo::waiting_for_end_historic_samples_

private

Definition at line 220 of file WriterInfo.h.

◆ writer_coherent_samples_

WriterCoherentSample OpenDDS::DCPS::WriterInfo::writer_coherent_samples_

private

Definition at line 252 of file WriterInfo.h.

◆ writer_id_

GUID_t OpenDDS::DCPS::WriterInfo::writer_id_

private

DCPSInfoRepo ID of the DataWriter.

Definition at line 232 of file WriterInfo.h.

◆ writer_qos_

DDS::DataWriterQos OpenDDS::DCPS::WriterInfo::writer_qos_

private

Writer qos.

Definition at line 235 of file WriterInfo.h.

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

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Friends

Additional Inherited Members

Detailed Description

Member Enumeration Documentation

◆ TimerState

◆ WriterState

Constructor & Destructor Documentation

◆ WriterInfo()

Member Function Documentation

◆ add_coherent_samples()

◆ cancel_historic_samples_timer()

◆ check_activity()

◆ check_end_historic_samples()

◆ check_historic()

◆ clear_owner_evaluated()

◆ coherent_change()

◆ coherent_change_received()

◆ finished_delivering_historic()

◆ get_state_str()

◆ group_coherent()

◆ handle() [1/2]

◆ handle() [2/2]

◆ is_owner_evaluated()

◆ last_historic_seq() [1/2]

◆ last_historic_seq() [2/2]

◆ OPENDDS_MAP() [1/2]

◆ OPENDDS_MAP() [2/2]

◆ publisher_id()

◆ received_activity()

◆ removed()

◆ reset_coherent_info()

◆ schedule_historic_samples_timer()

◆ set_group_info()

◆ set_owner_evaluated()

◆ state() [1/2]

◆ state() [2/2]

◆ waiting_for_end_historic_samples() [1/2]

◆ waiting_for_end_historic_samples() [2/2]

◆ writer_id()

◆ writer_qos_ownership_strength() [1/2]

◆ writer_qos_ownership_strength() [2/2]

Friends And Related Function Documentation

◆ WriteInfoListner

Member Data Documentation

◆ coherent_sample_sequence_

◆ coherent_samples_

◆ delivering_historic_samples_

◆ delivering_historic_samples_cv_

◆ group_coherent_

◆ group_coherent_samples_

◆ handle_

◆ historic_samples_timer_

◆ last_historic_seq_

◆ last_liveliness_activity_time_

◆ mutex_

◆ owner_evaluated_

◆ publisher_id_

◆ reader_

◆ state_

◆ waiting_for_end_historic_samples_

◆ writer_coherent_samples_

◆ writer_id_

◆ writer_qos_