OpenDDS::DCPS::SubscriberMonitorImpl Class Reference

#include <SubscriberMonitorImpl.h>

Inheritance diagram for OpenDDS::DCPS::SubscriberMonitorImpl:

[legend]Collaboration diagram for OpenDDS::DCPS::SubscriberMonitorImpl:

[legend]List of all members.

Public Member Functions
	SubscriberMonitorImpl (SubscriberImpl *sub, OpenDDS::DCPS::SubscriberReportDataWriter_ptr sub_writer)
virtual	~SubscriberMonitorImpl ()
virtual void	report ()
Private Attributes
SubscriberImpl *	sub_
OpenDDS::DCPS::SubscriberReportDataWriter_var	sub_writer_

---

Detailed Description

Definition at line 22 of file SubscriberMonitorImpl.h.

---

Constructor & Destructor Documentation

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

Definition at line 19 of file SubscriberMonitorImpl.cpp.

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

OpenDDS::DCPS::SubscriberMonitorImpl::~SubscriberMonitorImpl

(

)

[virtual]

Definition at line 26 of file SubscriberMonitorImpl.cpp.

{
}

---

Member Function Documentation

void OpenDDS::DCPS::SubscriberMonitorImpl::report

(

)

[virtual]

Implements OpenDDS::DCPS::Monitor.

Definition at line 31 of file SubscriberMonitorImpl.cpp.

References OpenDDS::DCPS::SubscriberImpl::get_instance_handle(), OpenDDS::DCPS::SubscriberImpl::get_participant(), OpenDDS::DCPS::SubscriberImpl::get_subscription_ids(), DDS::HANDLE_NIL, sub_, and sub_writer_.

                              {
  if (!CORBA::is_nil(this->sub_writer_.in())) {
    SubscriberReport report;
    report.handle = sub_->get_instance_handle();
    DDS::DomainParticipant_var dp = sub_->get_participant();
    report.dp_id   = dynamic_cast<DomainParticipantImpl*>(dp.in())->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

SubscriberImpl* OpenDDS::DCPS::SubscriberMonitorImpl::sub_ [private]

Definition at line 30 of file SubscriberMonitorImpl.h.

Referenced by report().

OpenDDS::DCPS::SubscriberReportDataWriter_var OpenDDS::DCPS::SubscriberMonitorImpl::sub_writer_ [private]

Definition at line 31 of file SubscriberMonitorImpl.h.

Referenced by report().

---

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

• SubscriberMonitorImpl.h
• SubscriberMonitorImpl.cpp

---