Method stopInstrumentation

tools/monitor/MonitorTask.cpp:156–207

}

void
Monitor::MonitorTask::stopInstrumentation()
{
  // Only shutdown if we are currently actively processing data from a
  // repository.
  if( CORBA::is_nil( this->participant_.in())) {
    return;
  }

  ACE_DEBUG((LM_DEBUG,
    ACE_TEXT("(%P|%t) MonitorTask::stopInstrumentation() - ")
    ACE_TEXT("removing participant for domain %d.\n"),
    this->participant_->get_domain_id()
  ));

  ACE_GUARD(ACE_SYNCH_MUTEX, guard, this->lock_);

  // Clean up the wait conditions.
  DDS::ConditionSeq conditions;
  this->waiter_->get_conditions( conditions);
  this->waiter_->detach_conditions( conditions);

  // Reattach the guard condition.
  this->waiter_->attach_condition( this->guardCondition_);

  // Terminate the transport resources.

  // It is possible that the repository was down at this point,
  // and we do not want the exception stop the monitor process
  // so catch exception here.
  try {
    // Destroy the instrumentation participant.
    this->participant_->delete_contained_entities();
    TheParticipantFactory->delete_participant( this->participant_.in());
  }
  catch (const CORBA::TRANSIENT&)
  {
    ACE_DEBUG((LM_DEBUG,
      ACE_TEXT("(%P|%t) MonitorTask::stopInstrumentation() - ")
      ACE_TEXT("caught TRANSIENT exception.\n")
    ));
  }
  catch (const CORBA::Exception& ex) {
    ex._tao_print_exception("(%P|%t)  MonitorTask::stopInstrumentation() - ");
    throw;
  }
  catch (...) {
    throw;
  }

  this->participant_ = DDS::DomainParticipant::_nil();
}

Monitor::MonitorTask::RepoKey
Monitor::MonitorTask::setRepoIor( const std::string& ior)