#include <InternalDataWriter.h>

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

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

[legend]

Classes
struct	SampleHolder

Public Types
typedef RcHandle< InternalDataReader< T > >	InternalDataReader_rch

typedef WeakRcHandle< InternalDataReader< T > >	InternalDataReader_wrch

Public Member Functions
	InternalDataWriter (bool durable)

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	register_instance (const T &sample)

void	write (const T &sample)

void	unregister_instance (const T &sample)

void	dispose (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 bool	durable_

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 26 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 28 of file InternalDataWriter.h.

◆ InternalDataReader_wrch

template<typename T>

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

Definition at line 29 of file InternalDataWriter.h.

Constructor & Destructor Documentation

◆ InternalDataWriter()

template<typename T>

OpenDDS::DCPS::InternalDataWriter< T >::InternalDataWriter ( bool durable )

inlineexplicit

Definition at line 31 of file InternalDataWriter.h.

32 : durable_(durable)

33 {}

OpenDDS::DCPS::InternalDataWriter::durable_

const bool durable_

Definition: InternalDataWriter.h:144

Member Function Documentation

◆ add_reader()

template<typename T>

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

inline

Definition at line 37 of file InternalDataWriter.h.

   {
     ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
     readers_.insert(reader);
 
     if (durable_ && reader->durable()) {
       for (typename InstanceMap::const_iterator pos = instance_map_.begin(), limit = instance_map_.end();
            pos != limit; ++pos) {
         if (pos->second.valid_data) {
           reader->write(static_rchandle_cast<InternalEntity>(rchandle_from(this)), pos->second.sample);
         } else {
           reader->register_instance(static_rchandle_cast<InternalEntity>(rchandle_from(this)), pos->first);
         }
       }
     }
   }

◆ dispose()

template<typename T>

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

inline

Definition at line 126 of file InternalDataWriter.h.

   {
     ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
 
     if (durable_) {
       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) {
         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 62 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

Referenced by OpenDDS::DCPS::InternalDataWriter< T >::SampleHolder::SampleHolder().

◆ 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 68 of file InternalDataWriter.h.

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

◆ register_instance()

template<typename T>

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

inline

Definition at line 76 of file InternalDataWriter.h.

   {
     ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
 
     if (durable_) {
       instance_map_.insert(std::make_pair(sample, SampleHolder()));
     }
 
     for (typename ReaderSet::const_iterator pos = readers_.begin(), limit = readers_.end(); pos != limit; ++pos) {
       InternalDataReader_rch reader = pos->lock();
       if (reader) {
         reader->register_instance(static_rchandle_cast<InternalEntity>(rchandle_from(this)), sample);
       }
     }
   }

◆ remove_reader()

template<typename T>

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

inline

Definition at line 54 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)));
     }
   }

◆ unregister_instance()

template<typename T>

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

inline

Definition at line 110 of file InternalDataWriter.h.

   {
     ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
 
     if (durable_) {
       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) {
         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 (durable_) {
       const std::pair<typename InstanceMap::iterator, bool> p = instance_map_.insert(std::make_pair(sample, SampleHolder()));
       p.first->second.sample = sample;
       p.first->second.valid_data = true;
     }
 
     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);
       }
     }
   }