#include <SubscriberMonitorImpl.h>

Inheritance diagram for OpenDDS::DCPS::SubscriberMonitorImpl:

Collaboration diagram for OpenDDS::DCPS::SubscriberMonitorImpl:

[legend]

Public Member Functions
	SubscriberMonitorImpl (SubscriberImpl *sub, OpenDDS::DCPS::SubscriberReportDataWriter_ptr sub_writer)

virtual	~SubscriberMonitorImpl ()

virtual void	report ()

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

virtual	~Monitor ()

Private Attributes
SubscriberImpl *	sub_

OpenDDS::DCPS::SubscriberReportDataWriter_var	sub_writer_

Detailed Description

Definition at line 24 of file SubscriberMonitorImpl.h.

Constructor & Destructor Documentation

◆ SubscriberMonitorImpl()

OpenDDS::DCPS::SubscriberMonitorImpl::SubscriberMonitorImpl	(	SubscriberImpl *	sub,
		OpenDDS::DCPS::SubscriberReportDataWriter_ptr	sub_writer
	)

Definition at line 21 of file SubscriberMonitorImpl.cpp.

References _duplicate().

   : sub_(sub),
     sub_writer_(SubscriberReportDataWriter::_duplicate(sub_writer))
 {
 }

◆ ~SubscriberMonitorImpl()

OpenDDS::DCPS::SubscriberMonitorImpl::~SubscriberMonitorImpl ( )

virtual

Definition at line 28 of file SubscriberMonitorImpl.cpp.

29 {

30 }

Member Function Documentation

◆ report()

void OpenDDS::DCPS::SubscriberMonitorImpl::report ( )

virtual

Implements OpenDDS::DCPS::Monitor.

Definition at line 33 of file SubscriberMonitorImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::SubscriberReport::dp_id, OpenDDS::DCPS::DomainParticipantImpl::get_id(), OpenDDS::DCPS::SubscriberImpl::get_instance_handle(), OpenDDS::DCPS::SubscriberImpl::get_participant(), OpenDDS::DCPS::SubscriberImpl::get_subscription_ids(), OpenDDS::DCPS::SubscriberReport::handle, DDS::HANDLE_NIL, CORBA::is_nil(), LM_ERROR, OPENDDS_END_VERSIONED_NAMESPACE_DECL, OpenDDS::DCPS::SubscriberReport::readers, sub_, sub_writer_, and OpenDDS::DCPS::SubscriberReport::transport_id.

                               {
   if (!CORBA::is_nil(this->sub_writer_.in())) {
     SubscriberReport report;
     report.handle = sub_->get_instance_handle();
     DDS::DomainParticipant_var dp = sub_->get_participant();
     OpenDDS::DCPS::DomainParticipantImpl* dpi = dynamic_cast<DomainParticipantImpl*>(dp.in());
     if (!dpi) {
       ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) SubscriberMonitorImpl::report():")
         ACE_TEXT(" failed to obtain DomainParticipantImpl.\n")));
       return;
     }
     report.dp_id   = dpi->get_id();
     TransportImpl_rch ti; //TODO: transport    = sub_->get_transport_impl();
     // TODO: remove transport_id and replace with name
     report.transport_id = 0;
     SubscriberImpl::SubscriptionIdVec readers;
     sub_->get_subscription_ids(readers);
     CORBA::ULong length = 0;
     report.readers.length(static_cast<CORBA::ULong>(readers.size()));
     for (SubscriberImpl::SubscriptionIdVec::iterator iter = readers.begin();
          iter != readers.end();
          ++iter) {
       report.readers[length++] = *iter;
     }
     this->sub_writer_->write(report, DDS::HANDLE_NIL);
   }
 }

Member Data Documentation

◆ sub_

SubscriberImpl* OpenDDS::DCPS::SubscriberMonitorImpl::sub_

private

Definition at line 32 of file SubscriberMonitorImpl.h.

Referenced by report().

◆ sub_writer_

OpenDDS::DCPS::SubscriberReportDataWriter_var OpenDDS::DCPS::SubscriberMonitorImpl::sub_writer_