WebdaqInfoSvc.cxx File Reference

#include "WebdaqInfoSvc.h"
#include "GaudiKernel/IIncidentSvc.h"
#include "AthenaInterprocess/Incidents.h"
#include "hltinterface/ContainerFactory.h"
#include "hltinterface/GenericHLTContainer.h"
#include "webdaq/webdaq.hpp"
#include <nlohmann/json.hpp>
#include <cstdlib>
#include <utility>

Include dependency graph for WebdaqInfoSvc.cxx:

Go to the source code of this file.

Classes
struct	WebdaqInfoSvc::Holder
	One entry per registered IS object. More...

Functions
StatusCode WebdaqInfoSvc::initialize	ATLAS_NOT_THREAD_SAFE ()
	Install fatal handler with default options.

Function Documentation

ATLAS_NOT_THREAD_SAFE()

StatusCode WebdaqInfoSvc::initialize ATLAS_NOT_THREAD_SAFE ( )

inline

Install fatal handler with default options.

This is meant to be easy to call from python via ctypes.

Definition at line 41 of file WebdaqInfoSvc.cxx.

{
  //Retrieve environment variables
  const char* tdaq_partition_cstr = std::getenv("TDAQ_PARTITION");
  if (tdaq_partition_cstr != nullptr) {
    m_partition = std::string(tdaq_partition_cstr);
    ATH_MSG_INFO("Partition: " << m_partition);
  } else {
    ATH_MSG_ERROR("TDAQ_PARTITION environment variable not set");
    return StatusCode::FAILURE;
  }
  const char* tdaqWebdaqBase_cstr = std::getenv("TDAQ_WEBDAQ_BASE");
  if (tdaqWebdaqBase_cstr != nullptr) {
    m_tdaqWebdaqBase = std::string(tdaqWebdaqBase_cstr);
    ATH_MSG_INFO("TDAQ_WEBDAQ_BASE value: " << m_tdaqWebdaqBase);
  } else {
    ATH_MSG_ERROR("TDAQ_WEBDAQ_BASE environment variable not set! "
                  "Is needed for the IS publication through webdaq");
    return StatusCode::FAILURE;
  }
  const char* tdaq_is_server = std::getenv("TDAQ_IS_SERVER");
  if (tdaq_is_server != nullptr) {
    m_tdaqIsServerName = std::string(tdaq_is_server);
  } else {
    m_tdaqIsServerName = m_isServerName.value();
  }
  ATH_MSG_INFO("TDAQ_IS_SERVER value: " << m_tdaqIsServerName);
 
  // Install as the IInfoRegister singleton 
  hltinterface::IInfoRegister::setInstance(this, /*force=*/true);
  ATH_MSG_INFO("Installed WebdaqInfoSvc as the hltinterface::IInfoRegister singleton");
 
  // Provide a default ContainerFactory to build GenericHLTContainer instances via ContainerFactory::getInstance() 
  m_factory = hltinterface::ContainerFactory::getInstance();
  if (m_factory) {
    ATH_MSG_INFO("Reusing the hltinterface::ContainerFactory installed by another component");
  }
  else {
    m_factory = std::make_shared<hltinterface::ContainerFactory>();
    hltinterface::ContainerFactory::setInstance(m_factory);
    ATH_MSG_INFO("Installed the default hltinterface::ContainerFactory");
  }
 
  // Start publishing thread after fork
  ServiceHandle<IIncidentSvc> incSvc("IncidentSvc", name());
  ATH_CHECK( incSvc.retrieve() );
  incSvc->addListener(this, AthenaInterprocess::UpdateAfterFork::type());
  return StatusCode::SUCCESS;
}