PluginManager.cpp

Go to the documentation of this file.

/*
 * DUNE DAQ modification notice:
 * This file has been modified from the original ATLAS ers source for the DUNE DAQ project.
 * Fork baseline commit: 8267df82a4f6fe6bf02c4014923eba19eddc4614 (2020-04-14).
 * Renamed since fork: yes (from src/PluginManager.cxx to src/PluginManager.cpp).
 *
 * Original copyright:
 * Copyright (C) 2001-2020 CERN for the benefit of the ATLAS collaboration.
 * Licensed under the Apache License, Version 2.0.
 */
 
#ifndef __rtems__
#include <dlfcn.h>
#endif
 
#include <vector>
 
#include <ers/internal/PluginManager.hpp>
#include <ers/internal/Util.hpp>
#include <ers/internal/macro.hpp>
 
namespace {
const char* const SEPARATOR = ":";
const char* const DefaultLibraryName =
  "ers_AbortStream_ersStream:ers_ExitStream_ersStream:ers_FilterStream_ersStream:ers_GlobalLockStream_ersStream:ers_"
  "LockStream_ersStream:ers_NullStream_ersStream:ers_RFilterStream_ersStream:ers_StandardStream_ersStream:ers_"
  "ThrottleStream_ersStream:ers_ThrowStream_ersStream";
const char* const EnvironmentName = "DUNEDAQ_ERS_STREAM_LIBS";
}
 
namespace ers {
 
PluginManager::SharedLibrary::SharedLibrary(const std::string& name)
{
#ifndef __rtems__
  std::string library = "lib" + name + ".so";
 
  handle_ = dlopen(library.c_str(), RTLD_LAZY | RTLD_GLOBAL);
  char* error = dlerror();
 
  if (!handle_) {
    throw PluginException(error);
  }
#endif
}
 
PluginManager::SharedLibrary::~SharedLibrary()
{
  // Library should be unloaded, but with some compilers (e.g gcc323)
  // this results in crash of program, because it is not recognized
  // that the library is still in use
 
  // dlclose( handle_ );
}
 
PluginManager::~PluginManager()
{
  LibMap::iterator it = libraries_.begin();
  for (; it != libraries_.end();) {
    delete it->second;
    libraries_.erase(it++);
  }
}
 
PluginManager::PluginManager()
{
  const char* env = ::getenv(EnvironmentName);
  std::string config(env ? std::string(env) + SEPARATOR + DefaultLibraryName : DefaultLibraryName);
 
  std::vector<std::string> libs;
  ers::tokenize(config, SEPARATOR, libs);
 
  for (size_t i = 0; i < libs.size(); i++) {
    LibMap::iterator it = libraries_.find(libs[i]);
    if (it == libraries_.end()) {
      try {
        libraries_[libs[i]] = new SharedLibrary(libs[i]);
      } catch (PluginException& ex) {
        ERS_INTERNAL_ERROR("Library " << libs[i] << " can not be loaded because " << ex.reason())
      }
    }
  }
}
}