OpenDDS::DCPS::NetworkConfigMonitor Class Reference

#include <NetworkConfigMonitor.h>

Inheritance diagram for OpenDDS::DCPS::NetworkConfigMonitor:

Collaboration diagram for OpenDDS::DCPS::NetworkConfigMonitor:

Public Member Functions
typedef	OPENDDS_LIST (NetworkInterfaceAddress) List
	NetworkConfigMonitor ()
virtual	~NetworkConfigMonitor ()
void	connect (RcHandle< InternalTopic< NetworkInterfaceAddress > > topic)
virtual bool	open ()=0
virtual bool	close ()=0
void	disconnect (RcHandle< InternalTopic< NetworkInterfaceAddress > > topic)
Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()
virtual void	_add_ref ()
virtual void	_remove_ref ()
long	ref_count () const
WeakObject *	_get_weak_object () const

Protected Member Functions
void	set (const List &list)
void	clear ()
void	set (const NetworkInterfaceAddress &nia)
void	remove_interface (const OPENDDS_STRING &name)
void	remove_address (const OPENDDS_STRING &name, const NetworkAddress &address)
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Private Attributes
RcHandle< InternalDataWriter< NetworkInterfaceAddress > >	writer_
List	list_
ACE_Thread_Mutex	mutex_

Detailed Description

Definition at line 78 of file NetworkConfigMonitor.h.

Constructor & Destructor Documentation

NetworkConfigMonitor()

OpenDDS::DCPS::NetworkConfigMonitor::NetworkConfigMonitor

(

)

Definition at line 39 of file NetworkConfigMonitor.cpp.

  : writer_(make_rch<InternalDataWriter<NetworkInterfaceAddress> >(true))
{}

~NetworkConfigMonitor()

OpenDDS::DCPS::NetworkConfigMonitor::~NetworkConfigMonitor ( )

virtual

Definition at line 43 of file NetworkConfigMonitor.cpp.

{}

Member Function Documentation

clear()

void OpenDDS::DCPS::NetworkConfigMonitor::clear ( void  )

protected

Definition at line 84 of file NetworkConfigMonitor.cpp.

References ACE_GUARD, list_, mutex_, and writer_.

{
  ACE_GUARD(ACE_Thread_Mutex, g, mutex_);

  for (List::const_iterator pos = list_.begin(), limit = list_.end(); pos != limit; ++pos) {
    writer_->dispose(*pos);
  }

  list_.clear();
}

close()

virtual bool OpenDDS::DCPS::NetworkConfigMonitor::close ( )

pure virtual

Implemented in OpenDDS::DCPS::DefaultNetworkConfigMonitor.

Referenced by OpenDDS::DCPS::Service_Participant::get_domain_participant_factory(), and OpenDDS::DCPS::Service_Participant::shutdown().

connect()

void OpenDDS::DCPS::NetworkConfigMonitor::connect

(

RcHandle< InternalTopic< NetworkInterfaceAddress > >

topic

)

Definition at line 46 of file NetworkConfigMonitor.cpp.

References writer_.

Referenced by OpenDDS::DCPS::Service_Participant::get_domain_participant_factory().

{
  topic->connect(writer_);
}

disconnect()

void OpenDDS::DCPS::NetworkConfigMonitor::disconnect

(

RcHandle< InternalTopic< NetworkInterfaceAddress > >

topic

)

Definition at line 51 of file NetworkConfigMonitor.cpp.

References writer_.

Referenced by OpenDDS::DCPS::Service_Participant::get_domain_participant_factory(), and OpenDDS::DCPS::Service_Participant::shutdown().

{
  topic->disconnect(writer_);
}

open()

virtual bool OpenDDS::DCPS::NetworkConfigMonitor::open ( )

pure virtual

Implemented in OpenDDS::DCPS::DefaultNetworkConfigMonitor.

Referenced by OpenDDS::DCPS::Service_Participant::get_domain_participant_factory().

OPENDDS_LIST()

typedef OpenDDS::DCPS::NetworkConfigMonitor::OPENDDS_LIST

(

NetworkInterfaceAddress

)

remove_address()

void OpenDDS::DCPS::NetworkConfigMonitor::remove_address ( const OPENDDS_STRING &  name, const NetworkAddress &  address  )

protected

Definition at line 125 of file NetworkConfigMonitor.cpp.

References ACE_GUARD, list_, mutex_, OPENDDS_END_VERSIONED_NAMESPACE_DECL, and writer_.

{
  ACE_GUARD(ACE_Thread_Mutex, g, mutex_);

  for (List::iterator pos = list_.begin(), limit = list_.end(); pos != limit;) {
    if (pos->name == name && pos->address == address) {
      writer_->dispose(*pos);
      list_.erase(pos++);
    } else {
      ++pos;
    }
  }
}

remove_interface()

void OpenDDS::DCPS::NetworkConfigMonitor::remove_interface ( const OPENDDS_STRING &  name )

protected

Definition at line 111 of file NetworkConfigMonitor.cpp.

References ACE_GUARD, list_, mutex_, and writer_.

{
  ACE_GUARD(ACE_Thread_Mutex, g, mutex_);

  for (List::iterator pos = list_.begin(), limit = list_.end(); pos != limit;) {
    if (pos->name == name) {
      writer_->dispose(*pos);
      list_.erase(pos++);
    } else {
      ++pos;
    }
  }
}

set() [1/2]

void OpenDDS::DCPS::NetworkConfigMonitor::set ( const List &  list )

protected

Definition at line 56 of file NetworkConfigMonitor.cpp.

References ACE_GUARD, list_, mutex_, and writer_.

{
  ACE_GUARD(ACE_Thread_Mutex, g, mutex_);

  for (List::const_iterator pos = list.begin(), limit = list.end(); pos != limit; ++pos) {
    List::const_iterator iter = std::find_if(list_.begin(), list_.end(), NetworkInterfaceAddressKeyEqual(*pos));
    if (iter != list_.end()) {
      if (*iter != *pos) {
        // Change.
        writer_->write(*pos);
      }
    } else {
      // New.
      writer_->write(*pos);
    }
  }

  for (List::const_iterator pos = list_.begin(), limit = list_.end(); pos != limit; ++pos) {
    List::const_iterator iter = std::find_if(list.begin(), list.end(), NetworkInterfaceAddressKeyEqual(*pos));
    if (iter == list.end()) {
      // Deleted.
      writer_->dispose(*pos);
    }
  }

  list_ = list;
}

set() [2/2]

void OpenDDS::DCPS::NetworkConfigMonitor::set ( const NetworkInterfaceAddress &  nia )

protected

Definition at line 95 of file NetworkConfigMonitor.cpp.

References ACE_GUARD, list_, mutex_, and writer_.

{
  ACE_GUARD(ACE_Thread_Mutex, g, mutex_);

  List::iterator pos = std::find_if(list_.begin(), list_.end(), NetworkInterfaceAddressKeyEqual(nia));
  if (pos != list_.end()) {
    if (*pos != nia) {
      writer_->write(nia);
      *pos = nia;
    }
  } else {
    writer_->write(nia);
    list_.push_back(nia);
  }
}

Member Data Documentation

list_

List OpenDDS::DCPS::NetworkConfigMonitor::list_

private

Definition at line 101 of file NetworkConfigMonitor.h.

Referenced by clear(), remove_address(), remove_interface(), and set().

mutex_

ACE_Thread_Mutex OpenDDS::DCPS::NetworkConfigMonitor::mutex_

mutableprivate

Definition at line 103 of file NetworkConfigMonitor.h.

Referenced by clear(), remove_address(), remove_interface(), and set().

writer_

RcHandle<InternalDataWriter<NetworkInterfaceAddress> > OpenDDS::DCPS::NetworkConfigMonitor::writer_

private

Definition at line 99 of file NetworkConfigMonitor.h.

Referenced by clear(), connect(), disconnect(), remove_address(), remove_interface(), and set().

---

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

• NetworkConfigMonitor.h
• NetworkConfigMonitor.cpp