OpenDDS::DCPS::DWMonitorImpl Class Reference

#include <DWMonitorImpl.h>

Inheritance diagram for OpenDDS::DCPS::DWMonitorImpl:

Collaboration diagram for OpenDDS::DCPS::DWMonitorImpl:

Public Member Functions
	DWMonitorImpl (DataWriterImpl *dw, OpenDDS::DCPS::DataWriterReportDataWriter_ptr dw_writer)
virtual	~DWMonitorImpl ()
virtual void	report ()
Public Member Functions inherited from OpenDDS::DCPS::Monitor
	Monitor ()
virtual	~Monitor ()

Private Attributes
DataWriterImpl *	dw_
OpenDDS::DCPS::DataWriterReportDataWriter_var	dw_writer_

Detailed Description

Definition at line 24 of file DWMonitorImpl.h.

Constructor & Destructor Documentation

DWMonitorImpl()

OpenDDS::DCPS::DWMonitorImpl::DWMonitorImpl	(	DataWriterImpl *	dw,
		OpenDDS::DCPS::DataWriterReportDataWriter_ptr	dw_writer
	)

Definition at line 19 of file DWMonitorImpl.cpp.

References _duplicate().

  : dw_(dw)
  , dw_writer_(DataWriterReportDataWriter::_duplicate(dw_writer))
{
}

~DWMonitorImpl()

OpenDDS::DCPS::DWMonitorImpl::~DWMonitorImpl ( )

virtual

Definition at line 26 of file DWMonitorImpl.cpp.

{
}

Member Function Documentation

report()

void OpenDDS::DCPS::DWMonitorImpl::report ( )

virtual

Implements OpenDDS::DCPS::Monitor.

Definition at line 31 of file DWMonitorImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::DataWriterReport::associations, OpenDDS::DCPS::DataWriterReport::dp_id, dw_, OpenDDS::DCPS::DataWriterReport::dw_id, dw_writer_, OpenDDS::DCPS::DataWriterImpl::get_dp_id(), OpenDDS::DCPS::DataWriterImpl::get_guid(), OpenDDS::DCPS::TopicImpl::get_id(), OpenDDS::DCPS::DataWriterImpl::get_instance_handles(), OpenDDS::DCPS::DataWriterImpl::get_publisher(), OpenDDS::DCPS::DataWriterImpl::get_readers(), OpenDDS::DCPS::DataWriterImpl::get_topic(), DDS::HANDLE_NIL, OpenDDS::DCPS::DataWriterReport::instances, CORBA::is_nil(), LM_ERROR, OPENDDS_END_VERSIONED_NAMESPACE_DECL, OpenDDS::DCPS::DataWriterReport::pub_handle, and OpenDDS::DCPS::DataWriterReport::topic_id.

                      {
  if (!CORBA::is_nil(dw_writer_.in())) {
    DataWriterReport report;
    report.dp_id = dw_->get_dp_id();
    DDS::Publisher_var pub = dw_->get_publisher();
    report.pub_handle = pub->get_instance_handle();
    report.dw_id = dw_->get_guid();
    DDS::Topic_var topic = dw_->get_topic();
    OpenDDS::DCPS::TopicImpl* ti = dynamic_cast<TopicImpl*>(topic.in());
    if (!ti) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) DWMonitorImpl::report():")
        ACE_TEXT(" failed to obtain TopicImpl.\n")));
      return;
    }
    report.topic_id = ti->get_id();
    DataWriterImpl::InstanceHandleVec instances;
    dw_->get_instance_handles(instances);
    CORBA::ULong length = 0;
    report.instances.length(static_cast<CORBA::ULong>(instances.size()));
    for (DataWriterImpl::InstanceHandleVec::iterator iter = instances.begin();
         iter != instances.end();
         ++iter) {
      report.instances[length++] = *iter;
    }
    DCPS::RepoIdSet readers;
    dw_->get_readers(readers);
    length = 0;
    report.associations.length(static_cast<CORBA::ULong>(readers.size()));
    for (DCPS::RepoIdSet::iterator iter = readers.begin();
         iter != readers.end();
         ++iter) {
      report.associations[length].dr_id = *iter;
      length++;
    }
    dw_writer_->write(report, DDS::HANDLE_NIL);
  }
}

Member Data Documentation

dw_

DataWriterImpl* OpenDDS::DCPS::DWMonitorImpl::dw_

private

Definition at line 32 of file DWMonitorImpl.h.

Referenced by report().

dw_writer_

OpenDDS::DCPS::DataWriterReportDataWriter_var OpenDDS::DCPS::DWMonitorImpl::dw_writer_

private

Definition at line 33 of file DWMonitorImpl.h.

Referenced by report().

---

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

• DWMonitorImpl.h
• DWMonitorImpl.cpp