#include <InternalDataWriter.h>

Inheritance diagram for OpenDDS::DCPS::InternalDataWriter< T >:

Collaboration diagram for OpenDDS::DCPS::InternalDataWriter< T >:

[legend]

Classes
class	SampleHolder

Public Types
typedef RcHandle< InternalDataReader< T > >	InternalDataReader_rch

typedef WeakRcHandle< InternalDataReader< T > >	InternalDataReader_wrch

Public Member Functions
	InternalDataWriter (const DDS::DataWriterQos &qos)

InternalTopic Interface
void	add_reader (InternalDataReader_rch reader)

void	remove_reader (InternalDataReader_rch reader)

bool	has_reader (InternalDataReader_rch reader)

InternalEntity_wrch	publication_handle ()

User Interface
void	write (const T &sample)

void	dispose (const T &sample)

void	unregister_instance (const T &sample)

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
typedef	OPENDDS_SET (InternalDataReader_wrch) ReaderSet

typedef	OPENDDS_MAP_T (T, SampleHolder) InstanceMap

Private Attributes
const DDS::DataWriterQos	qos_

ReaderSet	readers_

InstanceMap	instance_map_

ACE_Thread_Mutex	mutex_

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

Detailed Description

template<typename T>
class OpenDDS::DCPS::InternalDataWriter< T >

Definition at line 46 of file InternalDataWriter.h.

Member Typedef Documentation

◆ InternalDataReader_rch

template<typename T>

typedef RcHandle<InternalDataReader<T> > OpenDDS::DCPS::InternalDataWriter< T >::InternalDataReader_rch

Definition at line 48 of file InternalDataWriter.h.

◆ InternalDataReader_wrch

template<typename T>

typedef WeakRcHandle<InternalDataReader<T> > OpenDDS::DCPS::InternalDataWriter< T >::InternalDataReader_wrch

Definition at line 49 of file InternalDataWriter.h.

Constructor & Destructor Documentation

◆ InternalDataWriter()

template<typename T>

OpenDDS::DCPS::InternalDataWriter< T >::InternalDataWriter ( const DDS::DataWriterQos & qos )

inlineexplicit

Definition at line 51 of file InternalDataWriter.h.

52 : qos_(qos)

53 {}

OpenDDS::DCPS::InternalDataWriter::qos_

const DDS::DataWriterQos qos_

Definition: InternalDataWriter.h:149

Member Function Documentation

◆ add_reader()

template<typename T>

void OpenDDS::DCPS::InternalDataWriter< T >::add_reader ( InternalDataReader_rch reader )

inline

Definition at line 57 of file InternalDataWriter.h.

   {
     ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
     readers_.insert(reader);
 
     if (qos_.durability.kind == DDS::TRANSIENT_LOCAL_DURABILITY_QOS && reader->durable()) {
       for (typename InstanceMap::iterator pos = instance_map_.begin(), limit = instance_map_.end();
            pos != limit; ++pos) {
         pos->second.add_reader(reader, static_rchandle_cast<InternalEntity>(rchandle_from(this)));
       }
     }
   }

◆ dispose()

template<typename T>

void OpenDDS::DCPS::InternalDataWriter< T >::dispose ( const T & sample )

inline

Definition at line 109 of file InternalDataWriter.h.

   {
     ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
 
     if (qos_.durability.kind == DDS::TRANSIENT_LOCAL_DURABILITY_QOS) {
       typename InstanceMap::iterator pos = instance_map_.find(sample);
       if (pos != instance_map_.end()) {
         pos->second.dispose();
       }
     }
 
     for (typename ReaderSet::const_iterator pos = readers_.begin(), limit = readers_.end(); pos != limit; ++pos) {
       InternalDataReader_rch reader = pos->lock();
       if (reader) {
         reader->dispose(static_rchandle_cast<InternalEntity>(rchandle_from(this)), sample);
       }
     }
   }

◆ has_reader()

template<typename T>

bool OpenDDS::DCPS::InternalDataWriter< T >::has_reader ( InternalDataReader_rch reader )

inline

Definition at line 78 of file InternalDataWriter.h.

   {
     ACE_GUARD_RETURN(ACE_Thread_Mutex, g, mutex_, false);
     return readers_.count(reader);
   }

◆ OPENDDS_MAP_T()

template<typename T>

typedef OpenDDS::DCPS::InternalDataWriter< T >::OPENDDS_MAP_T	(	T	,
		SampleHolder
	)

private

◆ OPENDDS_SET()

template<typename T>

typedef OpenDDS::DCPS::InternalDataWriter< T >::OPENDDS_SET ( InternalDataReader_wrch )

private

◆ publication_handle()

template<typename T>

InternalEntity_wrch OpenDDS::DCPS::InternalDataWriter< T >::publication_handle ( )

inline

Definition at line 84 of file InternalDataWriter.h.

   {
     return static_rchandle_cast<InternalEntity>(rchandle_from(this));
   }

◆ remove_reader()

template<typename T>

void OpenDDS::DCPS::InternalDataWriter< T >::remove_reader ( InternalDataReader_rch reader )

inline

Definition at line 70 of file InternalDataWriter.h.

   {
     ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
     if (readers_.erase(reader)) {
       reader->remove_publication(static_rchandle_cast<InternalEntity>(rchandle_from(this)), qos_.writer_data_lifecycle.autodispose_unregistered_instances);
     }
   }

◆ unregister_instance()

template<typename T>

void OpenDDS::DCPS::InternalDataWriter< T >::unregister_instance ( const T & sample )

inline

Definition at line 128 of file InternalDataWriter.h.

   {
     ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
 
     if (qos_.durability.kind == DDS::TRANSIENT_LOCAL_DURABILITY_QOS) {
       instance_map_.erase(sample);
     }
 
     for (typename ReaderSet::const_iterator pos = readers_.begin(), limit = readers_.end(); pos != limit; ++pos) {
       InternalDataReader_rch reader = pos->lock();
       if (reader) {
         if (qos_.writer_data_lifecycle.autodispose_unregistered_instances) {
           reader->dispose(static_rchandle_cast<InternalEntity>(rchandle_from(this)), sample);
         }
         reader->unregister_instance(static_rchandle_cast<InternalEntity>(rchandle_from(this)), sample);
       }
     }
   }

◆ write()

template<typename T>

void OpenDDS::DCPS::InternalDataWriter< T >::write ( const T & sample )

inline

Definition at line 92 of file InternalDataWriter.h.

   {
     ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
 
     if (qos_.durability.kind == DDS::TRANSIENT_LOCAL_DURABILITY_QOS) {
       const std::pair<typename InstanceMap::iterator, bool> p = instance_map_.insert(std::make_pair(sample, SampleHolder()));
       p.first->second.write(sample, qos_);
     }
 
     for (typename ReaderSet::const_iterator pos = readers_.begin(), limit = readers_.end(); pos != limit; ++pos) {
       InternalDataReader_rch reader = pos->lock();
       if (reader) {
         reader->write(static_rchandle_cast<InternalEntity>(rchandle_from(this)), sample);
       }
     }
   }