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

#include <InternalDataReader.h>

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

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

Classes
class	Instance

Public Types
typedef RcHandle< InternalDataReaderListener< T > >	Listener_rch
typedef WeakRcHandle< InternalDataReaderListener< T > >	Listener_wrch

Public Member Functions
typedef	OPENDDS_VECTOR (T) SampleSequence
	InternalDataReader (const DDS::DataReaderQos qos, Listener_rch listener=Listener_rch())
InternalTopic and InternalWriter Interface
bool	durable () const
void	remove_publication (InternalEntity_wrch publication_handle, bool autodispose_unregistered_instances)
void	write (InternalEntity_wrch publication_handle, const T &sample)
void	dispose (InternalEntity_wrch publication_handle, const T &sample)
void	unregister_instance (InternalEntity_wrch publication_handle, const T &sample)
User Interface
void	set_listener (Listener_rch listener)
Listener_rch	get_listener () const
void	read (SampleSequence &samples, InternalSampleInfoSequence &infos, CORBA::Long max_samples, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
void	take (SampleSequence &samples, InternalSampleInfoSequence &infos, CORBA::Long max_samples, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
void	read_instance (SampleSequence &samples, InternalSampleInfoSequence &infos, CORBA::Long max_samples, const T &key, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
void	take_instance (SampleSequence &samples, InternalSampleInfoSequence &infos, CORBA::Long max_samples, const T &key, DDS::SampleStateMask sample_states, DDS::ViewStateMask view_states, DDS::InstanceStateMask instance_states)
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 (InternalEntity_wrch) PublicationSet
typedef	OPENDDS_MAP_T (T, Instance) InstanceMap

Private Attributes
const DDS::DataReaderQos	qos_
Listener_wrch	listener_
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::InternalDataReader< T >

Definition at line 95 of file InternalDataReader.h.

Member Typedef Documentation

Listener_rch

template<typename T>

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

Definition at line 98 of file InternalDataReader.h.

Listener_wrch

template<typename T>

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

Definition at line 99 of file InternalDataReader.h.

Constructor & Destructor Documentation

InternalDataReader()

template<typename T>

OpenDDS::DCPS::InternalDataReader< T >::InternalDataReader ( const DDS::DataReaderQos  qos, Listener_rch  listener = Listener_rch()  )

inlineexplicit

Definition at line 101 of file InternalDataReader.h.

    : qos_(qos)
    , listener_(listener)
  {}

Member Function Documentation

dispose()

template<typename T>

void OpenDDS::DCPS::InternalDataReader< T >::dispose ( InternalEntity_wrch  publication_handle, const T &  sample  )

inline

Definition at line 148 of file InternalDataReader.h.

  {
    ACE_GUARD(ACE_Thread_Mutex, g, mutex_);

    typename InstanceMap::iterator pos = instance_map_.find(sample);
    if (pos == instance_map_.end()) {
      return;
    }

    if (pos->second.dispose(publication_handle, qos_)) {
      const Listener_rch listener = listener_.lock();
      if (listener) {
        listener->schedule(rchandle_from(this));
      }
    }
  }

durable()

template<typename T>

bool OpenDDS::DCPS::InternalDataReader< T >::durable ( ) const

inline

Definition at line 109 of file InternalDataReader.h.

{ return qos_.durability.kind == DDS::TRANSIENT_LOCAL_DURABILITY_QOS; }

get_listener()

template<typename T>

Listener_rch OpenDDS::DCPS::InternalDataReader< T >::get_listener ( ) const

inline

Definition at line 191 of file InternalDataReader.h.

  {
    ACE_GUARD_RETURN(ACE_Thread_Mutex, g, mutex_, Listener_rch());
    return listener_.lock();
  }

OPENDDS_MAP_T()

template<typename T>

typedef OpenDDS::DCPS::InternalDataReader< T >::OPENDDS_MAP_T ( T  , Instance    )

private

OPENDDS_SET()

template<typename T>

typedef OpenDDS::DCPS::InternalDataReader< T >::OPENDDS_SET ( InternalEntity_wrch  )

private

OPENDDS_VECTOR()

template<typename T>

typedef OpenDDS::DCPS::InternalDataReader< T >::OPENDDS_VECTOR

(

T

)

read()

template<typename T>

void OpenDDS::DCPS::InternalDataReader< T >::read ( SampleSequence &  samples, InternalSampleInfoSequence &  infos, CORBA::Long  max_samples, DDS::SampleStateMask  sample_states, DDS::ViewStateMask  view_states, DDS::InstanceStateMask  instance_states  )

inline

Definition at line 197 of file InternalDataReader.h.

  {
    samples.clear();
    infos.clear();

    // TODO: Index to avoid the loop.
    ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
    for (typename InstanceMap::iterator pos = instance_map_.begin(), limit = instance_map_.end(); pos != limit; ) {
      pos->second.read(pos->first, samples, infos, max_samples, sample_states, view_states, instance_states);
      pos->second.purge_samples(qos_);
      if (pos->second.can_purge_instance(qos_)) {
        instance_map_.erase(pos++);
      } else {
        ++pos;
      }
    }
  }

read_instance()

template<typename T>

void OpenDDS::DCPS::InternalDataReader< T >::read_instance ( SampleSequence &  samples, InternalSampleInfoSequence &  infos, CORBA::Long  max_samples, const T &  key, DDS::SampleStateMask  sample_states, DDS::ViewStateMask  view_states, DDS::InstanceStateMask  instance_states  )

inline

Definition at line 243 of file InternalDataReader.h.

  {
    samples.clear();
    infos.clear();

    ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
    typename InstanceMap::iterator pos = instance_map_.find(key);
    if (pos != instance_map_.end()) {
      pos->second.read(pos->first, samples, infos, max_samples, sample_states, view_states, instance_states);
      pos->second.purge_samples(qos_);
      if (pos->second.can_purge_instance(qos_)) {
        instance_map_.erase(pos);
      }
    }
  }

remove_publication()

template<typename T>

void OpenDDS::DCPS::InternalDataReader< T >::remove_publication ( InternalEntity_wrch  publication_handle, bool  autodispose_unregistered_instances  )

inline

Definition at line 111 of file InternalDataReader.h.

  {
    ACE_GUARD(ACE_Thread_Mutex, g, mutex_);

    // FUTURE: Index by publication_handle to avoid the loop.
    bool schedule = false;
    for (typename InstanceMap::iterator pos = instance_map_.begin(), limit = instance_map_.end(); pos != limit; ++pos) {
      if (autodispose_unregistered_instances && pos->second.dispose(publication_handle, qos_)) {
        schedule = true;
      }
      if (pos->second.unregister_instance(publication_handle, qos_)) {
        schedule = true;
      }
    }

    if (schedule) {
      const Listener_rch listener = listener_.lock();
      if (listener) {
        listener->schedule(rchandle_from(this));
        // TODO: If the listener doesn't do anything, then clean up then possibly clean up the instance.
      }
    }
  }

set_listener()

template<typename T>

void OpenDDS::DCPS::InternalDataReader< T >::set_listener ( Listener_rch  listener )

inline

Definition at line 185 of file InternalDataReader.h.

  {
    ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
    listener_ = listener;
  }

take()

template<typename T>

void OpenDDS::DCPS::InternalDataReader< T >::take ( SampleSequence &  samples, InternalSampleInfoSequence &  infos, CORBA::Long  max_samples, DDS::SampleStateMask  sample_states, DDS::ViewStateMask  view_states, DDS::InstanceStateMask  instance_states  )

inline

Definition at line 220 of file InternalDataReader.h.

  {
    samples.clear();
    infos.clear();

    // TODO: Index to avoid the loop.
    ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
    for (typename InstanceMap::iterator pos = instance_map_.begin(), limit = instance_map_.end(); pos != limit; ) {
      pos->second.take(pos->first, samples, infos, max_samples, sample_states, view_states, instance_states);
      pos->second.purge_samples(qos_);
      if (pos->second.can_purge_instance(qos_)) {
        instance_map_.erase(pos++);
      } else {
        ++pos;
      }
    }
  }

take_instance()

template<typename T>

void OpenDDS::DCPS::InternalDataReader< T >::take_instance ( SampleSequence &  samples, InternalSampleInfoSequence &  infos, CORBA::Long  max_samples, const T &  key, DDS::SampleStateMask  sample_states, DDS::ViewStateMask  view_states, DDS::InstanceStateMask  instance_states  )

inline

Definition at line 265 of file InternalDataReader.h.

  {
    samples.clear();
    infos.clear();

    ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
    typename InstanceMap::iterator pos = instance_map_.find(key);
    if (pos != instance_map_.end()) {
      pos->second.take(pos->first, samples, infos, max_samples, sample_states, view_states, instance_states);
      pos->second.purge_samples(qos_);
      if (pos->second.can_purge_instance(qos_)) {
        instance_map_.erase(pos);
      }
    }
  }

unregister_instance()

template<typename T>

void OpenDDS::DCPS::InternalDataReader< T >::unregister_instance ( InternalEntity_wrch  publication_handle, const T &  sample  )

inline

Definition at line 165 of file InternalDataReader.h.

  {
    ACE_GUARD(ACE_Thread_Mutex, g, mutex_);

    typename InstanceMap::iterator pos = instance_map_.find(sample);
    if (pos == instance_map_.end()) {
      return;
    }

    if (pos->second.unregister_instance(publication_handle, qos_)) {
      const Listener_rch listener = listener_.lock();
      if (listener) {
        listener->schedule(rchandle_from(this));
      }
    }
  }

write()

template<typename T>

void OpenDDS::DCPS::InternalDataReader< T >::write ( InternalEntity_wrch  publication_handle, const T &  sample  )

inline

Definition at line 135 of file InternalDataReader.h.

  {
    ACE_GUARD(ACE_Thread_Mutex, g, mutex_);

    const std::pair<typename InstanceMap::iterator, bool> p = instance_map_.insert(std::make_pair(sample, Instance()));
    p.first->second.write(publication_handle, sample, qos_);

    const Listener_rch listener = listener_.lock();
    if (listener) {
      listener->schedule(rchandle_from(this));
    }
  }

Member Data Documentation

instance_map_

template<typename T>

InstanceMap OpenDDS::DCPS::InternalDataReader< T >::instance_map_

private

Definition at line 563 of file InternalDataReader.h.

listener_

template<typename T>

Listener_wrch OpenDDS::DCPS::InternalDataReader< T >::listener_

private

Definition at line 293 of file InternalDataReader.h.

mutex_

template<typename T>

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

mutableprivate

Definition at line 565 of file InternalDataReader.h.

qos_

template<typename T>

const DDS::DataReaderQos OpenDDS::DCPS::InternalDataReader< T >::qos_

private

Definition at line 289 of file InternalDataReader.h.

---

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

• InternalDataReader.h