FastTimerService::ThreadGuard Struct Reference

Classes
struct	specific_t

Public Member Functions
void	finalize ()
bool	register_thread (FastTimerService::AtomicResources &r)
Measurement &	thread ()
	ThreadGuard ()
	~ThreadGuard ()=default

Static Public Member Functions
static std::shared_ptr< specific_t > *	ptr (void *p)
static void	retire_thread (void *t)

Public Attributes
pthread_key_t	key_
tbb::concurrent_vector< std::shared_ptr< specific_t > >	thread_resources_

Detailed Description

Definition at line 467 of file FastTimerService.h.

Constructor & Destructor Documentation

ThreadGuard()

FastTimerService::ThreadGuard::ThreadGuard

(

)

Definition at line 1726 of file FastTimerService.cc.

References submitPVResolutionJobs::err, Exception, key_, and retire_thread().

                                         {
  auto err = ::pthread_key_create(&key_, retire_thread);
  if (err) {
    throw cms::Exception("FastTimerService") << "ThreadGuard key creation failed: " << ::strerror(err);
  }
}

~ThreadGuard()

FastTimerService::ThreadGuard::~ThreadGuard ( )

default

Member Function Documentation

finalize()

void FastTimerService::ThreadGuard::finalize

(

void

)

Definition at line 1765 of file FastTimerService.cc.

References AlCaHLTBitMon_ParallelJobs::p.

                                           {
  for (auto& p : thread_resources_) {
    auto expected = true;
    if (p->live_.compare_exchange_strong(expected, false)) {
      p->measurement_.measure_and_accumulate(p->resource_);
    }
  }
}

ptr()

std::shared_ptr< FastTimerService::ThreadGuard::specific_t > * FastTimerService::ThreadGuard::ptr ( void *  p )

static

Definition at line 1749 of file FastTimerService.cc.

References AlCaHLTBitMon_ParallelJobs::p.

                                                                                              {
  return static_cast<std::shared_ptr<specific_t>*>(p);
}

register_thread()

bool FastTimerService::ThreadGuard::register_thread

(

FastTimerService::AtomicResources &

r

)

Definition at line 1734 of file FastTimerService.cc.

References submitPVResolutionJobs::err, Exception, ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, createTree::pp, and alignCSCRings::r.

Referenced by FastTimerService::on_scheduler_entry().

                                                                                    {
  auto ptr = ::pthread_getspecific(key_);

  if (not ptr) {
    auto it = thread_resources_.emplace_back(std::make_shared<specific_t>(r));
    auto pp = new std::shared_ptr<specific_t>(*it);
    auto err = ::pthread_setspecific(key_, pp);
    if (err) {
      throw cms::Exception("FastTimerService") << "ThreadGuard pthread_setspecific failed: " << ::strerror(err);
    }
    return true;
  }
  return false;
}

retire_thread()

void FastTimerService::ThreadGuard::retire_thread ( void *  t )

static

Definition at line 1754 of file FastTimerService.cc.

References AlCaHLTBitMon_ParallelJobs::p.

Referenced by ThreadGuard().

                                                       {
  auto ps = ptr(p);
  auto expected = true;
  if ((*ps)->live_.compare_exchange_strong(expected, false)) {
    // account any resources used or freed by the thread before leaving the TBB pool
    (*ps)->measurement_.measure_and_accumulate((*ps)->resource_);
  }
  delete ps;
}

thread()

FastTimerService::Measurement & FastTimerService::ThreadGuard::thread

(

)

Definition at line 1774 of file FastTimerService.cc.

Referenced by FastTimerService::thread().

                                                                 {
  return (*ptr(::pthread_getspecific(key_)))->measurement_;
}

Member Data Documentation

key_

pthread_key_t FastTimerService::ThreadGuard::key_

Definition at line 488 of file FastTimerService.h.

Referenced by ThreadGuard().

thread_resources_

tbb::concurrent_vector<std::shared_ptr<specific_t> > FastTimerService::ThreadGuard::thread_resources_

Definition at line 487 of file FastTimerService.h.