OpenDDS::DCPS::InternalDataReaderListener< T > Class Template Reference

#include <InternalDataReaderListener.h>

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

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

Classes
class	ListenerJob

Public Types
typedef RcHandle< InternalDataReader< T > >	InternalDataReader_rch

Public Member Functions
	InternalDataReaderListener ()
	InternalDataReaderListener (JobQueue_rch job_queue)
void	job_queue (JobQueue_rch job_queue)
virtual void	on_data_available (InternalDataReader_rch reader)=0
InternalDataReader Interface
void	schedule (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 Types
typedef WeakRcHandle< InternalDataReader< T > >	Reader

Private Member Functions
typedef	OPENDDS_SET (Reader) ReaderSet
void	execute ()

Private Attributes
JobPtr	job_
JobQueue_wrch	job_queue_
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::InternalDataReaderListener< T >

Definition at line 28 of file InternalDataReaderListener.h.

Member Typedef Documentation

InternalDataReader_rch

template<typename T>

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

Definition at line 30 of file InternalDataReaderListener.h.

Reader

template<typename T>

typedef WeakRcHandle<InternalDataReader<T> > OpenDDS::DCPS::InternalDataReaderListener< T >::Reader

private

Definition at line 85 of file InternalDataReaderListener.h.

Constructor & Destructor Documentation

InternalDataReaderListener() [1/2]

template<typename T>

OpenDDS::DCPS::InternalDataReaderListener< T >::InternalDataReaderListener ( )

inline

Definition at line 32 of file InternalDataReaderListener.h.

    : job_(make_rch<ListenerJob>(rchandle_from(this)))
  {}

InternalDataReaderListener() [2/2]

template<typename T>

OpenDDS::DCPS::InternalDataReaderListener< T >::InternalDataReaderListener ( JobQueue_rch  job_queue )

inlineexplicit

Definition at line 36 of file InternalDataReaderListener.h.

    : job_(make_rch<ListenerJob>(rchandle_from(this)))
    , job_queue_(job_queue)
  {}

Member Function Documentation

execute()

template<typename T>

void OpenDDS::DCPS::InternalDataReaderListener< T >::execute ( void  )

inlineprivate

Definition at line 91 of file InternalDataReaderListener.h.

  {
    ReaderSet readers;

    {
      ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
      std::swap(readers, readers_);
    }

    for (typename ReaderSet::const_iterator pos = readers.begin(), limit = readers.end();
         pos != limit; ++pos) {
      InternalDataReader_rch reader = pos->lock();
      if (reader) {
        on_data_available(reader);
      }
    }
  }

job_queue()

template<typename T>

void OpenDDS::DCPS::InternalDataReaderListener< T >::job_queue ( JobQueue_rch  job_queue )

inline

Definition at line 41 of file InternalDataReaderListener.h.

Referenced by OpenDDS::DCPS::InternalDataReaderListener< NetworkInterfaceAddress >::job_queue().

  {
    job_queue_ = job_queue;
  }

on_data_available()

template<typename T>

virtual void OpenDDS::DCPS::InternalDataReaderListener< T >::on_data_available ( InternalDataReader_rch  reader )

pure virtual

Referenced by OpenDDS::DCPS::InternalDataReaderListener< NetworkInterfaceAddress >::execute(), and OpenDDS::DCPS::InternalDataReaderListener< NetworkInterfaceAddress >::job_queue().

OPENDDS_SET()

template<typename T>

typedef OpenDDS::DCPS::InternalDataReaderListener< T >::OPENDDS_SET ( Reader  )

private

schedule()

template<typename T>

void OpenDDS::DCPS::InternalDataReaderListener< T >::schedule ( InternalDataReader_rch  reader )

inline

Definition at line 50 of file InternalDataReaderListener.h.

  {
    ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
    JobQueue_rch lock = job_queue_.lock();
    if (lock) {
      const bool enqueue = readers_.empty();
      readers_.insert(reader);
      if (enqueue) {
        lock->enqueue(job_);
      }
    }
  }

Member Data Documentation

job_

template<typename T>

JobPtr OpenDDS::DCPS::InternalDataReaderListener< T >::job_

private

Definition at line 83 of file InternalDataReaderListener.h.

Referenced by OpenDDS::DCPS::InternalDataReaderListener< NetworkInterfaceAddress >::schedule().

job_queue_

template<typename T>

JobQueue_wrch OpenDDS::DCPS::InternalDataReaderListener< T >::job_queue_

private

Definition at line 84 of file InternalDataReaderListener.h.

Referenced by OpenDDS::DCPS::InternalDataReaderListener< NetworkInterfaceAddress >::job_queue(), and OpenDDS::DCPS::InternalDataReaderListener< NetworkInterfaceAddress >::schedule().

mutex_

template<typename T>

ACE_Thread_Mutex OpenDDS::DCPS::InternalDataReaderListener< T >::mutex_

mutableprivate

Definition at line 89 of file InternalDataReaderListener.h.

Referenced by OpenDDS::DCPS::InternalDataReaderListener< NetworkInterfaceAddress >::schedule().

readers_

template<typename T>

ReaderSet OpenDDS::DCPS::InternalDataReaderListener< T >::readers_

private

Definition at line 87 of file InternalDataReaderListener.h.

Referenced by OpenDDS::DCPS::InternalDataReaderListener< NetworkInterfaceAddress >::schedule().

---

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

• InternalDataReaderListener.h