Struct that has information about an instance and the instance sample list. More...

#include <SubscriptionInstance.h>

Inheritance diagram for OpenDDS::DCPS::SubscriptionInstance:

Collaboration diagram for OpenDDS::DCPS::SubscriptionInstance:

[legend]

Public Member Functions
	SubscriptionInstance (const DataReaderImpl_rch &reader, const DDS::DataReaderQos &qos, ACE_Recursive_Thread_Mutex &lock, DDS::InstanceHandle_t handle, bool owns_handle)

virtual	~SubscriptionInstance ()

bool	matches (CORBA::ULong sample_states, CORBA::ULong view_states, CORBA::ULong instance_states) 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 InstanceState_rch	instance_state_
	Instance state for this instance. More...

SequenceNumber	last_sequence_
	Sequence number of the move recent data sample received. More...

ReceivedDataElementList	rcvd_samples_
	Data sample(s) in this instance. More...

CORBA::ULong	read_sample_count_

CORBA::ULong	not_read_sample_count_

CORBA::ULong	sample_states_

unique_ptr< ReceivedDataStrategy >	rcvd_strategy_
	ReceivedDataElementList strategy. More...

const DDS::InstanceHandle_t	instance_handle_
	The instance handle for the registered object. More...

const bool	owns_handle_

MonotonicTimePoint	last_sample_tv_

MonotonicTimePoint	cur_sample_tv_

MonotonicTimePoint	deadline_

MonotonicTimePoint	last_accepted_

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

Detailed Description

Struct that has information about an instance and the instance sample list.

Definition at line 36 of file SubscriptionInstance.h.

Constructor & Destructor Documentation

◆ SubscriptionInstance()

OpenDDS::DCPS::SubscriptionInstance::SubscriptionInstance	(	const DataReaderImpl_rch &	reader,
		const DDS::DataReaderQos &	qos,
		ACE_Recursive_Thread_Mutex &	lock,
		DDS::InstanceHandle_t	handle,
		bool	owns_handle
	)

Definition at line 17 of file SubscriptionInstance.cpp.

References ACE_ERROR, ACE_TEXT(), DDS::BY_RECEPTION_TIMESTAMP_DESTINATIONORDER_QOS, DDS::BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS, DDS::DataReaderQos::destination_order, DDS::DestinationOrderQosPolicy::kind, LM_ERROR, rcvd_samples_, and rcvd_strategy_.

   : instance_state_(make_rch<InstanceState>(ref(reader), ref(lock), handle))
   , rcvd_samples_(reader, instance_state_)
   , read_sample_count_(0)
   , not_read_sample_count_(0)
   , sample_states_(0)
   , instance_handle_(handle)
   , owns_handle_(owns_handle)
 {
   switch (qos.destination_order.kind) {
   case DDS::BY_RECEPTION_TIMESTAMP_DESTINATIONORDER_QOS:
     rcvd_strategy_.reset(new ReceptionDataStrategy(rcvd_samples_));
     break;
 
   case DDS::BY_SOURCE_TIMESTAMP_DESTINATIONORDER_QOS:
     rcvd_strategy_.reset(new SourceDataStrategy(rcvd_samples_));
     break;
   }
 
   if (!rcvd_strategy_) {
     ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: SubscriptionInstance: ")
                 ACE_TEXT("unable to allocate ReceiveDataStrategy!\n")));
   }
 }

◆ ~SubscriptionInstance()

OpenDDS::DCPS::SubscriptionInstance::~SubscriptionInstance ( )

virtual

Definition at line 47 of file SubscriptionInstance.cpp.

References OpenDDS::DCPS::InstanceState::data_reader(), instance_handle_, instance_state_, OpenDDS::DCPS::WeakRcHandle< T >::lock(), and owns_handle_.

 {
   if (owns_handle_) {
     const RcHandle<DataReaderImpl> reader = instance_state_->data_reader().lock();
     if (reader) {
       reader->return_handle(instance_handle_);
     }
   }
 }

Member Function Documentation

◆ matches()

bool OpenDDS::DCPS::SubscriptionInstance::matches	(	CORBA::ULong	sample_states,
		CORBA::ULong	view_states,
		CORBA::ULong	instance_states
	)		const

Definition at line 57 of file SubscriptionInstance.cpp.

References instance_state_, OpenDDS::DCPS::InstanceState::match(), OpenDDS::DCPS::ReceivedDataElementList::matches(), OPENDDS_END_VERSIONED_NAMESPACE_DECL, and rcvd_samples_.

 {
   return instance_state_->match(view_states, instance_states) && rcvd_samples_.matches(sample_states);
 }

Member Data Documentation

◆ cur_sample_tv_

MonotonicTimePoint OpenDDS::DCPS::SubscriptionInstance::cur_sample_tv_

Definition at line 71 of file SubscriptionInstance.h.

Referenced by OpenDDS::DCPS::DataReaderImpl::accept_sample_processing(), and OpenDDS::DCPS::DataReaderImpl::process_deadline().

◆ deadline_

MonotonicTimePoint OpenDDS::DCPS::SubscriptionInstance::deadline_

Definition at line 73 of file SubscriptionInstance.h.

Referenced by OpenDDS::DCPS::DataReaderImpl::cancel_deadline(), OpenDDS::DCPS::DataReaderImpl::process_deadline(), OpenDDS::DCPS::DataReaderImpl::reschedule_deadline(), and OpenDDS::DCPS::DataReaderImpl::schedule_deadline().

◆ instance_handle_

const DDS::InstanceHandle_t OpenDDS::DCPS::SubscriptionInstance::instance_handle_

The instance handle for the registered object.

Definition at line 65 of file SubscriptionInstance.h.

Referenced by OpenDDS::DCPS::DataReaderImpl::data_received(), OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >::finish_store_instance_data(), OpenDDS::DCPS::DataReaderImpl::ownership_filter_instance(), OpenDDS::DCPS::DataReaderImpl::process_deadline(), OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >::purge_data(), OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >::store_synthetic_data(), and ~SubscriptionInstance().

◆ instance_state_

const InstanceState_rch OpenDDS::DCPS::SubscriptionInstance::instance_state_

Instance state for this instance.

Definition at line 49 of file SubscriptionInstance.h.

◆ last_accepted_

MonotonicTimePoint OpenDDS::DCPS::SubscriptionInstance::last_accepted_

Definition at line 75 of file SubscriptionInstance.h.

Referenced by OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >::filter_delayed(), and OpenDDS::DCPS::DataReaderImpl::time_based_filter_instance().

◆ last_sample_tv_

MonotonicTimePoint OpenDDS::DCPS::SubscriptionInstance::last_sample_tv_

Definition at line 69 of file SubscriptionInstance.h.

Referenced by OpenDDS::DCPS::DataReaderImpl::accept_sample_processing(), OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >::filter_delayed(), and OpenDDS::DCPS::DataReaderImpl::process_deadline().

◆ last_sequence_

SequenceNumber OpenDDS::DCPS::SubscriptionInstance::last_sequence_

Sequence number of the move recent data sample received.

Definition at line 52 of file SubscriptionInstance.h.

Referenced by OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >::finish_store_instance_data().

◆ not_read_sample_count_

CORBA::ULong OpenDDS::DCPS::SubscriptionInstance::not_read_sample_count_

Definition at line 58 of file SubscriptionInstance.h.

◆ owns_handle_

const bool OpenDDS::DCPS::SubscriptionInstance::owns_handle_

Definition at line 67 of file SubscriptionInstance.h.

Referenced by ~SubscriptionInstance().

◆ rcvd_samples_

ReceivedDataElementList OpenDDS::DCPS::SubscriptionInstance::rcvd_samples_

Data sample(s) in this instance.

Definition at line 55 of file SubscriptionInstance.h.

◆ rcvd_strategy_

unique_ptr<ReceivedDataStrategy> OpenDDS::DCPS::SubscriptionInstance::rcvd_strategy_

ReceivedDataElementList strategy.

Definition at line 62 of file SubscriptionInstance.h.

Referenced by OpenDDS::DCPS::DataReaderImpl_T< DynamicSample >::finish_store_instance_data(), and SubscriptionInstance().

◆ read_sample_count_

CORBA::ULong OpenDDS::DCPS::SubscriptionInstance::read_sample_count_

Definition at line 57 of file SubscriptionInstance.h.

◆ sample_states_

CORBA::ULong OpenDDS::DCPS::SubscriptionInstance::sample_states_

Definition at line 59 of file SubscriptionInstance.h.

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

Public Member Functions

Public Attributes

Additional Inherited Members