ThreadInitTask Class Reference

#include <src/ThreadInitTask.h>

Inheritance diagram for ThreadInitTask:

Collaboration diagram for ThreadInitTask:

Public Member Functions
	ThreadInitTask (ToolHandleArray< IThreadInitTool > &tools, boost::barrier *b, ISvcLocator *svcLocator, bool terminate=false)
virtual tbb::task *	execute ()

Static Public Member Functions
static bool	execFailed ()

Private Attributes
ToolHandleArray< IThreadInitTool > &	m_tools
boost::barrier *	m_barrier
SmartIF< ISvcLocator >	m_serviceLocator
bool	m_terminate

Static Private Attributes
static std::atomic< bool >	m_execFailed

Detailed Description

Definition at line 14 of file ThreadInitTask.h.

Constructor & Destructor Documentation

ThreadInitTask::ThreadInitTask ( ToolHandleArray< IThreadInitTool > &  tools, boost::barrier *  b, ISvcLocator *  svcLocator, bool  terminate = false  )

inline

Definition at line 19 of file ThreadInitTask.h.

                               : 
    m_tools(tools), m_barrier(b), m_serviceLocator(svcLocator),
    m_terminate(terminate){};

Member Function Documentation

static bool ThreadInitTask::execFailed ( )

inlinestatic

Definition at line 28 of file ThreadInitTask.h.

{ return m_execFailed; }

tbb::task * ThreadInitTask::execute ( )

virtual

Definition at line 13 of file ThreadInitTask.cpp.

                        {

  SmartIF<IMessageSvc> messageSvc (m_serviceLocator);
  MsgStream log(messageSvc, "ThreadInitTask");

  const auto debug = log.level() <= MSG::DEBUG;

  if (debug)
    log << MSG::DEBUG << "execute in thread 0x" << std::hex << pthread_self()
        << " at " << this
        << std::dec << endmsg;

  if (m_tools.retrieve().isFailure()) {
    log << MSG::ERROR << "unable to retrieve ToolHandleArray " << m_tools
    << endmsg;
    m_execFailed = true;
  } else {

    if (m_tools.size() == 0) {
      log << MSG::INFO << "no entries in Tool Array"
    << endmsg;
    } else {
      if (debug)
        log << MSG::DEBUG << "executing in thread 0x" << std::hex << pthread_self()
        << std::dec << endmsg;

    for ( auto t : m_tools ) {

    try {

    if (debug)
      log << MSG::DEBUG << "calling IThreadInitTool " << t << endmsg;

    if (!m_terminate) {
      t->initThread();
      } else {
      t->terminateThread();
      }

    } catch( const GaudiException& exc ) {
      log << MSG::ERROR << "ThreadInitTool " << t << " in thread 0x"
          << std::hex << pthread_self() << std::dec << " threw GaudiException: "
          << exc << endmsg;
      m_execFailed = true;
    } catch (const std::exception& exc ) {
      log << MSG::ERROR << "ThreadInitTool " << t << " in thread 0x"
          << std::hex << pthread_self() << std::dec << " threw std::exception: "
          << exc.what() << endmsg;
      m_execFailed = true;
    } catch(...) {
      log << MSG::ERROR << "ThreadInitTool " << t << " in thread 0x"
          << std::hex << pthread_self() << std::dec << " threw unknown exception"
          << endmsg;
      m_execFailed = true;
    }

    }

      m_tools.release().ignore();

    }
  }


  if (m_barrier != 0) {
    log << MSG::INFO << "waiting at barrier in thread 0x" << std::hex << pthread_self()
    << std::dec << endmsg;
    m_barrier->wait();
  }

  return nullptr;

}

Member Data Documentation

boost::barrier* ThreadInitTask::m_barrier

private

Definition at line 34 of file ThreadInitTask.h.

std::atomic< bool > ThreadInitTask::m_execFailed

staticprivate

Definition at line 38 of file ThreadInitTask.h.

SmartIF<ISvcLocator> ThreadInitTask::m_serviceLocator

private

Definition at line 35 of file ThreadInitTask.h.

bool ThreadInitTask::m_terminate

private

Definition at line 36 of file ThreadInitTask.h.

ToolHandleArray<IThreadInitTool>& ThreadInitTask::m_tools

private

Definition at line 32 of file ThreadInitTask.h.

---

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

• GaudiHive/src/ThreadInitTask.h
• GaudiHive/src/ThreadInitTask.cpp