OpenDDS::DCPS::PublisherMonitorImpl Class Reference

#include <PublisherMonitorImpl.h>

Inheritance diagram for OpenDDS::DCPS::PublisherMonitorImpl:

[legend]

Collaboration diagram for OpenDDS::DCPS::PublisherMonitorImpl:

[legend]

List of all members.

Public Member Functions
	PublisherMonitorImpl (PublisherImpl *pub, OpenDDS::DCPS::PublisherReportDataWriter_ptr pub_writer)
virtual	~PublisherMonitorImpl ()
virtual void	report ()
Private Attributes
PublisherImpl *	pub_
OpenDDS::DCPS::PublisherReportDataWriter_var	pub_writer_

---

Detailed Description

Definition at line 24 of file PublisherMonitorImpl.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::PublisherMonitorImpl::PublisherMonitorImpl	(	PublisherImpl *	pub,
		OpenDDS::DCPS::PublisherReportDataWriter_ptr	pub_writer
	)

Definition at line 21 of file PublisherMonitorImpl.cpp.

References _duplicate().

  : pub_(pub),
    pub_writer_(PublisherReportDataWriter::_duplicate(pub_writer))
{
}

Here is the call graph for this function:

OpenDDS::DCPS::PublisherMonitorImpl::~PublisherMonitorImpl

(

)

[virtual]

Definition at line 28 of file PublisherMonitorImpl.cpp.

{
}

---

Member Function Documentation

void OpenDDS::DCPS::PublisherMonitorImpl::report

(

void

)

[virtual]

Implements OpenDDS::DCPS::Monitor.

Definition at line 33 of file PublisherMonitorImpl.cpp.

References ACE_TEXT(), OpenDDS::DCPS::PublisherReport::dp_id, OpenDDS::DCPS::DomainParticipantImpl::get_id(), OpenDDS::DCPS::PublisherImpl::get_instance_handle(), OpenDDS::DCPS::PublisherImpl::get_participant(), OpenDDS::DCPS::PublisherImpl::get_publication_ids(), OpenDDS::DCPS::PublisherReport::handle, DDS::HANDLE_NIL, CORBA::is_nil(), LM_ERROR, pub_, pub_writer_, OpenDDS::DCPS::PublisherReport::transport_id, and OpenDDS::DCPS::PublisherReport::writers.

                             {
  if (!CORBA::is_nil(this->pub_writer_.in())) {
    PublisherReport report;
    report.handle = pub_->get_instance_handle();
    DDS::DomainParticipant_var dp = pub_->get_participant();
    OpenDDS::DCPS::DomainParticipantImpl* dpi = dynamic_cast<DomainParticipantImpl*>(dp.in());
    if (!dpi) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) PublisherMonitorImpl::report():")
        ACE_TEXT(" failed to obtain DomainParticipantImpl.\n")));
      return;
    }
    report.dp_id   = dpi->get_id();
    TransportImpl_rch ti; //TODO: transport    = pub_->get_transport_impl();
    // TODO: remove/replace
    report.transport_id = 0;
    PublisherImpl::PublicationIdVec writers;
    pub_->get_publication_ids(writers);
    CORBA::ULong length = 0;
    report.writers.length(static_cast<CORBA::ULong>(writers.size()));
    for (PublisherImpl::PublicationIdVec::iterator iter = writers.begin();
         iter != writers.end();
         ++iter) {
      report.writers[length++] = *iter;
    }
    this->pub_writer_->write(report, DDS::HANDLE_NIL);
  }
}

Here is the call graph for this function:

---

Member Data Documentation

PublisherImpl* OpenDDS::DCPS::PublisherMonitorImpl::pub_ [private]

Definition at line 32 of file PublisherMonitorImpl.h.

Referenced by report().

OpenDDS::DCPS::PublisherReportDataWriter_var OpenDDS::DCPS::PublisherMonitorImpl::pub_writer_ [private]

Definition at line 33 of file PublisherMonitorImpl.h.

Referenced by report().

---

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

• PublisherMonitorImpl.h
• PublisherMonitorImpl.cpp