#include <TopicMonitorImpl.h>

Inheritance diagram for OpenDDS::DCPS::TopicMonitorImpl:

Collaboration diagram for OpenDDS::DCPS::TopicMonitorImpl:

[legend]

Public Member Functions
	TopicMonitorImpl (TopicImpl *topic, OpenDDS::DCPS::TopicReportDataWriter_ptr topic_writer)

virtual	~TopicMonitorImpl ()

virtual void	report ()

Public Member Functions inherited from OpenDDS::DCPS::Monitor
	Monitor ()

virtual	~Monitor ()

Private Attributes
TopicImpl *	topic_

OpenDDS::DCPS::TopicReportDataWriter_var	topic_writer_

Detailed Description

Definition at line 24 of file TopicMonitorImpl.h.

Constructor & Destructor Documentation

◆ TopicMonitorImpl()

OpenDDS::DCPS::TopicMonitorImpl::TopicMonitorImpl	(	TopicImpl *	topic,
		OpenDDS::DCPS::TopicReportDataWriter_ptr	topic_writer
	)

Definition at line 21 of file TopicMonitorImpl.cpp.

References _duplicate().

   : topic_(topic),
     topic_writer_(TopicReportDataWriter::_duplicate(topic_writer))
 {
 }

◆ ~TopicMonitorImpl()

OpenDDS::DCPS::TopicMonitorImpl::~TopicMonitorImpl ( )

virtual

Definition at line 28 of file TopicMonitorImpl.cpp.

29 {

30 }

Member Function Documentation

◆ report()

void OpenDDS::DCPS::TopicMonitorImpl::report ( )

virtual

Implements OpenDDS::DCPS::Monitor.

Definition at line 33 of file TopicMonitorImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::TopicReport::dp_id, OpenDDS::DCPS::TopicImpl::get_id(), OpenDDS::DCPS::DomainParticipantImpl::get_id(), OpenDDS::DCPS::TopicDescriptionImpl::get_name(), OpenDDS::DCPS::TopicDescriptionImpl::get_participant(), OpenDDS::DCPS::TopicDescriptionImpl::get_type_name(), DDS::HANDLE_NIL, CORBA::is_nil(), LM_ERROR, OPENDDS_END_VERSIONED_NAMESPACE_DECL, topic_, OpenDDS::DCPS::TopicReport::topic_id, OpenDDS::DCPS::TopicReport::topic_name, topic_writer_, and OpenDDS::DCPS::TopicReport::type_name.

                          {
   if (!CORBA::is_nil(this->topic_writer_.in())) {
     TopicReport report;
     DDS::DomainParticipant_var dp = this->topic_->get_participant();
     DomainParticipantImpl* dp_impl =
       dynamic_cast<DomainParticipantImpl*>(dp.in());
     if (dp_impl) {
       report.dp_id = dp_impl->get_id();
       report.topic_id = this->topic_->get_id();
       report.topic_name = this->topic_->get_name();
       report.type_name = this->topic_->get_type_name();
       this->topic_writer_->write(report, DDS::HANDLE_NIL);
     } else {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) TopicMonitorImpl::report(): ")
         ACE_TEXT("failed to obtain DomainParticipantImpl.\n")));
     }
   }
 }

Member Data Documentation

◆ topic_

TopicImpl* OpenDDS::DCPS::TopicMonitorImpl::topic_

private

Definition at line 32 of file TopicMonitorImpl.h.

Referenced by report().

◆ topic_writer_

OpenDDS::DCPS::TopicReportDataWriter_var OpenDDS::DCPS::TopicMonitorImpl::topic_writer_