OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner Struct Reference

Inheritance diagram for OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner:

[legend]

Collaboration diagram for OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner:

[legend]

List of all members.

Public Member Functions
	OrbRunner ()
int	svc ()
void	shutdown ()
Public Attributes
CORBA::ORB_var	orb_
ACE_Atomic_Op < ACE_Thread_Mutex, unsigned long >	use_count_
Private Member Functions
	OrbRunner (const OrbRunner &)
OrbRunner &	operator= (const OrbRunner &)

---

Detailed Description

Definition at line 248 of file InfoRepoDiscovery.h.

---

Constructor & Destructor Documentation

OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::OrbRunner

(

)

[inline]

Definition at line 249 of file InfoRepoDiscovery.h.

{}

OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::OrbRunner

(

const OrbRunner &

)

[private]

---

Member Function Documentation

OrbRunner& OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::operator=

(

const OrbRunner &

)

[private]

Reimplemented from ACE_Task_Base.

void OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::shutdown

(

void

)

Definition at line 990 of file InfoRepoDiscovery.cpp.

References orb_, and ACE_Task_Base::wait().

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::~InfoRepoDiscovery().

{
  orb_->shutdown();
  wait();
  orb_->destroy();
}

Here is the call graph for this function:

Here is the caller graph for this function:

int OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::svc

(

void

)

[virtual]

Reimplemented from ACE_Task_Base.

Definition at line 1001 of file InfoRepoDiscovery.cpp.

References CORBA::Exception::_tao_print_exception(), orb_, SIG_SETMASK, ACE_OS::sigfillset(), sigset_t, and ACE_OS::thr_sigsetmask().

{
  // this method was originally Service_Participant::svc()
  bool done = false;

  // Ignore all signals to avoid
  //     ERROR: <something descriptive> Interrupted system call
  // The main thread will handle signals.
  sigset_t set;
  ACE_OS::sigfillset(&set);
  ACE_OS::thr_sigsetmask(SIG_SETMASK, &set, NULL);

  while (!done) {
    try {
      if (orb_->orb_core()->has_shutdown() == false) {
        orb_->run();
      }

      done = true;

    } catch (const CORBA::SystemException& sysex) {
      sysex._tao_print_exception(
        "ERROR: InfoRepoDiscovery::OrbRunner");

    } catch (const CORBA::UserException& userex) {
      userex._tao_print_exception(
        "ERROR: InfoRepoDiscovery::OrbRunner");

    } catch (const CORBA::Exception& ex) {
      ex._tao_print_exception(
        "ERROR: InfoRepoDiscovery::OrbRunner");
    }

    if (orb_->orb_core()->has_shutdown()) {
      done = true;

    } else {
      orb_->orb_core()->reactor()->reset_reactor_event_loop();
    }
  }

  return 0;
}

Here is the call graph for this function:

---

Member Data Documentation

CORBA::ORB_var OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::orb_

Definition at line 253 of file InfoRepoDiscovery.h.

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::get_dcps_info(), shutdown(), and svc().

ACE_Atomic_Op<ACE_Thread_Mutex, unsigned long> OpenDDS::DCPS::InfoRepoDiscovery::OrbRunner::use_count_

Definition at line 254 of file InfoRepoDiscovery.h.

Referenced by OpenDDS::DCPS::InfoRepoDiscovery::get_dcps_info(), and OpenDDS::DCPS::InfoRepoDiscovery::~InfoRepoDiscovery().

---

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

• InfoRepoDiscovery.h
• InfoRepoDiscovery.cpp