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 460 of file FastTimerService.h.

Constructor & Destructor Documentation

ThreadGuard()

FastTimerService::ThreadGuard::ThreadGuard

(

)

Definition at line 1670 of file FastTimerService.cc.

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

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

~ThreadGuard()

FastTimerService::ThreadGuard::~ThreadGuard ( )

default

Member Function Documentation

finalize()

void FastTimerService::ThreadGuard::finalize

(

void

)

Definition at line 1709 of file FastTimerService.cc.

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

References AlCaHLTBitMon_ParallelJobs::p.

ptr()

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

static

Definition at line 1693 of file FastTimerService.cc.

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

References AlCaHLTBitMon_ParallelJobs::p.

register_thread()

bool FastTimerService::ThreadGuard::register_thread

(

FastTimerService::AtomicResources &

r

)

Definition at line 1678 of file FastTimerService.cc.

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

References submitPVResolutionJobs::err, Exception, AlCaHLTBitMon_ParallelJobs::p, createTree::pp, and alignCSCRings::r.

Referenced by FastTimerService::on_scheduler_entry().

retire_thread()

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

static

Definition at line 1698 of file FastTimerService.cc.

                                                       {
  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;
}

References AlCaHLTBitMon_ParallelJobs::p.

Referenced by ThreadGuard().

thread()

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

(

)

Definition at line 1718 of file FastTimerService.cc.

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

Referenced by FastTimerService::thread().

Member Data Documentation

key_

pthread_key_t FastTimerService::ThreadGuard::key_

Definition at line 481 of file FastTimerService.h.

Referenced by ThreadGuard().

thread_resources_

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

Definition at line 480 of file FastTimerService.h.