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
struct	Instance

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

Public Member Functions
typedef	OPENDDS_VECTOR (T) SampleSequence
	InternalDataReader (bool durable=false, Listener_rch listener=Listener_rch())
InternalTopic and InternalWriter Interface
bool	durable () const
void	remove_publication (InternalEntity_wrch publication_handle)
void	register_instance (InternalEntity_wrch publication_handle, const T &sample)
void	write (InternalEntity_wrch publication_handle, const T &sample)
void	unregister_instance (InternalEntity_wrch publication_handle, const T &sample)
void	dispose (InternalEntity_wrch publication_handle, const T &sample)
User Interface
void	set_listener (Listener_rch listener)
Listener_rch	get_listener () const
void	take (SampleSequence &samples, InternalSampleInfoSequence &infos)
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 bool	durable_
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 58 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 61 of file InternalDataReader.h.

Listener_wrch

template<typename T>

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

Definition at line 62 of file InternalDataReader.h.

Constructor & Destructor Documentation

InternalDataReader()

template<typename T>

OpenDDS::DCPS::InternalDataReader< T >::InternalDataReader ( bool  durable = false, Listener_rch  listener = Listener_rch()  )

inlineexplicit

Definition at line 64 of file InternalDataReader.h.

    : durable_(durable)
    , 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 153 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;
    }

    pos->second.samples.push_back(sample);
    pos->second.infos.push_back(InternalSampleInfo(ISIK_DISPOSE, publication_handle));
    pos->second.instance_state = DDS::NOT_ALIVE_DISPOSED_INSTANCE_STATE;

    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 72 of file InternalDataReader.h.

{ return durable_; }

get_listener()

template<typename T>

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

inline

Definition at line 181 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

)

register_instance()

template<typename T>

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

inline

Definition at line 92 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()));
    const std::pair<PublicationSet::iterator, bool> q = p.first->second.publication_set.insert(publication_handle);
    if (q.second) {
      // New publication.
      p.first->second.samples.push_back(sample);
      p.first->second.infos.push_back(InternalSampleInfo(ISIK_REGISTER, publication_handle));

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

    if (p.second) {
      p.first->second.view_state = DDS::NEW_VIEW_STATE;
    }
    p.first->second.instance_state = DDS::ALIVE_INSTANCE_STATE;
  }

remove_publication()

template<typename T>

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

inline

Definition at line 74 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 (pos->second.unregister_instance(pos->first, publication_handle)) {
        schedule = true;
      }
    }

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

set_listener()

template<typename T>

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

inline

Definition at line 175 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  )

inline

Definition at line 187 of file InternalDataReader.h.

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

    ACE_GUARD(ACE_Thread_Mutex, g, mutex_);
    for (typename InstanceMap::iterator pos = instance_map_.begin(), limit = instance_map_.end(); pos != limit; ) {
      samples.insert(samples.end(), pos->second.samples.begin(), pos->second.samples.end());
      pos->second.samples.clear();
      infos.insert(infos.end(), pos->second.infos.begin(), pos->second.infos.end());
      pos->second.infos.clear();

      pos->second.view_state = DDS::NOT_NEW_VIEW_STATE;

      if (pos->second.instance_state != DDS::ALIVE_INSTANCE_STATE) {
        instance_map_.erase(pos++);
      } else {
        ++pos;
      }
    }
  }

unregister_instance()

template<typename T>

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

inline

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

    const Listener_rch listener = listener_.lock();
    if (pos->second.unregister_instance(sample, publication_handle) && 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 115 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.publication_set.insert(publication_handle);
    p.first->second.samples.push_back(sample);
    p.first->second.infos.push_back(InternalSampleInfo(ISIK_SAMPLE, publication_handle));

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

    if (p.second ||
        (p.first->second.view_state == DDS::NOT_NEW_VIEW_STATE &&
         p.first->second.instance_state != DDS::ALIVE_INSTANCE_STATE)) {
      p.first->second.view_state = DDS::NEW_VIEW_STATE;
    }

    p.first->second.instance_state = DDS::ALIVE_INSTANCE_STATE;
  }

Member Data Documentation

durable_

template<typename T>

const bool OpenDDS::DCPS::InternalDataReader< T >::durable_

private

Definition at line 211 of file InternalDataReader.h.

instance_map_

template<typename T>

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

private

Definition at line 246 of file InternalDataReader.h.

listener_

template<typename T>

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

private

Definition at line 215 of file InternalDataReader.h.

mutex_

template<typename T>

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

mutableprivate

Definition at line 248 of file InternalDataReader.h.

---

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

• InternalDataReader.h