AthAsynchronousAlgorithm.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2026 CERN for the benefit of the ATLAS collaboration
*/
// AthAsynchronousAlgorithm.cxx
// Implementation file for class AthAsynchronousAlgorithm
// Author: Beojan Stanislaus
 
#include "AthenaBaseComps/AthAsynchronousAlgorithm.h"
#include "CxxUtils/checker_macros.h"
#include <print>
 
StatusCode AthAsynchronousAlgorithm::sysExecute(const EventContext& ctx) {
  ATH_MSG_VERBOSE("Starting sysExecute for AthAsynchronousAlgorithm on slot {}",
                  ctx.slot());
  if (m_currentCtx.get() == nullptr) {
    // const_cast because fiber_specific_ptr doesn't support const pointers
    // The const is never actually violated
    EventContext* ctx_temp ATLAS_THREAD_SAFE = const_cast<EventContext*>(&ctx);
    m_currentCtx.reset(ctx_temp);
  } else if (m_currentCtx->evt() != ctx.evt() ||
             m_currentCtx->slot() != ctx.slot()) {
    ATH_MSG_ERROR("m_currentCtx is set to {} (slot {}) but incorrect. "
                  "It should be {} (slot {})",
                  m_currentCtx->evt(), m_currentCtx->slot(),
                  ctx.evt(), ctx.slot());
    return StatusCode::FAILURE;
  }
  return Gaudi::AsynchronousAlgorithm::sysExecute(ctx);
}
 
StatusCode AthAsynchronousAlgorithm::restoreAfterSuspend() const {
  auto* currentCtx = m_currentCtx.get();
  ATH_MSG_DEBUG("Setting current context to {}", static_cast<void*>(currentCtx));
  Gaudi::Hive::setCurrentContext(currentCtx);
  return StatusCode::SUCCESS;
}