OpenDDS::DCPS::SPMonitorImpl Class Reference

#include <SPMonitorImpl.h>

Inheritance diagram for OpenDDS::DCPS::SPMonitorImpl:

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

[legend]List of all members.

Public Member Functions
	SPMonitorImpl (MonitorFactoryImpl *monitor_factory, Service_Participant *sp)
virtual	~SPMonitorImpl ()
virtual void	report ()
Private Attributes
MonitorFactoryImpl *	monitor_factory_
OpenDDS::DCPS::ServiceParticipantReportDataWriter_var	sp_writer_
std::string	hostname_
pid_t	pid_

---

Detailed Description

Definition at line 24 of file SPMonitorImpl.h.

---

Constructor & Destructor Documentation

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

Definition at line 20 of file SPMonitorImpl.cpp.

References hostname_, and pid_.

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

OpenDDS::DCPS::SPMonitorImpl::~SPMonitorImpl

(

)

[virtual]

Definition at line 30 of file SPMonitorImpl.cpp.

{
}

---

Member Function Documentation

void OpenDDS::DCPS::SPMonitorImpl::report

(

)

[virtual]

Implements OpenDDS::DCPS::Monitor.

Definition at line 35 of file SPMonitorImpl.cpp.

References OpenDDS::DCPS::MonitorFactoryImpl::get_sp_writer(), DDS::HANDLE_NIL, hostname_, monitor_factory_, 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;
    const DomainParticipantFactoryImpl::DPMap& participants =
      dynamic_cast<DomainParticipantFactoryImpl*>(pf.in())->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->svt_->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

std::string OpenDDS::DCPS::SPMonitorImpl::hostname_ [private]

Definition at line 34 of file SPMonitorImpl.h.

Referenced by report(), and SPMonitorImpl().

MonitorFactoryImpl* OpenDDS::DCPS::SPMonitorImpl::monitor_factory_ [private]

Definition at line 32 of file SPMonitorImpl.h.

Referenced by report().

pid_t OpenDDS::DCPS::SPMonitorImpl::pid_ [private]

Definition at line 35 of file SPMonitorImpl.h.

Referenced by report(), and SPMonitorImpl().

OpenDDS::DCPS::ServiceParticipantReportDataWriter_var OpenDDS::DCPS::SPMonitorImpl::sp_writer_ [private]

Definition at line 33 of file SPMonitorImpl.h.

Referenced by report().

---

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

• SPMonitorImpl.h
• SPMonitorImpl.cpp

---