Geant4RunAction.cpp

Go to the documentation of this file.

//==========================================================================
//  AIDA Detector description implementation 
//--------------------------------------------------------------------------
// Copyright (C) Organisation europeenne pour la Recherche nucleaire (CERN)
// All rights reserved.
//
// For the licensing terms see $DD4hepINSTALL/LICENSE.
// For the list of contributors see $DD4hepINSTALL/doc/CREDITS.
//
// Author     : M.Frank
//
//==========================================================================
 
// Framework include files
#include <DD4hep/InstanceCount.h>
#include <DDG4/Geant4RunAction.h>
 
// Geant4 headers
#include <G4Threading.hh>
#include <G4AutoLock.hh>
 
using namespace dd4hep::sim;
 
namespace {
  G4Mutex action_mutex=G4MUTEX_INITIALIZER;
  G4Mutex sequence_mutex=G4MUTEX_INITIALIZER;
}
 
Geant4RunAction::Geant4RunAction(Geant4Context* ctxt, const std::string& nam)
  : Geant4Action(ctxt, nam) {
  InstanceCount::increment(this);
}
 
Geant4RunAction::~Geant4RunAction() {
  InstanceCount::decrement(this);
}
 
void Geant4RunAction::begin(const G4Run*) {
}
 
void Geant4RunAction::end(const G4Run*) {
}
 
Geant4SharedRunAction::Geant4SharedRunAction(Geant4Context* ctxt, const std::string& nam)
  : Geant4RunAction(ctxt, nam)
{
  InstanceCount::increment(this);
}
 
Geant4SharedRunAction::~Geant4SharedRunAction()   {
  detail::releasePtr(m_action);
  InstanceCount::decrement(this);
}
 
void Geant4SharedRunAction::configureFiber(Geant4Context* thread_context)   {
  m_action->configureFiber(thread_context);
}
 
void Geant4SharedRunAction::use(Geant4RunAction* action)   {
  if (action) {
    action->addRef();
    m_properties.adopt(action->properties());
    m_action = action;
    return;
  }
  except("Geant4SharedRunAction: Attempt to use invalid actor!");
}
 
void Geant4SharedRunAction::begin(const G4Run* run)   {
  if ( m_action )  {
    G4AutoLock protection_lock(&action_mutex);    {
      ContextSwap swap(m_action,context());
      m_action->begin(run);
    }
  }
}
 
void Geant4SharedRunAction::end(const G4Run* run)   {
  if ( m_action )  {
    G4AutoLock protection_lock(&action_mutex);  {
      ContextSwap swap(m_action,context());
      m_action->end(run);
    }
  }
}
 
Geant4RunActionSequence::Geant4RunActionSequence(Geant4Context* ctxt, const std::string& nam)
  : Geant4Action(ctxt, nam) {
  m_needsControl = true;
  InstanceCount::increment(this);
}
 
Geant4RunActionSequence::~Geant4RunActionSequence() {
  m_actors(&Geant4RunAction::release);
  m_actors.clear();
  m_begin.clear();
  m_end.clear();
  InstanceCount::decrement(this);
}
 
void Geant4RunActionSequence::updateContext(Geant4Context* ctxt)    {
  m_context = ctxt;
  m_actors.updateContext(ctxt);
}
 
void Geant4RunActionSequence::configureFiber(Geant4Context* thread_context)   {
  m_actors(&Geant4Action::configureFiber, thread_context);
}
 
Geant4RunAction* Geant4RunActionSequence::get(const std::string& nam) const   {
  return m_actors.get(FindByName(TypeName::split(nam).second));
}
 
void Geant4RunActionSequence::adopt(Geant4RunAction* action) {
  if (action) {
    G4AutoLock protection_lock(&action_mutex);
    action->addRef();
    m_actors.add(action);
    return;
  }
  except("Geant4RunActionSequence: Attempt to add invalid actor!");
}
 
void Geant4RunActionSequence::begin(const G4Run* run) {
  G4AutoLock protection_lock(&sequence_mutex);
  m_actors(&Geant4RunAction::begin, run);
  m_begin(run);
}
 
void Geant4RunActionSequence::end(const G4Run* run) {
  G4AutoLock protection_lock(&sequence_mutex);
  m_end(run);
  m_actors(&Geant4RunAction::end, run);
}