OpenDDS::DCPS::SPMonitorImpl Class Reference

#include <SPMonitorImpl.h>

Inheritance diagram for OpenDDS::DCPS::SPMonitorImpl:

Collaboration diagram for OpenDDS::DCPS::SPMonitorImpl:

Public Member Functions
	SPMonitorImpl (MonitorFactoryImpl *monitor_factory, Service_Participant *sp)
virtual	~SPMonitorImpl ()
virtual void	report ()
Public Member Functions inherited from OpenDDS::DCPS::Monitor
	Monitor ()
virtual	~Monitor ()

Private Attributes
MonitorFactoryImpl *	monitor_factory_
OpenDDS::DCPS::ServiceParticipantReportDataWriter_var	sp_writer_
std::string	hostname_
pid_t	pid_

Detailed Description

Definition at line 26 of file SPMonitorImpl.h.

Constructor & Destructor Documentation

SPMonitorImpl()

OpenDDS::DCPS::SPMonitorImpl::SPMonitorImpl	(	MonitorFactoryImpl *	monitor_factory,
		Service_Participant *	sp
	)

Definition at line 22 of file SPMonitorImpl.cpp.

References ACE_OS::getpid(), ACE_OS::hostname(), hostname_, and pid_.

    : monitor_factory_(monitor_factory)
{
  char host[256];
  ACE_OS::hostname(host, 256);
  hostname_ = host;
  pid_ = ACE_OS::getpid();
}

~SPMonitorImpl()

OpenDDS::DCPS::SPMonitorImpl::~SPMonitorImpl ( )

virtual

Definition at line 32 of file SPMonitorImpl.cpp.

{
}

Member Function Documentation

report()

void OpenDDS::DCPS::SPMonitorImpl::report ( )

virtual

Implements OpenDDS::DCPS::Monitor.

Definition at line 37 of file SPMonitorImpl.cpp.

References ACE_ERROR, ACE_TEXT(), OpenDDS::DCPS::ServiceParticipantReport::domain_participants, OpenDDS::DCPS::MonitorFactoryImpl::get_sp_writer(), DDS::HANDLE_NIL, OpenDDS::DCPS::ServiceParticipantReport::host, hostname_, CORBA::is_nil(), LM_ERROR, monitor_factory_, OPENDDS_END_VERSIONED_NAMESPACE_DECL, OpenDDS::DCPS::DomainParticipantFactoryImpl::participants(), OpenDDS::DCPS::ServiceParticipantReport::pid, pid_, sp_writer_, and TheParticipantFactory.

{
  if (CORBA::is_nil(this->sp_writer_.in())) {
    this->sp_writer_ = this->monitor_factory_->get_sp_writer();
  }

  // If the SP writer is not available, it is too soon to report
  if (!CORBA::is_nil(this->sp_writer_.in())) {
    ServiceParticipantReport report;
    report.host = this->hostname_.c_str();
    report.pid  = this->pid_;
    DDS::DomainParticipantFactory_var pf = TheParticipantFactory;

    OpenDDS::DCPS::DomainParticipantFactoryImpl* pi = dynamic_cast<DomainParticipantFactoryImpl*>(pf.in());
    if (!pi) {
      ACE_ERROR((LM_ERROR, ACE_TEXT("(%P|%t) SPMonitorImpl::report():")
        ACE_TEXT(" failed to obtain DomainParticipantFactoryImpl.\n")));
      return;
    }

    const DomainParticipantFactoryImpl::DPMap& participants = pi->participants();
    CORBA::ULong length = 0;
    for (DomainParticipantFactoryImpl::DPMap::const_iterator mapIter = participants.begin();
         mapIter != participants.end();
         ++mapIter) {
      for (DomainParticipantFactoryImpl::DPSet::const_iterator iter = mapIter->second.begin();
           iter != mapIter->second.end();
           ++iter) {
        report.domain_participants.length(length+1);
        report.domain_participants[length] = (*iter)->get_id();
        length++;
      }
    }
    length = 0;
    // TODO: Redo the transport-related monitor publishing here...
    //const TransportFactory::ImplMap& transports =
    //  TransportFactory::instance()->get_transport_impl_map();
    //report.transports.length(static_cast<CORBA::ULong>(transports.size()));
    //for (TransportFactory::ImplMap::const_iterator mapIter = transports.begin();
    //     mapIter != transports.end();
    //     ++mapIter) {
    //  report.transports[length++] = mapIter->first;
    //}
    this->sp_writer_->write(report, DDS::HANDLE_NIL);
  }
}

Member Data Documentation

hostname_

std::string OpenDDS::DCPS::SPMonitorImpl::hostname_

private

Definition at line 36 of file SPMonitorImpl.h.

Referenced by report(), and SPMonitorImpl().

monitor_factory_

MonitorFactoryImpl* OpenDDS::DCPS::SPMonitorImpl::monitor_factory_

private

Definition at line 34 of file SPMonitorImpl.h.

Referenced by report().

pid_

pid_t OpenDDS::DCPS::SPMonitorImpl::pid_

private

Definition at line 37 of file SPMonitorImpl.h.

Referenced by report(), and SPMonitorImpl().

sp_writer_

OpenDDS::DCPS::ServiceParticipantReportDataWriter_var OpenDDS::DCPS::SPMonitorImpl::sp_writer_

private

Definition at line 35 of file SPMonitorImpl.h.

Referenced by report().

---

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

• SPMonitorImpl.h
• SPMonitorImpl.cpp