#include <InternalTopic.h>

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

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

[legend]

Public Types
typedef RcHandle< InternalDataWriter< T > >	InternalDataWriter_rch

typedef WeakRcHandle< InternalDataWriter< T > >	InternalDataWriter_wrch

typedef RcHandle< InternalDataReader< T > >	InternalDataReader_rch

typedef WeakRcHandle< InternalDataReader< T > >	InternalDataReader_wrch

Public Member Functions
void	connect (InternalDataWriter_rch writer)

void	connect (InternalDataReader_rch reader)

void	disconnect (InternalDataWriter_rch writer)

void	disconnect (InternalDataReader_rch reader)

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 (InternalDataWriter_wrch) WriterSet

typedef	OPENDDS_SET (InternalDataReader_wrch) ReaderSet

Private Attributes
WriterSet	writers_

ReaderSet	readers_

ACE_Thread_Mutex	mutex_

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

Detailed Description

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

Definition at line 28 of file InternalTopic.h.

Member Typedef Documentation

◆ InternalDataReader_rch

template<typename T>

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

Definition at line 32 of file InternalTopic.h.

◆ InternalDataReader_wrch

template<typename T>

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

Definition at line 33 of file InternalTopic.h.

◆ InternalDataWriter_rch

template<typename T>

typedef RcHandle<InternalDataWriter<T> > OpenDDS::DCPS::InternalTopic< T >::InternalDataWriter_rch

Definition at line 30 of file InternalTopic.h.

◆ InternalDataWriter_wrch

template<typename T>

typedef WeakRcHandle<InternalDataWriter<T> > OpenDDS::DCPS::InternalTopic< T >::InternalDataWriter_wrch

Definition at line 31 of file InternalTopic.h.

Member Function Documentation

◆ connect() [1/2]

template<typename T>

void OpenDDS::DCPS::InternalTopic< T >::connect ( InternalDataWriter_rch writer )

inline

Definition at line 35 of file InternalTopic.h.

   {
     ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
     const std::pair<typename WriterSet::iterator, bool> p = writers_.insert(writer);
 
     if (p.second) {
       for (typename ReaderSet::const_iterator pos = readers_.begin(), limit = readers_.end(); pos != limit; ++pos) {
         InternalDataReader_rch reader = pos->lock();
         if (reader) {
           writer->add_reader(reader);
         }
       }
     }
   }

◆ connect() [2/2]

template<typename T>

void OpenDDS::DCPS::InternalTopic< T >::connect ( InternalDataReader_rch reader )

inline

Definition at line 50 of file InternalTopic.h.

   {
     ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
     const std::pair<typename ReaderSet::iterator, bool> p = readers_.insert(reader);
 
     if (p.second) {
       for (typename WriterSet::const_iterator pos = writers_.begin(), limit = writers_.end(); pos != limit; ++pos) {
         InternalDataWriter_rch writer = pos->lock();
         if (writer) {
           writer->add_reader(reader);
         }
       }
     }
   }

◆ disconnect() [1/2]

template<typename T>

void OpenDDS::DCPS::InternalTopic< T >::disconnect ( InternalDataWriter_rch writer )

inline

Definition at line 65 of file InternalTopic.h.

   {
     ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
 
     if (writers_.erase(writer)) {
       for (typename ReaderSet::const_iterator pos = readers_.begin(), limit = readers_.end(); pos != limit; ++pos) {
         InternalDataReader_rch reader = pos->lock();
         if (reader) {
           writer->remove_reader(reader);
         }
       }
     }
   }

◆ disconnect() [2/2]

template<typename T>

void OpenDDS::DCPS::InternalTopic< T >::disconnect ( InternalDataReader_rch reader )

inline

Definition at line 79 of file InternalTopic.h.

   {
     ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
 
     if (readers_.erase(reader)) {
       for (typename WriterSet::const_iterator pos = writers_.begin(), limit = writers_.end(); pos != limit; ++pos) {
         InternalDataWriter_rch writer = pos->lock();
         if (writer) {
           writer->remove_reader(reader);
         }
       }
     }
   }