OpenDDS::DCPS::DataReaderRemoteImpl Class Reference

Implements the OpenDDS::DCPS::ReaderRemote interface that is used to add and remove associations. More...

#include <DataReaderRemoteImpl.h>

Collaboration diagram for OpenDDS::DCPS::DataReaderRemoteImpl:

[legend]List of all members.

Public Member Functions
	DataReaderRemoteImpl (DataReaderCallbacks *parent)
virtual	~DataReaderRemoteImpl ()
virtual void	add_association (const RepoId &yourId, const WriterAssociation &writer, bool active)
virtual void	association_complete (const RepoId &remote_id)
virtual void	remove_associations (const WriterIdSeq &writers, CORBA::Boolean callback)
virtual void	update_incompatible_qos (const IncompatibleQosStatus &status)
void	detach_parent ()
Private Attributes
DataReaderCallbacks *	parent_
ACE_Thread_Mutex	mutex_

---

Detailed Description

Implements the OpenDDS::DCPS::ReaderRemote interface that is used to add and remove associations.

Definition at line 33 of file DataReaderRemoteImpl.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::DataReaderRemoteImpl::DataReaderRemoteImpl

(

DataReaderCallbacks *

parent

)

[explicit]

Definition at line 14 of file DataReaderRemoteImpl.cpp.

                                                                      :
    parent_(parent)
{
}

OpenDDS::DCPS::DataReaderRemoteImpl::~DataReaderRemoteImpl

(

)

[virtual]

Definition at line 21 of file DataReaderRemoteImpl.cpp.

{
}

---

Member Function Documentation

void OpenDDS::DCPS::DataReaderRemoteImpl::add_association	(	const RepoId &	yourId,
		const WriterAssociation &	writer,
		bool	active
	)			[virtual]

Definition at line 44 of file DataReaderRemoteImpl.cpp.

References OpenDDS::DCPS::DataReaderCallbacks::add_association(), OpenDDS::DCPS::getDataReader(), and parent_.

{
  DataReaderCallbacks* parent = 0;
  DDS::DataReader_var drv;
  {
    ACE_GUARD(ACE_Thread_Mutex, g, this->mutex_);
    drv = getDataReader(this->parent_);
    parent = this->parent_;
  }
  if (parent) {
    parent->add_association(yourId, writer, active);
  }
}

void OpenDDS::DCPS::DataReaderRemoteImpl::association_complete

(

const RepoId &

remote_id

)

[virtual]

Definition at line 61 of file DataReaderRemoteImpl.cpp.

References OpenDDS::DCPS::DataReaderCallbacks::association_complete(), OpenDDS::DCPS::getDataReader(), and parent_.

{
  DataReaderCallbacks* parent = 0;
  DDS::DataReader_var drv;
  {
    ACE_GUARD(ACE_Thread_Mutex, g, this->mutex_);
    drv = getDataReader(this->parent_);
    parent = this->parent_;
  }
  if (parent) {
    parent->association_complete(remote_id);
  }
}

void OpenDDS::DCPS::DataReaderRemoteImpl::detach_parent

(

)

Definition at line 26 of file DataReaderRemoteImpl.cpp.

References parent_.

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::removeDataReaderRemote().

{
  ACE_GUARD(ACE_Thread_Mutex, g, this->mutex_);
  this->parent_ = 0;
}

void OpenDDS::DCPS::DataReaderRemoteImpl::remove_associations	(	const WriterIdSeq &	writers,
		CORBA::Boolean	callback
	)			[virtual]

Definition at line 76 of file DataReaderRemoteImpl.cpp.

References OpenDDS::DCPS::getDataReader(), parent_, and OpenDDS::DCPS::DataReaderCallbacks::remove_associations().

{
  DataReaderCallbacks* parent = 0;
  DDS::DataReader_var drv;
  {
    ACE_GUARD(ACE_Thread_Mutex, g, this->mutex_);
    drv = getDataReader(this->parent_);
    parent = this->parent_;
  }
  if (parent) {
    parent->remove_associations(writers, notify_lost);
  }
}

void OpenDDS::DCPS::DataReaderRemoteImpl::update_incompatible_qos

(

const IncompatibleQosStatus &

status

)

[virtual]

Definition at line 92 of file DataReaderRemoteImpl.cpp.

References OpenDDS::DCPS::getDataReader(), parent_, and OpenDDS::DCPS::DataReaderCallbacks::update_incompatible_qos().

{
  DataReaderCallbacks* parent = 0;
  DDS::DataReader_var drv;
  {
    ACE_GUARD(ACE_Thread_Mutex, g, this->mutex_);
    drv = getDataReader(this->parent_);
    parent = this->parent_;
  }
  if (parent) {
    parent->update_incompatible_qos(status);
  }
}

---

Member Data Documentation

ACE_Thread_Mutex OpenDDS::DCPS::DataReaderRemoteImpl::mutex_ [private]

Definition at line 56 of file DataReaderRemoteImpl.h.

DataReaderCallbacks* OpenDDS::DCPS::DataReaderRemoteImpl::parent_ [private]

Definition at line 55 of file DataReaderRemoteImpl.h.

Referenced by add_association(), association_complete(), detach_parent(), remove_associations(), and update_incompatible_qos().

---

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

• DataReaderRemoteImpl.h
• DataReaderRemoteImpl.cpp

---