OpenDDS::DCPS::DataReaderRemoteImpl Class Reference

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

#include <DataReaderRemoteImpl.h>

Inheritance diagram for OpenDDS::DCPS::DataReaderRemoteImpl:

Collaboration diagram for OpenDDS::DCPS::DataReaderRemoteImpl:

Public Member Functions
	DataReaderRemoteImpl (DataReaderCallbacks &parent)
virtual	~DataReaderRemoteImpl ()
virtual void	add_association (const GUID_t &yourId, const WriterAssociation &writer, bool active)
virtual void	remove_associations (const WriterIdSeq &writers, CORBA::Boolean callback)
virtual void	update_incompatible_qos (const IncompatibleQosStatus &status)
void	detach_parent ()

Private Attributes
WeakRcHandle< DataReaderCallbacks >	parent_

Detailed Description

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

Definition at line 34 of file DataReaderRemoteImpl.h.

Constructor & Destructor Documentation

DataReaderRemoteImpl()

OpenDDS::DCPS::DataReaderRemoteImpl::DataReaderRemoteImpl ( DataReaderCallbacks &  parent )

explicit

Definition at line 19 of file DataReaderRemoteImpl.cpp.

  : parent_(parent)
{
}

~DataReaderRemoteImpl()

OpenDDS::DCPS::DataReaderRemoteImpl::~DataReaderRemoteImpl ( )

virtual

Definition at line 26 of file DataReaderRemoteImpl.cpp.

{
}

Member Function Documentation

add_association()

void OpenDDS::DCPS::DataReaderRemoteImpl::add_association ( const GUID_t &  yourId, const WriterAssociation &  writer, bool  active  )

virtual

Definition at line 36 of file DataReaderRemoteImpl.cpp.

References ACE_DEBUG, ACE_TEXT(), OpenDDS::DCPS::LogGuid::c_str(), OpenDDS::DCPS::DCPS_debug_level, LM_DEBUG, OpenDDS::DCPS::WeakRcHandle< T >::lock(), parent_, and OpenDDS::DCPS::WriterAssociation::writerId.

{
  if (DCPS_debug_level) {
    LogGuid writer_log(yourId);
    LogGuid reader_log(writer.writerId);
    ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) DataReaderRemoteImpl::add_association - ")
               ACE_TEXT("local %C remote %C\n"),
               writer_log.c_str(),
               reader_log.c_str()));
  }

  // the local copy of parent_ is necessary to prevent race condition
  RcHandle<DataReaderCallbacks> parent = parent_.lock();
  if (parent) {
    parent->add_association(yourId, writer, active);
  }
}

detach_parent()

void OpenDDS::DCPS::DataReaderRemoteImpl::detach_parent

(

)

Definition at line 31 of file DataReaderRemoteImpl.cpp.

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

{
}

remove_associations()

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

virtual

Definition at line 57 of file DataReaderRemoteImpl.cpp.

References OpenDDS::DCPS::WeakRcHandle< T >::lock(), and parent_.

{
  // the local copy of parent_ is necessary to prevent race condition
  RcHandle<DataReaderCallbacks> parent = parent_.lock();
  if (parent) {
    parent->remove_associations(writers, notify_lost);
  }
}

update_incompatible_qos()

void OpenDDS::DCPS::DataReaderRemoteImpl::update_incompatible_qos ( const IncompatibleQosStatus &  status )

virtual

Definition at line 68 of file DataReaderRemoteImpl.cpp.

References OpenDDS::DCPS::WeakRcHandle< T >::lock(), OPENDDS_END_VERSIONED_NAMESPACE_DECL, and parent_.

{
  // the local copy of parent_ is necessary to prevent race condition
  RcHandle<DataReaderCallbacks> parent = parent_.lock();
  if (parent) {
    parent->update_incompatible_qos(status);
  }
}

Member Data Documentation

parent_

WeakRcHandle<DataReaderCallbacks> OpenDDS::DCPS::DataReaderRemoteImpl::parent_

private

Definition at line 54 of file DataReaderRemoteImpl.h.

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

---

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

• DataReaderRemoteImpl.h
• DataReaderRemoteImpl.cpp