OpenDDS::DCPS::DataWriterRemoteImpl Class Reference

Implements the OpenDDS::DCPS::DataWriterRemote interface. More...

#include <DataWriterRemoteImpl.h>

Collaboration diagram for OpenDDS::DCPS::DataWriterRemoteImpl:

[legend]

List of all members.

Public Member Functions
	DataWriterRemoteImpl (DataWriterCallbacks &parent)
virtual	~DataWriterRemoteImpl ()
virtual void	add_association (const RepoId &yourId, const ReaderAssociation &readers, bool active)
virtual void	association_complete (const RepoId &remote_id)
virtual void	remove_associations (const ReaderIdSeq &readers, CORBA::Boolean callback)
virtual void	update_incompatible_qos (const IncompatibleQosStatus &status)
virtual void	update_subscription_params (const RepoId &readerId, const DDS::StringSeq &exprParams)
void	detach_parent ()
Private Attributes
WeakRcHandle< DataWriterCallbacks >	parent_

---

Detailed Description

Implements the OpenDDS::DCPS::DataWriterRemote interface.

Definition at line 31 of file DataWriterRemoteImpl.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::DataWriterRemoteImpl::DataWriterRemoteImpl

(

DataWriterCallbacks &

parent

)

[explicit]

Definition at line 17 of file DataWriterRemoteImpl.cpp.

  : parent_(parent)
{
}

OpenDDS::DCPS::DataWriterRemoteImpl::~DataWriterRemoteImpl

(

)

[virtual]

Definition at line 24 of file DataWriterRemoteImpl.cpp.

{
}

---

Member Function Documentation

void OpenDDS::DCPS::DataWriterRemoteImpl::add_association	(	const RepoId &	yourId,
		const ReaderAssociation &	readers,
		bool	active
	)			[virtual]

Definition at line 34 of file DataWriterRemoteImpl.cpp.

References ACE_TEXT(), OpenDDS::DCPS::DCPS_debug_level, OpenDDS::DCPS::RcHandle< T >::in(), LM_DEBUG, OpenDDS::DCPS::WeakRcHandle< T >::lock(), parent_, and OpenDDS::DCPS::ReaderAssociation::readerId.

{
  if (DCPS_debug_level) {
    GuidConverter writer_converter(yourId);
    GuidConverter reader_converter(reader.readerId);
    ACE_DEBUG((LM_DEBUG, ACE_TEXT("(%P|%t) DataWriterRemoteImpl::add_association - ")
               ACE_TEXT("local %C remote %C\n"),
               std::string(writer_converter).c_str(),
               std::string(reader_converter).c_str()));
  }

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

Here is the call graph for this function:

void OpenDDS::DCPS::DataWriterRemoteImpl::association_complete

(

const RepoId &

remote_id

)

[virtual]

Definition at line 55 of file DataWriterRemoteImpl.cpp.

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

{
  // the local copy of parent_ is necessary to prevent race condition
  RcHandle<DataWriterCallbacks> parent = parent_.lock();
  if (parent.in()) {
    parent->association_complete(remote_id);
  }
}

Here is the call graph for this function:

void OpenDDS::DCPS::DataWriterRemoteImpl::detach_parent

(

)

Definition at line 29 of file DataWriterRemoteImpl.cpp.

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

{
}

Here is the caller graph for this function:

void OpenDDS::DCPS::DataWriterRemoteImpl::remove_associations	(	const ReaderIdSeq &	readers,
		CORBA::Boolean	callback
	)			[virtual]

Definition at line 65 of file DataWriterRemoteImpl.cpp.

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

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

Here is the call graph for this function:

void OpenDDS::DCPS::DataWriterRemoteImpl::update_incompatible_qos

(

const IncompatibleQosStatus &

status

)

[virtual]

Definition at line 76 of file DataWriterRemoteImpl.cpp.

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

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

Here is the call graph for this function:

void OpenDDS::DCPS::DataWriterRemoteImpl::update_subscription_params	(	const RepoId &	readerId,
		const DDS::StringSeq &	exprParams
	)			[virtual]

Definition at line 87 of file DataWriterRemoteImpl.cpp.

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

{
  // the local copy of parent_ is necessary to prevent race condition
  RcHandle<DataWriterCallbacks> parent = parent_.lock();
  if (parent.in()) {
    parent->update_subscription_params(readerId, params);
  }
}

Here is the call graph for this function:

---

Member Data Documentation

WeakRcHandle<DataWriterCallbacks> OpenDDS::DCPS::DataWriterRemoteImpl::parent_ [private]

Definition at line 55 of file DataWriterRemoteImpl.h.

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

---

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

• DataWriterRemoteImpl.h
• DataWriterRemoteImpl.cpp