OpenDDS::DCPS::DRMonitorImpl Class Reference

#include <DRMonitorImpl.h>

Inheritance diagram for OpenDDS::DCPS::DRMonitorImpl:

Collaboration diagram for OpenDDS::DCPS::DRMonitorImpl:

Public Member Functions
	DRMonitorImpl (DataReaderImpl *dr, OpenDDS::DCPS::DataReaderReportDataWriter_ptr dr_writer)
virtual	~DRMonitorImpl ()
virtual void	report ()
Public Member Functions inherited from OpenDDS::DCPS::Monitor
	Monitor ()
virtual	~Monitor ()

Private Attributes
DataReaderImpl *	dr_
OpenDDS::DCPS::DataReaderReportDataWriter_var	dr_writer_

Detailed Description

Definition at line 24 of file DRMonitorImpl.h.

Constructor & Destructor Documentation

DRMonitorImpl()

OpenDDS::DCPS::DRMonitorImpl::DRMonitorImpl	(	DataReaderImpl *	dr,
		OpenDDS::DCPS::DataReaderReportDataWriter_ptr	dr_writer
	)

Definition at line 20 of file DRMonitorImpl.cpp.

References _duplicate().

  : dr_(dr)
  , dr_writer_(DataReaderReportDataWriter::_duplicate(dr_writer))
{
}

~DRMonitorImpl()

OpenDDS::DCPS::DRMonitorImpl::~DRMonitorImpl ( )

virtual

Definition at line 27 of file DRMonitorImpl.cpp.

{
}

Member Function Documentation

report()

void OpenDDS::DCPS::DRMonitorImpl::report ( )

virtual

Implements OpenDDS::DCPS::Monitor.

Definition at line 32 of file DRMonitorImpl.cpp.

References OpenDDS::DCPS::DataReaderReport::associations, OpenDDS::DCPS::DataReaderReport::dp_id, dr_, OpenDDS::DCPS::DataReaderReport::dr_id, dr_writer_, OpenDDS::DCPS::DataReaderImpl::get_dp_id(), OpenDDS::DCPS::DataReaderImpl::get_guid(), OpenDDS::DCPS::DataReaderImpl::get_instance_handles(), OpenDDS::DCPS::DataReaderImpl::get_subscriber(), OpenDDS::DCPS::DataReaderImpl::get_topic_id(), OpenDDS::DCPS::DataReaderImpl::get_writer_states(), DDS::HANDLE_NIL, OpenDDS::DCPS::DataReaderReport::instances, CORBA::is_nil(), OPENDDS_END_VERSIONED_NAMESPACE_DECL, OpenDDS::DCPS::DataReaderReport::sub_handle, and OpenDDS::DCPS::DataReaderReport::topic_id.

                      {
  if (!CORBA::is_nil(dr_writer_.in())) {
    DataReaderReport report;
    report.dp_id = dr_->get_dp_id();
    DDS::Subscriber_var sub = dr_->get_subscriber();
    report.sub_handle = sub->get_instance_handle();
    report.dr_id = dr_->get_guid();
    report.topic_id = dr_->get_topic_id();
    DataReaderImpl::InstanceHandleVec instances;
    dr_->get_instance_handles(instances);
    CORBA::ULong length = 0;
    report.instances.length(static_cast<CORBA::ULong>(instances.size()));
    for (DataReaderImpl::InstanceHandleVec::iterator iter = instances.begin();
         iter != instances.end();
         ++iter) {
      report.instances[length++] = *iter;
    }
    DataReaderImpl::WriterStatePairVec writer_states;
    dr_->get_writer_states(writer_states);
    length = 0;
    report.associations.length(static_cast<CORBA::ULong>(writer_states.size()));
    for (DataReaderImpl::WriterStatePairVec::iterator iter = writer_states.begin();
         iter != writer_states.end();
         ++iter) {
      report.associations[length].dw_id = iter->first;
      report.associations[length].state = iter->second;
      length++;
    }
    dr_writer_->write(report, DDS::HANDLE_NIL);
  }
}

Member Data Documentation

dr_

DataReaderImpl* OpenDDS::DCPS::DRMonitorImpl::dr_

private

Definition at line 32 of file DRMonitorImpl.h.

Referenced by report().

dr_writer_

OpenDDS::DCPS::DataReaderReportDataWriter_var OpenDDS::DCPS::DRMonitorImpl::dr_writer_

private

Definition at line 33 of file DRMonitorImpl.h.

Referenced by report().

---

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

• DRMonitorImpl.h
• DRMonitorImpl.cpp