OpenDDS::DCPS::TransportMonitorImpl Class Reference

#include <TransportMonitorImpl.h>

Inheritance diagram for OpenDDS::DCPS::TransportMonitorImpl:

Collaboration diagram for OpenDDS::DCPS::TransportMonitorImpl:

Public Member Functions
	TransportMonitorImpl (TransportImpl *transport, OpenDDS::DCPS::TransportReportDataWriter_ptr transport_writer)
virtual	~TransportMonitorImpl ()
virtual void	report ()
Public Member Functions inherited from OpenDDS::DCPS::Monitor
	Monitor ()
virtual	~Monitor ()

Private Types
typedef std::vector< TransportReport >	TransportReportVec

Private Attributes
OpenDDS::DCPS::TransportReportDataWriter_var	transport_writer_
std::string	hostname_
pid_t	pid_

Static Private Attributes
static ACE_Recursive_Thread_Mutex	queue_lock_
static TransportReportVec	queue_

Detailed Description

Definition at line 26 of file TransportMonitorImpl.h.

Member Typedef Documentation

TransportReportVec

typedef std::vector<TransportReport> OpenDDS::DCPS::TransportMonitorImpl::TransportReportVec

private

Definition at line 38 of file TransportMonitorImpl.h.

Constructor & Destructor Documentation

TransportMonitorImpl()

OpenDDS::DCPS::TransportMonitorImpl::TransportMonitorImpl	(	TransportImpl *	transport,
		OpenDDS::DCPS::TransportReportDataWriter_ptr	transport_writer
	)

Definition at line 22 of file TransportMonitorImpl.cpp.

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

  : transport_writer_(TransportReportDataWriter::_duplicate(transport_writer))
{
  char host[256];
  ACE_OS::hostname(host, 256);
  hostname_ = host;
  pid_  = ACE_OS::getpid();
}

~TransportMonitorImpl()

OpenDDS::DCPS::TransportMonitorImpl::~TransportMonitorImpl ( )

virtual

Definition at line 32 of file TransportMonitorImpl.cpp.

{
}

Member Function Documentation

report()

void OpenDDS::DCPS::TransportMonitorImpl::report ( )

virtual

Implements OpenDDS::DCPS::Monitor.

Definition at line 37 of file TransportMonitorImpl.cpp.

References DDS::HANDLE_NIL, OpenDDS::DCPS::TransportReport::host, hostname_, CORBA::is_nil(), OPENDDS_END_VERSIONED_NAMESPACE_DECL, OpenDDS::DCPS::TransportReport::pid, pid_, queue_, OpenDDS::DCPS::TransportReport::transport_id, OpenDDS::DCPS::TransportReport::transport_type, and transport_writer_.

                             {
  // ACE_DEBUG((LM_DEBUG, "TransportMonitorImpl::report()\n"));
  TransportReport report;
  report.host = this->hostname_.c_str();
  report.pid  = this->pid_;
  // TODO: remove/replace
  report.transport_id  = 0;
  report.transport_type = "";
  // ACE_GUARD(ACE_Recursive_Thread_Mutex, guard, queue_lock_);
  if (!CORBA::is_nil(this->transport_writer_.in())) {
    if (this->queue_.size()) {
      // ACE_DEBUG((LM_DEBUG, "TransportMonitorImpl::report(): popping\n"));
      for (unsigned int i = 0; i < this->queue_.size(); i++) {
        // ACE_DEBUG((LM_DEBUG, "TransportMonitorImpl::report(): writing, id = %d\n",
        //                      this->queue_[i].transport_id));
        this->transport_writer_->write(this->queue_[i], DDS::HANDLE_NIL);
      }
      this->queue_.clear();
    }
    // ACE_DEBUG((LM_DEBUG, "TransportMonitorImpl::report(): writing, id = %d\n",
    //                      report.transport_id));
    this->transport_writer_->write(report, DDS::HANDLE_NIL);
  } else {
    // ACE_DEBUG((LM_DEBUG, "TransportMonitorImpl::report(): queueing, id = %d\n",
    //                      report.transport_id));
    queue_.push_back(report);
  }
}

Member Data Documentation

hostname_

std::string OpenDDS::DCPS::TransportMonitorImpl::hostname_

private

Definition at line 35 of file TransportMonitorImpl.h.

Referenced by report(), and TransportMonitorImpl().

pid_

pid_t OpenDDS::DCPS::TransportMonitorImpl::pid_

private

Definition at line 36 of file TransportMonitorImpl.h.

Referenced by report(), and TransportMonitorImpl().

queue_

TransportMonitorImpl::TransportReportVec OpenDDS::DCPS::TransportMonitorImpl::queue_

staticprivate

Definition at line 40 of file TransportMonitorImpl.h.

Referenced by report().

queue_lock_

ACE_Recursive_Thread_Mutex OpenDDS::DCPS::TransportMonitorImpl::queue_lock_

staticprivate

Definition at line 39 of file TransportMonitorImpl.h.

transport_writer_

OpenDDS::DCPS::TransportReportDataWriter_var OpenDDS::DCPS::TransportMonitorImpl::transport_writer_

private

Definition at line 34 of file TransportMonitorImpl.h.

Referenced by report().

---

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

• TransportMonitorImpl.h
• TransportMonitorImpl.cpp