HanConfig.cxx

Go to the documentation of this file.

/*
  Copyright (C) 2002-2025 CERN for the benefit of the ATLAS collaboration
*/
 
#include "DataQualityInterfaces/HanConfig.h"
 
#include <cstring>  // strncmp()
 
#include <iostream>
 
#include <sstream>
 
#include <TCollection.h>
#include <TDirectory.h>
#include <TFile.h>
#include <TGraph.h>
#include <TH1.h>
#include <TKey.h>
#include <TBox.h>
#include <TLine.h>
#include <TROOT.h>
#include <TEfficiency.h>
#include <TPython.h>
 
#include "DataQualityInterfaces/CompositeAlgorithm.h"
#include "DataQualityInterfaces/ConditionsSingleton.h"
#include "DataQualityInterfaces/DatabaseConfig.h"
#include "DataQualityInterfaces/HanAlgorithmConfig.h"
#include "DataQualityInterfaces/HanConfigCompAlg.h"
#include "DataQualityInterfaces/HanConfigAlgLimit.h"
#include "DataQualityInterfaces/HanConfigAlgPar.h"
#include "DataQualityInterfaces/HanConfigAssessor.h"
#include "DataQualityInterfaces/HanConfigGroup.h"
#include "DataQualityInterfaces/HanConfigMetadata.h"
#include "DataQualityInterfaces/HanConfigParMap.h"
#include "DataQualityInterfaces/HanOutput.h"
#include "DataQualityInterfaces/HanUtils.h"
#include "DataQualityInterfaces/MiniConfig.h"
#include "DataQualityInterfaces/HanInputRootFile.h"
#include "dqm_core/LibraryManager.h"
#include "dqm_core/Parameter.h"
#include "dqm_core/ParameterConfig.h"
#include "dqm_core/Region.h"
#include "dqm_core/RegionConfig.h"
#include <boost/algorithm/string/case_conv.hpp>
#include <boost/algorithm/string/classification.hpp>
#include <boost/algorithm/string/split.hpp>
#include <boost/algorithm/string/join.hpp>
#include <boost/algorithm/string/trim.hpp>
#include <utility>
 
#include "CxxUtils/checker_macros.h"
ATLAS_NO_CHECK_FILE_THREAD_SAFETY;  // standalone application
 
ClassImp(dqi::HanConfig)
 
namespace dqi {
 
// *********************************************************************
// Public Methods
// *********************************************************************
 
HanConfig::
HanConfig()
  : m_config(0)
  , m_dqRoot()
  , m_top_level(0)
  , m_metadata(0)
{
}
 
 
HanConfig::
~HanConfig()
{
  delete m_config;
  /* delete m_dqRoot; */
  delete m_top_level;
  if (m_metadata) m_metadata->Delete();
  delete m_metadata;
}
 
namespace {
  bool TestMiniNodeIsRegex(const MiniConfigTreeNode* node) {
    std::string regexflag(node->GetAttribute("regex"));
    boost::algorithm::to_lower(regexflag);
    if (regexflag == "1" || regexflag == "true" || regexflag == "yes") {
        return true;
    }
    return false;
  }
}
 
void
HanConfig::
AssembleAndSave( const std::string & infileName, const std::string & outfileName, const std::string & connectionString, long runNumber, bool bulk)
{
  std::unique_ptr< TFile > outfile( TFile::Open( outfileName.c_str(),
                                                 "RECREATE" ) );
  DirMap_t directories;
 
  // Collect reference histograms and copy to config file
  MiniConfig refconfig;
  refconfig.AddKeyword("reference");
  refconfig.ReadFile(infileName);
  TMap refsourcedata;
  refsourcedata.SetOwnerKeyValue();
  RefVisitor refvisitor( outfile.get(), directories, &refsourcedata );
  refconfig.SendVisitor( refvisitor );
 
  DatabaseConfig databaseConfig(connectionString, runNumber);
  RefWriter refwriter(databaseConfig, bulk);
  refconfig.SendWriter( refwriter );
  databaseConfig.Disconnect();
 
  // Collect threshold definitions
  MiniConfig thrconfig;
  thrconfig.AddKeyword("thresholds");
  thrconfig.AddAttributeKeyword("limits");
  thrconfig.ReadFile(infileName);
 
  // Collect algorithm definitions
  MiniConfig algconfig;
  algconfig.AddKeyword("algorithm");
  algconfig.ReadFile(infileName);
 
  // Collect region definitions
  MiniConfig regconfig;
  regconfig.AddKeyword("output");
  regconfig.ReadFile(infileName);
 
  // Collect histogram definitions
  MiniConfig histconfig;
  histconfig.AddKeyword("dir");
  histconfig.AddAttributeKeyword("hist");
  histconfig.SetAttribKeywordPropagateDown(false);
  histconfig.ReadFile(infileName);
 
  // Collect and write composite-algorithm definitions
  MiniConfig compalgconfig;
  compalgconfig.AddKeyword("compositealgorithm");
  compalgconfig.ReadFile(infileName);
  CompAlgVisitor compalgvisitor(outfile.get(), compalgconfig);
  compalgconfig.SendVisitor(compalgvisitor);
 
  MiniConfig metadataconfig;
  metadataconfig.AddKeyword("metadata");
  metadataconfig.ReadFile(infileName);
  MetadataVisitor metadatavisitor(outfile.get(), metadataconfig);
  metadataconfig.SendVisitor(metadatavisitor);
 
  // Assemble into a hierarchical configuration
  outfile->cd();
  std::unique_ptr< HanConfigGroup > root( new HanConfigGroup() );
 
  RegionVisitor regvisitor( root.get(), algconfig, thrconfig, refconfig, directories );
  regconfig.SendVisitor( regvisitor );
 
  AssessmentVisitor histvisitor( root.get(), algconfig, thrconfig, refconfig, outfile.get(),
                 directories, &refsourcedata );
  histconfig.SendVisitor( histvisitor );
 
  outfile->WriteTObject(&refsourcedata, "refsourcedata");
  outfile->cd();
  root->Write();
  outfile->Write();
  outfile->Close();
}
 
void
HanConfig::
BuildMonitors( std::string configName, HanInputRootFile& input, HanOutput& output )
{
  bool isInitialized = Initialize( configName );
  if( !isInitialized ) {
    return;
  }
 
  m_dqRoot = BuildMonitorsNewRoot( std::move(configName), input, output );
 
  output.setConfig( this );
}
 
boost::shared_ptr<dqm_core::Region>
HanConfig::
BuildMonitorsNewRoot( std::string configName, HanInputRootFile& input, dqm_core::Output& output )
{
  bool isInitialized = Initialize( configName );
  if( !isInitialized ) {
    return boost::shared_ptr<dqm_core::Region>();
  }
 
  TDirectory* topdir = const_cast<TDirectory*>(input.getBasedir());
  TPython::Bind(m_config, "config");
  TPython::Bind(m_top_level, "top_level");
  TPython::Bind(topdir, "path");
  TPython::Exec("from DataQualityInterfaces.han import FixRegion, logLevel");
  const char* debugflag = std::getenv("HANDEBUG");
  if (!debugflag) {
    TPython::Exec("logLevel('INFO')");
  } else {
    TPython::Exec("logLevel('DEBUG')");
  }
 
#if ROOT_VERSION_CODE >= ROOT_VERSION(6,33,01)
  std::any result;
  TPython::Exec ("_anyresult = ROOT.std.make_any['dqi::HanConfigGroup'](FixRegion(config, top_level, path))", &result);
  auto new_top_level = new dqi::HanConfigGroup (std::any_cast<HanConfigGroup>(result));
#else
  HanConfigGroup* new_top_level = TPython::Eval("FixRegion(config, top_level, path)");
#endif
  delete m_top_level;
  m_top_level = new_top_level;
 
  std::string algName( m_top_level->GetAlgName() );
  std::string algLibName( m_top_level->GetAlgLibName() );
  if( algLibName != "" ) {
    try {
      dqm_core::LibraryManager::instance().loadLibrary( algLibName );
    }
    catch ( dqm_core::Exception& ex ) {
      //std::cout << "Can't load library " << algLibName << ". Continuing regardless ..." << std::endl;
    }
  }
  dqm_core::RegionConfig regc( algName, 1.0 );
  boost::shared_ptr<dqm_core::Region> retval(dqm_core::Region::createRootRegion( "top_level", input, output, regc ));
 
  ConfigVisitor confvisitor( m_config, &output );
  m_top_level->Accept( confvisitor, retval );
  return retval;
}
 
void
HanConfig::
BuildConfigOutput( std::string configName, TFile* inputFile, const std::string & path,
                   HanOutput::DQOutputMap_t* outputMap, TSeqCollection* outputList )
{
  bool isInitialized = Initialize( configName );
  if( !isInitialized ) {
    return;
  }
 
  if( inputFile == 0 ) {
    return;
  }
 
  TDirectory* basedir(0);
  if( path != "" ) {
    std::string pathForSearch = path + "/dummyName";
    basedir = ChangeInputDir( inputFile, std::move(pathForSearch) );
  }
 
  if( basedir == 0 )
    basedir = inputFile;
 
  TIter mdIter(m_metadata);
  TSeqCollection* mdList = newTList("HanMetadata_");
  HanConfigMetadata* md(0);
  while ((md = dynamic_cast<HanConfigMetadata*>(mdIter()))) {
    mdList->Add( md->GetList(basedir,*outputMap) );
  }
  TSeqCollection* top_level_list = m_top_level->GetList(basedir,*outputMap);
  top_level_list->Add( mdList );
  outputList->Add( top_level_list );
}
 
 
TObject*
HanConfig::
GetReference( std::string& groupName, std::string& name )
{
  /*  if( m_top_level == 0 ) {
    return 0;
  }
 
  HanConfigGroup* parent = m_top_level->GetNode(groupName);
  if( parent == 0 ) {
    parent = m_top_level;
    } */
  
  std::unique_ptr<const HanConfigAssessor> a(GetAssessor( groupName, name ));
  if (!a.get()) return 0;
  std::string refName( a->GetAlgRefName() );
  if( refName != "" ) {
    TKey* key = getObjKey( m_config, refName );
    if( key != 0 ) {
      //TObject* ref = m_config->Get(refName.c_str());
      TObject* ref = key->ReadObj();
      if (ref)
    return ref;
    }
  }
 
  return 0;
}
 
std::string
SplitReference(std::string refPath, const std::string& refName )
{
  // this will never be run in a multithread environment
  static std::map<std::string, std::string> mappingCache;
 
  //Split comma sepated inputs into individual file names
  std::vector<std::string> refFileDirList;
  boost::split(refFileDirList, refPath, boost::is_any_of(","));
 
  // construct vector of files (& clean up leading/trailing spaces)
  std::vector<std::string> refFileList;
  for (const auto& dir : refFileDirList ) {
    refFileList.push_back(boost::algorithm::trim_copy(dir+refName));
  }
 
  // Use TFile::Open | syntax to try opening the files in sequence
  std::string tfilestring = boost::algorithm::join(refFileList, "|");
  // have we already resolved?
  const auto& cachehit = mappingCache.find(tfilestring);
  if (cachehit != mappingCache.end()) {
    return cachehit->second;
  }
  // if not, do lookup
  if (const auto* f = TFile::Open(tfilestring.c_str())) {
    mappingCache[tfilestring] = f->GetName();
  } else {
    std::cerr << "Unable to open any reference files in " << tfilestring << ", reference will not be included" << std::endl;
    mappingCache[tfilestring] = "";
  }
  return mappingCache[tfilestring];
}
 
const HanConfigAssessor*
HanConfig::
GetAssessor( std::string& groupName, std::string& name ) const
{
  if( m_top_level == 0 ) {
    return 0;
  }
 
  HanConfigGroup* parent = m_top_level->GetNode(groupName);
  if( parent == 0 ) {
    parent = m_top_level;
  }
 
  const HanConfigAssessor& a = parent->GetAssessor(name);
 
  return new HanConfigAssessor(a);
}
 
void
HanConfig::
GetRegexList(std::set<std::string>& regexlist)
{
  RegexVisitor rv(regexlist);
  m_top_level->Accept(rv, boost::shared_ptr<dqm_core::Region>());
}
 
// *********************************************************************
// Protected Methods
// *********************************************************************
 
HanConfig::RefVisitor::
RefVisitor( TFile* outfile_, HanConfig::DirMap_t& directories_, TMap* refsourcedata_ )
  : m_outfile(outfile_)
  , m_directories(directories_)
  , m_refsourcedata(refsourcedata_)
{
}
 
 
void
HanConfig::RefVisitor::
Visit( const MiniConfigTreeNode* node )
{
  TObject* obj;
  std::string name = node->GetAttribute("name");
  std::string fileName = node->GetAttribute("file");
  if( fileName != "" && name != "" && name != "same_name" ) {
    fileName = SplitReference(node->GetAttribute("location"), fileName);
    std::string refInfo = node->GetAttribute("info");
    if (refInfo == "") {
      std::cerr << "INFO: Reference " << name << " is defined without an \"info\" attribute. Consider adding one" 
                << std::endl;
    }
    std::unique_ptr<TFile> infile( TFile::Open(fileName.c_str()) );
    TKey* key = getObjKey( infile.get(), name );
    if( key == 0 ) {
      std::cerr << "WARNING: HanConfig::RefVisitor::Visit(): Reference not found: \"" << name << "\"\n";
      return;
    }
//     TDirectory* dir = ChangeOutputDir( m_outfile, name, m_directories );
//     dir->cd();
    //sami
    m_outfile->cd();
    obj = key->ReadObj();
    //    obj->Write();
    std::string newHistoName=dqi::ConditionsSingleton::getInstance().getNewRefHistoName();
    //node->SetAttribute("newname",newHistoName,false);//add new name to tree
    //    std::cout<<"Writing \""<<name<<"\" in \""<<fileName<<"\" with new name \""<<newHistoName<<"\""<<std::endl;
    dqi::ConditionsSingleton::getInstance().setNewReferenceName(fileName+":/"+name,newHistoName);
    obj->Write(newHistoName.c_str());
    delete obj;
    TObjString* fnameostr = new TObjString(fileName.c_str());
    m_refsourcedata->Add(new TObjString(newHistoName.c_str()),
             fnameostr);
    if (! m_refsourcedata->FindObject(fileName.c_str())) {
      m_refsourcedata->Add(fnameostr->Clone(), refInfo != "" ? new TObjString(refInfo.c_str())
               : new TObjString("Reference"));
    }
  }
}
 
HanConfig::RefWriter::
RefWriter( DatabaseConfig& databaseConfig_, const bool bulk)
  : m_databaseConfig(databaseConfig_),
    m_bulk(bulk)
{
}
 
 
void
HanConfig::RefWriter::
Write( MiniConfigTreeNode* node )
{
  std::string database = node->GetAttribute("database");
 
  if(database != "") {
    database += (m_bulk ? "-physics-UPD4" : "-express-UPD1");
    nlohmann::json jsonPayload = m_databaseConfig.GetPayload(database);
    std::string reference = node->GetName();
 
    if(jsonPayload.find(reference) != jsonPayload.end()) {
      nlohmann::json referenceJson = jsonPayload[std::move(reference)];
      for (nlohmann::json::iterator it = referenceJson.begin(); it != referenceJson.end(); ++it) {
        node->SetAttribute(it.key(), it.value(), false);
      }
    } else {
      std::cerr << "Unable to find reference definition in database: " << reference << '\n';
    }
   }
}
 
HanConfig::AssessmentVisitorBase::
AssessmentVisitorBase( HanConfigGroup* root_, const MiniConfig& algConfig_,
                       const MiniConfig& thrConfig_, const MiniConfig& refConfig_,
                       TFile* outfile_, HanConfig::DirMap_t& directories_,
               TMap* refsourcedata_ )
  : m_root(root_)
  , m_algConfig(algConfig_)
  , m_thrConfig(thrConfig_)
  , m_refConfig(refConfig_)
  , m_outfile(outfile_)
  , m_directories(directories_)
  , m_refsourcedata(refsourcedata_)
{
}
 
std::shared_ptr<TFile>
HanConfig::AssessmentVisitorBase::
GetROOTFile( std::string& fname )
{
  auto it = m_filecache.find(fname);
  if (it != end(m_filecache)) {
    return it->second;
  } else {
    if (m_badPaths.find(fname) != m_badPaths.end()) {
      return std::shared_ptr<TFile>(nullptr);
    }
    std::shared_ptr<TFile> thisptr(TFile::Open(fname.c_str()));
    if (thisptr.get()) {
      return ( m_filecache[fname] = std::move(thisptr) );
     } else {
       m_badPaths.insert(fname);
      return thisptr;
    }
  }
}
 
void
HanConfig::AssessmentVisitorBase::
PopulateKeyCache(const std::string& fname, std::shared_ptr<TFile> & file) {
  auto& vec = m_keycache[fname];
  dolsr(file.get(), vec);
}
 
void
HanConfig::AssessmentVisitorBase::
EnsureKeyCache(std::string& fname) {
  DisableMustClean dmc;
  auto file = GetROOTFile(fname);
  if (file) {
    if (m_keycache.find(fname) != m_keycache.end()) {
      return;
    } else {
      m_keycache[fname].reserve(100000);
      PopulateKeyCache(fname, file);
    }
  }
}
 
float AttribToFloat(const MiniConfigTreeNode* node, const std::string& attrib,
            const std::string& warningString, bool local=false)
{
  std::istringstream valstream;
  if (local) {
    valstream.str(node->GetAttributeLocal(attrib));
  } else {
    valstream.str(node->GetAttribute(attrib));
  }
  float val;
  valstream >> val;
  if (! valstream) {
    std::cerr << warningString << std::endl;
    return 0;
  } else {
    return val;
  }
}
 
void
HanConfig::AssessmentVisitorBase::
GetAlgorithmConfiguration( HanConfigAssessor* dqpar, const std::string& algID,
                           const std::string& assessorName )
{
  // bool hasName(false);
  std::set<std::string> algAtt;
  m_algConfig.GetAttributeNames( algID, algAtt );
  std::set<std::string>::const_iterator algAttEnd = algAtt.end();
  for( std::set<std::string>::const_iterator i = algAtt.begin(); i != algAttEnd; ++i ) {
    std::string trail("");
    std::string::size_type pos = (*i).find('|');
    if (pos != std::string::npos) {
      trail = (*i).substr(pos + 1, std::string::npos);
    }
    if( *i == "name" ) {
      // hasName = true;
      std::string algName( m_algConfig.GetStringAttribute(algID,"name") );
      dqpar->SetAlgName( std::move(algName) );
    }
    else if( *i == "libname" ) {
      std::string algLibName( m_algConfig.GetStringAttribute(algID,"libname") );
      dqpar->SetAlgLibName( std::move(algLibName) );
    }
    else if( *i == "thresholds" || trail == "thresholds" ) {
      std::string thrID( m_algConfig.GetStringAttribute(algID,*i) );
      std::set<std::string> thrAtt;
      m_thrConfig.GetAttributeNames( thrID, thrAtt );
      std::set<std::string>::const_iterator thrAttEnd = thrAtt.end();
      for( std::set<std::string>::const_iterator t = thrAtt.begin(); t != thrAttEnd; ++t ) {
        std::string thrAttName = *t;
        std::string thrAttVal = m_thrConfig.GetStringAttribute( thrID, thrAttName );
        std::string limName = thrAttVal + std::string("/") + thrAttName;
        HanConfigAlgLimit algLim;
        if (pos != std::string::npos) {
          algLim.SetName( (*i).substr(0, pos) + std::string("|") + *t );
        } else {
          algLim.SetName( *t );
        }
        algLim.SetGreen( m_thrConfig.GetFloatAttribute(limName,"warning") );
        algLim.SetRed( m_thrConfig.GetFloatAttribute(std::move(limName),"error") );
        dqpar->AddAlgLimit( algLim );
      }
    }
    else if( *i == "reference" ) {
      // structure: if regex, store TMap of matching hist name -> names of reference objects
      // if not regex, just store names of reference objects
      // reference objects are TObjArrays if multiple references, else some kind of TObject
      std::string tmpRefID=m_algConfig.GetStringAttribute(algID,"reference");
      //std::cout<<"Got tmpRefID=\""<<tmpRefID<<"\""<<std::endl;
      dqi::ConditionsSingleton &CS=dqi::ConditionsSingleton::getInstance();
      //parses
      std::vector<std::pair<std::string,std::string> > condPairs=CS.getConditionReferencePairs(std::move(tmpRefID));
      std::stringstream newRefString;
      // for each condition ...
      for(size_t t=0;t<condPairs.size();t++){
        bool refsuccess(false);
        std::string refID=condPairs.at(t).second;
        std::string cond=condPairs.at(t).first;
        std::vector<std::string> refIDVec;
        // the following allows us to accumulate objects as necessary
        std::vector<std::vector<std::pair<std::string, std::shared_ptr<TObject>>>> objects;
        std::string newRefId("");
        bool isMultiRef(false);
        std::vector<std::string> sourceMatches;
        if (refID[0] == '[') {
          std::string cleanedRefID = refID;
          boost::algorithm::trim_if(cleanedRefID, boost::is_any_of("[] "));
          isMultiRef = true;
          boost::split(refIDVec, cleanedRefID, boost::is_any_of(","));
          // toarray = new TObjArray();
          // toarray->SetOwner(kTRUE);
        } else {
          refIDVec.push_back(refID);
        }
 
        // special case: not same_name, and is not a multiple reference
        // in these cases, things have been copied into file already
        std::string algRefName( m_refConfig.GetStringAttribute(refID,"name") );
        std::string algRefInfo( m_refConfig.GetStringAttribute(refID,"info") );
        std::string algRefFile( m_refConfig.GetStringAttribute(refID,"file") );
        if (algRefName != "same_name" && !isMultiRef) {
          newRefId=CS.getNewReferenceName(algRefFile+":/"+algRefName,true);
          
          if(newRefId.empty()){
            std::string algRefPath( m_refConfig.GetStringAttribute(refID,"path") );
            std::cerr<<"Warning New reference id is empty for refId=\""
                    <<refID<<"\", cond=\""<<cond<<"\", assessorName=\""
                    <<assessorName<<"\", algRefName=\""
                    <<algRefName<<"\""<<std::endl;
            std::cerr << "AlgRefPath=" << algRefPath << " AlgRefInfo=" << algRefInfo << std::endl;
          } else {
            refsuccess = true;
          }
        } else {
          // is same_name, or a regex multiple reference
          objects.resize(refIDVec.size());
          std::string absAlgRefName, algRefPath, algRefInfo;    
          for (size_t iRefID = 0; iRefID < refIDVec.size(); ++iRefID) {
            const auto& thisRefID = refIDVec[iRefID];
            algRefName = m_refConfig.GetStringAttribute(thisRefID,"name");
            algRefPath = m_refConfig.GetStringAttribute(thisRefID,"path");
            algRefInfo = m_refConfig.GetStringAttribute(thisRefID,"info");
            algRefFile = m_refConfig.GetStringAttribute(thisRefID,"file");
            if (algRefInfo == "") {
              std::cerr << "INFO: Reference " << thisRefID << " is defined without an \"info\" attribute. Consider adding one" 
                        << std::endl;
            }
            absAlgRefName = "";
            if( algRefPath != "" ) {
              absAlgRefName += algRefPath;
              absAlgRefName += "/";
            }
            if( algRefName == "same_name" ) {//sameName reference
              algRefName = assessorName;
              absAlgRefName += algRefName;
              algRefFile = SplitReference( m_refConfig.GetStringAttribute(thisRefID,"location"), algRefFile);
 
              if( algRefFile != "" ) {
                std::shared_ptr<TFile> infile = GetROOTFile(algRefFile);
                if ( ! infile.get() ) {
                  std::cerr << "HanConfig::AssessmentVistorBase::GetAlgorithmConfiguration: Reference file " << algRefFile << " not found" << std::endl;
                  continue;
                }
                std::vector<std::string> localMatches;
                if (dqpar->GetIsRegex()) {
                  if (! sourceMatches.empty()) {
                    std::cerr << "same_name appears twice in a reference request???" << std::endl;
                  } else {
                    // change Python to Boost syntax for named captures
                    std::string regexPattern = boost::regex_replace(absAlgRefName, boost::regex("\\(\\?P=([^)]*)\\)"), "\\\\k<\\1>", boost::format_all);
                    boost::regex re(boost::replace_all_copy(regexPattern, "(?P", "(?"));
                    EnsureKeyCache(algRefFile);
                    for (const auto& iKey: m_keycache[algRefFile]) {
                      if (boost::regex_match(iKey, re)) {
                        sourceMatches.push_back(iKey);
                        TKey* key = getObjKey(infile.get(), iKey);
                        m_outfile->cd(); //we are writing to the / folder of file
                        objects[iRefID].emplace_back(iKey, key->ReadObj());
                      }
                    }
                  }
                } else {
                  TKey* key = getObjKey( infile.get(), absAlgRefName );
                  if( key == 0 ) {
                    // no reference
                    continue;
                  }
                  m_outfile->cd(); //we are writing to the / folder of file
                  std::shared_ptr<TObject> q(key->ReadObj());
                  objects[iRefID].emplace_back(absAlgRefName, q);
                }
              }
            } else {
              absAlgRefName += algRefName;
              algRefFile = SplitReference( m_refConfig.GetStringAttribute(thisRefID,"location"), algRefFile);
 
              if( algRefFile != "" ) {
                std::shared_ptr<TFile> infile = GetROOTFile(algRefFile);
                if ( ! infile.get() ) {
                  std::cerr << "HanConfig::AssessmentVistorBase::GetAlgorithmConfiguration: Reference file " << algRefFile << " not found" << std::endl;
                  continue;
                }
 
                TKey* key = getObjKey( infile.get(), absAlgRefName );
                if( key == 0 ) {
                  // no reference
                  std::cerr << "Couldn't find reference " << absAlgRefName << std::endl;
                  continue;
                }
                m_outfile->cd(); //we are writing to the / folder of file
                std::shared_ptr<TObject> q(key->ReadObj());
                TNamed* qn = dynamic_cast<TNamed*>(q.get());
                if (isMultiRef && qn) {
                  std::string multirefname = thisRefID; // fallback
                  if (algRefInfo != "") {
                    multirefname = algRefInfo;
                  } else if (algRefFile != "") {
                    multirefname = algRefFile;
                  }
                  qn->SetName(multirefname.c_str());
                }
                objects[iRefID].emplace_back(absAlgRefName, q);
              } else {
                std::cerr << "No file specified for " << absAlgRefName << " ?" << std::endl;
              }
            }
          }
 
          std::shared_ptr<TObject> toWriteOut;
          std::string algRefUniqueName;
          std::string algRefSourceInfo = (algRefInfo != "" ? algRefInfo.c_str() : "Reference");
 
          if (!isMultiRef) {
            // is this a regex?
            if (dqpar->GetIsRegex() && !objects[0].empty()) {
              refsuccess = true;
              TMap* tmapobj = new TMap();
              tmapobj->SetOwnerKeyValue();
              for (const auto& thisPair: objects[0]) {
                std::unique_ptr<TObject> cobj(thisPair.second->Clone());
                TNamed* hobj = dynamic_cast<TNamed*>(cobj.get());
                if (hobj) {
                  hobj->SetName(refID.c_str());
                }
                algRefUniqueName = algRefFile+":/"+thisPair.first;
                newRefId=CS.getNewReferenceName(algRefUniqueName,true);
                if(newRefId.empty()){
                  newRefId=CS.getNewRefHistoName();
                  CS.setNewReferenceName(algRefUniqueName,newRefId);
                  m_refsourcedata->Add(new TObjString(newRefId.c_str()),
                    new TObjString(algRefFile.c_str()));
                  cobj->Write(newRefId.c_str(), 1);
                }
                m_outfile->cd();
                std::string maprefstring(thisPair.first);
                if (algRefPath != "") {
                  boost::replace_first(maprefstring, algRefPath + "/", "");
                }
                tmapobj->Add(new TObjString(maprefstring.c_str()), 
                            new TObjString(newRefId.c_str()));
              }
              toWriteOut.reset(tmapobj);
              algRefUniqueName = algRefFile+"_regex:/"+dqpar->GetUniqueName();
            }
            else {
              algRefUniqueName = algRefFile+":/"+absAlgRefName;
              if (! objects[0].empty()) {
                refsuccess = true;
                toWriteOut = objects[0][0].second;
              }
            }
          } else { // is multiref
            algRefUniqueName=cond+"_multiple:/"+absAlgRefName;
            algRefSourceInfo="Multiple references";
            // is this a regex?
            if (dqpar->GetIsRegex()) {
              // not implemented for now
            } else {
              TObjArray* toarray = new TObjArray();
              toarray->SetOwner(true);
              for (size_t iRef = 0; iRef < objects.size(); ++iRef) {
                // check that object is actually valid (might be missing a reference)
                if (! objects[iRef].empty()) {
                  toarray->Add(objects[iRef][0].second->Clone());
                }
              }
              toWriteOut.reset(toarray);
              refsuccess = true;
            }
          }
 
          if (refsuccess && toWriteOut) {
            // register top level object
            newRefId=CS.getNewReferenceName(algRefUniqueName,true);
            if(newRefId.empty()){
              newRefId=CS.getNewRefHistoName();
              CS.setNewReferenceName(algRefUniqueName,newRefId);
              if (! isMultiRef) {
                // ref to file
                m_refsourcedata->Add(new TObjString(newRefId.c_str()),
                  new TObjString(algRefFile.c_str()));
                // file to further info
                if (! m_refsourcedata->FindObject(algRefFile.c_str())) {
                  m_refsourcedata->Add(new TObjString(algRefFile.c_str()), 
                    new TObjString(algRefSourceInfo.c_str()));
                }
              } else {
                // ref to "Multiple references"
                m_refsourcedata->Add(new TObjString(newRefId.c_str()), 
                  new TObjString(algRefSourceInfo.c_str()));                
              }
            }
            m_outfile->cd();
            toWriteOut->Write(newRefId.c_str(), 1);
          }
        }
 
        if (!newRefId.empty()) {
          if(!cond.empty()){
            newRefString<<cond<<":"<<newRefId<<";";
          }else{
            newRefString<<newRefId;
          }
        }
      }
      dqpar->SetAlgRefName((newRefString.str()));
 
    }else {
      std::string stringValue = m_algConfig.GetStringAttribute( algID, *i );
      float numberValue;
      std::istringstream parser( stringValue );
      parser >> numberValue;
      if ( ! parser ) {
        HanConfigParMap algPar;
        algPar.SetName( *i );
        algPar.SetValue( stringValue );
        dqpar->AddAlgStrPar( algPar );
      } else {
        HanConfigAlgPar algPar;
        algPar.SetName( *i );
        algPar.SetValue( numberValue );
        dqpar->AddAlgPar( algPar );
      }
    }
  }
}
 
 
HanConfig::RegionVisitor::
RegionVisitor( HanConfigGroup* root_, const MiniConfig& algConfig_,
               const MiniConfig& thrConfig_, const MiniConfig& refConfig_,
               HanConfig::DirMap_t& directories_ )
  : AssessmentVisitorBase( root_, algConfig_, thrConfig_, refConfig_, 0, directories_, nullptr )
{
}
 
 
void
HanConfig::RegionVisitor::
Visit( const MiniConfigTreeNode* node )
{
  const MiniConfigTreeNode* parent = node->GetParent();
  if( parent == 0 )
    return;
 
  const MiniConfigTreeNode* grandparent = parent->GetParent();
  auto alloc = std::make_unique<HanConfigGroup>();
  HanConfigGroup* reg = (grandparent==0) ? m_root : alloc.get();
 
 
 
  reg->SetName( node->GetName() );
  reg->SetPathName( node->GetPathName() );
 
  std::string algID( node->GetAttribute("algorithm") );
  if( algID != "" ) {
    GetAlgorithmConfiguration( reg, algID );
  } else {
    std::cerr << "Warning: no summary algorithm specified for " << node->GetPathName() << std::endl
          << "This is probably not what you want" << std::endl;
  }
 
  if (node->GetAttributeLocal("weight") != "") {
    std::ostringstream err;
    err << "Weight is not a floating point attribute for " << node->GetPathName() << "; setting to 0";
    reg->SetWeight(AttribToFloat(node, "weight", err.str(), true));
  }
 
  if( grandparent != 0 ) {
    std::string path( parent->GetPathName() );
    HanConfigGroup* parentReg = m_root->GetNode( path );
    parentReg = (parentReg==0) ? m_root : parentReg;
    if( parentReg != 0 ) {
      parentReg->AddGroup( *reg );
    }
  }
}
 
HanConfig::RegexVisitor::
RegexVisitor( std::set<std::string>& regexes_ )
  : m_regexes(regexes_)
{
}
 
boost::shared_ptr<dqm_core::Node>
HanConfig::RegexVisitor::
Visit( const HanConfigAssessor* node, boost::shared_ptr<dqm_core::Region> )
{
  // ignore Groups
  if (dynamic_cast<const HanConfigGroup*>(node) != NULL) {
    return boost::shared_ptr<dqm_core::Parameter>();
  }
  if (node->GetIsRegex()) {
    m_regexes.insert(node->GetName());
  }
  return boost::shared_ptr<dqm_core::Parameter>();
}
 
HanConfig::AssessmentVisitor::
AssessmentVisitor( HanConfigGroup* root_, const MiniConfig& algConfig_,
                   const MiniConfig& thrConfig_, const MiniConfig& refConfig_,
                   TFile* outfile_, HanConfig::DirMap_t& directories_,
           TMap* refsourcedata_ )
  : AssessmentVisitorBase( root_, algConfig_, thrConfig_, refConfig_, outfile_, directories_, refsourcedata_ )
{
}
 
void
HanConfig::AssessmentVisitor::
Visit( const MiniConfigTreeNode* node )
{
  std::set<std::string> histAtt;
  node->GetAttributeNames( histAtt );
  std::set<std::string>  defined;
  std::string regID("");
  std::string algID("");
  std::set<std::string>::const_iterator histAttEnd = histAtt.end();
  for( std::set<std::string>::const_iterator h = histAtt.begin(); h != histAttEnd; ++h ) {
    const MiniConfigTreeNode* histNode = node->GetDaughter( *h );
    if( histNode == 0 )
      continue;
 
    algID = histNode->GetAttribute("algorithm");
    regID = histNode->GetAttribute("output");
 
    if( algID == "" ) {
      std::cerr << "No \"algorithm\" defined for " << histNode->GetPathName() << "\n";
      continue;
    }
 
    if( regID == "" )
      regID = "top_level";
 
    std::string strNodeName(histNode->GetName());
    std::string strHistName, strFullHistName;
    std::string::size_type atsign = strNodeName.find('@');
    if (atsign == std::string::npos) {
      strHistName = std::move(strNodeName);
      strFullHistName = histNode->GetPathName();
    } else {
      strHistName = strNodeName.substr(0, atsign);
      strFullHistName = histNode->GetPathName();
      strFullHistName.resize(strFullHistName.find('@'));
    }
 
    if( strHistName == "all_in_dir" )
      continue;
 
    if( defined.find(histNode->GetPathName()) != defined.end() )
      continue;
 
    HanConfigAssessor dqpar;
    dqpar.SetName( histNode->GetPathName() );
 
    dqpar.SetIsRegex(TestMiniNodeIsRegex(histNode));
 
    if (histNode->GetAttribute("weight") != "") {
      std::ostringstream err;
      err << "Weight attribute not a floating point type for " << histNode->GetPathName() << "; setting to zero";
      dqpar.SetWeight(AttribToFloat(histNode, "weight",
                    err.str()));
    }
 
    GetAlgorithmConfiguration( &dqpar, algID, strFullHistName );
 
    std::set<std::string> histAtt2;
    histNode->GetAttributeNames( histAtt2 );
    std::set<std::string>::const_iterator histAttEnd2 = histAtt2.end();
    for( std::set<std::string>::const_iterator h2 = histAtt2.begin(); h2 != histAttEnd2; ++h2 ) {
      if (node->GetDaughter( *h2 )
      || *h2 == "algorithm" || *h2 == "output" || *h2 == "reference"
      || *h2 == "weight" || *h2 == "regex") {
    continue;
      }
      HanConfigParMap parMap;
      parMap.SetName(*h2); parMap.SetValue(histNode->GetAttribute(*h2));
      dqpar.AddAnnotation(parMap);
    }
 
    // Add the histogram name
    HanConfigParMap parMap;
    parMap.SetName("inputname"); parMap.SetValue( strFullHistName );
    dqpar.AddAnnotation(parMap);
 
    HanConfigGroup* dqreg = m_root->GetNode( regID );
    dqreg = (dqreg==0) ? m_root : dqreg;
    if( dqreg != 0 ) {
      dqreg->AddAssessor( dqpar );
    }
    defined.insert( strFullHistName );
  }
 
  for( std::set<std::string>::const_iterator h = histAtt.begin(); h != histAttEnd; ++h ) {
    const MiniConfigTreeNode* histNode = node->GetDaughter( *h );
    if( histNode == 0 )
      continue;
 
    algID = histNode->GetAttribute("algorithm");
    regID = histNode->GetAttribute("output");
 
    if( algID == "" ) {
      std::cerr << "No \"algorithm\" defined for " << histNode->GetPathName() << "\n";
      continue;
    }
 
    if( regID == "" )
      regID = "top_level";
 
    std::string strNodeName(histNode->GetName());
    std::string strHistName, strFullHistName, extension;
    std::string::size_type atsign = strNodeName.find('@');
    if (atsign == std::string::npos) {
      strHistName = std::move(strNodeName);
      strFullHistName = histNode->GetPathName();
      extension = "";
    } else {
      strHistName = strNodeName.substr(0, atsign);
      extension = strNodeName.substr(atsign, std::string::npos);
      strFullHistName = histNode->GetPathName();
      strFullHistName.resize(strFullHistName.find('@'));
    }
 
    if( strHistName == "all_in_dir" ) {
 
      std::string regexflag(histNode->GetAttribute("regex"));
      if (histNode->GetAttribute("regex") != "") {
        std::cerr << "WARNING: all_in_dir and regex are incompatible; ignoring regex flag for " << histNode->GetPathName()
                            << "/all_in_dir" << std::endl;
      }
 
      std::string refID( histNode->GetAttribute("reference") );
      if( refID == "" ) {
        std::cerr << "WARNING: No \"reference\" defined for " << histNode->GetPathName() << "\n";
        continue;
      }
      std::string refFile( m_refConfig.GetStringAttribute(refID,"file") );
      if( refFile == "" ) {
        std::cerr << "WARNING: No \"file\" defined for " << histNode->GetPathName() << "\n";
        continue;
      }
 
      std::string refPath( m_refConfig.GetStringAttribute(refID,"path") );
 
      std::string objPath("");
      std::string absObjPath("");
 
      refFile = SplitReference( m_refConfig.GetStringAttribute(std::move(refID),"location"), refFile);
      std::shared_ptr<TFile> infile( GetROOTFile(refFile) );
      TDirectory* basedir(0);
      TDirectory* dir(0);
      TKey* key;
 
      if( refPath != "" ) {
        //std::cout << "Searching under path \"" << refPath << "\" for " << "\"" << histNode->GetPathName() << "\"\n";
        absObjPath += refPath;
        absObjPath += "/";
        std::string refPathForSearch = refPath;
        refPathForSearch += "/dummyName";
        basedir = ChangeInputDir( infile.get(), refPathForSearch );
        if( basedir == 0 ) {
          std::cerr << "INFO: Cannot find path \"" << refPath << "\" in reference file\n";
          continue;
        }
      }
 
      if( basedir == 0 )
        basedir = infile.get();
 
      std::string allPathName( histNode->GetPathName() );
      std::string::size_type i = allPathName.find_last_of('/');
      if( i != std::string::npos ) {
        objPath = std::string( allPathName, 0, i );
        objPath += "/";
        absObjPath += std::string( allPathName, 0, i );
        absObjPath += "/";
      }
 
      dir = ChangeInputDir( basedir, histNode->GetPathName() );
      if( dir == 0 ) {
        std::cerr << "INFO: Cannot find path \"" << absObjPath << "\" in reference file\n";
        continue;
      }
 
      TIter next( dir->GetListOfKeys() );
      std::string objName;
      std::string absObjName;
      // we might have multiple loops through 'all_in_dir', but each should
      // have unique objects
      std::set<std::string>  localdefined;
      while( (key = dynamic_cast<TKey*>(next())) != 0 ) {
        TObject* tmpobj = key->ReadObj();
        TH1* tmph = dynamic_cast<TH1*>(tmpobj);
        TGraph* tmpg = dynamic_cast<TGraph*>(tmpobj);
        TEfficiency* tmpe = dynamic_cast<TEfficiency*>(tmpobj);
        if( tmph == 0 && tmpg == 0 && tmpe == 0 )
          continue;
 
        objName = objPath;
        objName += std::string( tmpobj->GetName() );
        absObjName = absObjPath;
        absObjName += std::string( tmpobj->GetName() );
        delete tmpobj;
 
        if( defined.find(objName) != defined.end() ||
        localdefined.find(objName) != localdefined.end() )
          continue;
 
        TKey* test = getObjKey( infile.get(), absObjName );
        if( test == 0 )
          continue;
 
        HanConfigAssessor dqpar;
        dqpar.SetName( objName + extension );
        GetAlgorithmConfiguration( &dqpar, algID, objName );
 
    if (histNode->GetAttribute("weight") != "") {
      std::ostringstream err;
      err << "Weight attribute not a floating point type for " << objName << "; setting to zero";
      dqpar.SetWeight(AttribToFloat(histNode, "weight",
                    err.str()));
    }
 
    std::set<std::string> histAtt2;
    histNode->GetAttributeNames( histAtt2 );
    std::set<std::string>::const_iterator histAttEnd2 = histAtt2.end();
    for( std::set<std::string>::const_iterator h2 = histAtt2.begin(); h2 != histAttEnd2; ++h2 ) {
      if (node->GetDaughter( *h2 )
          || *h2 == "algorithm" || *h2 == "output" || *h2 == "reference"
          || *h2 == "weight" || *h2 == "regex") {
        continue;
      }
      HanConfigParMap parMap;
      parMap.SetName(*h2); parMap.SetValue(histNode->GetAttribute(*h2));
      dqpar.AddAnnotation(parMap);
    }
 
    // Add the histogram name
    HanConfigParMap parMap;
    parMap.SetName("inputname"); parMap.SetValue( objName );
    dqpar.AddAnnotation(parMap);
 
        HanConfigGroup* dqreg = m_root->GetNode( regID );
        dqreg = (dqreg==0) ? m_root : dqreg;
        if( dqreg != 0 ) {
          dqreg->AddAssessor( dqpar );
        }
        localdefined.insert( objName );
      }
 
      continue;
    }
  }
}
 
 
HanConfig::ConfigVisitor::
ConfigVisitor( TFile* file_, dqm_core::Output* output_ )
  : m_file(file_),
    m_output(output_)
{
}
 
 
boost::shared_ptr<dqm_core::Node>
HanConfig::ConfigVisitor::
Visit( const HanConfigAssessor* node, boost::shared_ptr<dqm_core::Region> dqParent )
{
  const HanConfigGroup* gnode = dynamic_cast<const HanConfigGroup*>( node );
  std::string algName( node->GetAlgName() );
  std::string algLibName( node->GetAlgLibName() );
  if( algLibName != "" ) {
    try {
      dqm_core::LibraryManager::instance().loadLibrary( algLibName );
    }
    catch ( dqm_core::Exception& ex ) {
      //std::cout << "Can't load library " << algLibName << ". Continuing regardless ..." << std::endl;
    }
  }
 
  if( gnode != 0 ) {
    dqm_core::RegionConfig regc( algName, node->GetWeight() );
    std::string regName( gnode->GetPathName() );
    boost::shared_ptr<dqm_core::Region> reg(dqParent->addRegion( regName, regc ));
    m_output->addListener(regName, dqParent.get());
    return reg;
  }
 
  std::string inputData( node->GetHistPath() );
  HanAlgorithmConfig* algConfig = new HanAlgorithmConfig( *node, m_file );
  dqm_core::ParameterConfig parc( inputData, algName, node->GetWeight(),
                  std::shared_ptr<HanAlgorithmConfig>(algConfig), node->GetIsRegex() );
  boost::shared_ptr<dqm_core::Node> par(dqParent->addParameter( node->GetName(), parc ));
  m_output->addListener(node->GetName(), dqParent.get());
  return par;
}
 
 
HanConfig::CompAlgVisitor::
CompAlgVisitor(TFile* outfile_, const MiniConfig& compAlgConfig_)
  : m_outfile(outfile_)
    , m_compAlgConfig(compAlgConfig_)
{
}
 
 
void
HanConfig::CompAlgVisitor::
Visit( const MiniConfigTreeNode* node )
{
  m_outfile->cd();
  std::map<std::string,MiniConfigTreeNode*> daughters = node->GetDaughters();
  std::map<std::string,MiniConfigTreeNode*>::const_iterator nodeiterEnd = daughters.end();
  for( std::map<std::string,MiniConfigTreeNode*>::const_iterator iter = daughters.begin(); iter != nodeiterEnd; ++iter ) {
    std::string compAlgID = iter->second->GetName();
    std::string compAlgKey = iter->first;
 
    HanConfigCompAlg* compAlg = new HanConfigCompAlg();
    std::set<std::string> compAlgAtt;
    m_compAlgConfig.GetAttributeNames(compAlgID, compAlgAtt);
    std::set<std::string>::const_iterator compAlgAttEnd = compAlgAtt.end();
    //std::cout << "Configuring composite algorithm: " << compAlgID << std::endl;
    compAlg->SetName(compAlgID);
    for( std::set<std::string>::const_iterator i = compAlgAtt.begin(); i != compAlgAttEnd; ++i ) {
      if( *i == "subalgs" ) {
        std::string subAlgs( m_compAlgConfig.GetStringAttribute(compAlgID,"subalgs") );
        std::string::size_type pos = subAlgs.find(',');
        for(int size=subAlgs.size(), sizeOld=-8;
            size != sizeOld;
            subAlgs.erase(0, pos+1), pos = subAlgs.find(','),sizeOld=size, size=subAlgs.size()) {
            //std::cout << "  --> adding component algorithm: " <<  subAlgs.substr(0,pos) << std::endl;
            compAlg->AddAlg( subAlgs.substr(0,pos));
          }
      }
      else if( *i == "libnames" ) {
        std::string libs( m_compAlgConfig.GetStringAttribute(compAlgID,"libnames") );
        std::string::size_type pos = libs.find(',');
        for(int size=libs.size(), sizeOld=-8;
            size != sizeOld;
            libs.erase(0, pos+1), pos = libs.find(','),sizeOld=size, size=libs.size()) {
            //std::cout << "  --> using library: " <<  libs.substr(0,pos) << std::endl;
            compAlg->AddLib( libs.substr(0,pos));
          }
      }
    }
    compAlg->Write();
  }
}
 
HanConfig::MetadataVisitor::
MetadataVisitor(TFile* outfile_, const MiniConfig& metadataConfig_)
  : m_outfile(outfile_)
    , m_metadataConfig(metadataConfig_)
{
}
 
 
void
HanConfig::MetadataVisitor::
Visit( const MiniConfigTreeNode* node )
{
  // maybe already existing?
  if (m_outfile->Get("HanMetadata")) {
    m_outfile->cd("HanMetadata");
  } else {
    // try to make it
    TDirectory* mdir = m_outfile->mkdir("HanMetadata");
    if (mdir) {
      mdir->cd();
    } else {
      // all fail
      m_outfile->cd();
    }
  }
 
  std::map<std::string,MiniConfigTreeNode*> daughters = node->GetDaughters();
  std::map<std::string,MiniConfigTreeNode*>::const_iterator nodeiterEnd = daughters.end();
  for( std::map<std::string,MiniConfigTreeNode*>::const_iterator iter = daughters.begin(); iter != nodeiterEnd; ++iter ) {
    std::string metadataID = iter->second->GetName();
 
    std::set<std::string> metadataAtt;
    m_metadataConfig.GetAttributeNames(metadataID, metadataAtt);
    HanConfigMetadata* metadata = new HanConfigMetadata();
    metadata->SetName(metadataID);
    for (std::set<std::string>::const_iterator i = metadataAtt.begin(); i != metadataAtt.end(); ++i ) {
      HanConfigParMap parMap;
      parMap.SetName(*i); parMap.SetValue(m_metadataConfig.GetStringAttribute(metadataID, *i));
      metadata->AddKeyVal(parMap);
    }
    metadata->Write();
    delete metadata;
  }
}
 
 
bool
HanConfig::
Initialize( const std::string& configName )
{
  if( m_config == 0 || m_top_level == 0 ) {
 
    delete m_config;
    delete m_top_level;
    if (m_metadata) {
      m_metadata->Delete();
    }
    delete m_metadata; m_metadata=newTList("HanMetadata");
 
    m_config = TFile::Open( configName.c_str(), "READ" );
    if( m_config == 0 ) {
      std::cerr << "HanConfig::Initialize() cannot open file \"" << configName << "\"\n";
      return false;
    }
 
    TMap* refsourcedata = dynamic_cast<TMap*>(m_config->Get("refsourcedata"));
    if (refsourcedata) {
      ConditionsSingleton::getInstance().setRefSourceMapping(refsourcedata);
    } else {
      std::cerr << "Can't retrieve reference source info" << std::endl;
    }
 
    TIter nextKey( m_config->GetListOfKeys() );
    TKey* compAlgKey(0);
    while( (compAlgKey = dynamic_cast<TKey*>( nextKey() )) != 0 ) {
      TObject* obj = compAlgKey->ReadObj();
      HanConfigCompAlg* compAlg = dynamic_cast<HanConfigCompAlg*>( obj );
      if( compAlg != 0 ) {
        //std::cout << "Instantiating composite algorithm \"" << compAlg->GetName() << "\"...\n";
        new CompositeAlgorithm( *compAlg );
      }
      delete obj;
    }
 
    TKey* key(0);
 
    m_metadata = newTList("HanMetadata");
    key = m_config->FindKey("HanMetadata");
    if ( key ) {
      TDirectory* mdDir = dynamic_cast<TDirectory*>(key->ReadObj());
      if (mdDir) {
    TIter mdIter(mdDir->GetListOfKeys());
    TKey* mdKey(0);
    while ((mdKey = dynamic_cast<TKey*>(mdIter()))) {
      HanConfigMetadata* md = dynamic_cast<HanConfigMetadata*>(mdKey->ReadObj());
      if (md) {
        m_metadata->Add(md);
      }
    }
      }
      delete mdDir;
    }
 
    key = m_config->FindKey("top_level");
    if( key == 0 ) {
      std::cerr << "HanConfig::Initialize() cannot find configuration in file \"" << configName << "\"\n";
      return false;
    }
 
    m_top_level = dynamic_cast<HanConfigGroup*>( key->ReadObj() );
    if( m_top_level == 0 ) {
      std::cerr << "HanConfig::Initialize() cannot find configuration in file \"" << configName << "\"\n";
      return false;
    }
  }
 
  return true;
}
 
 
// *********************************************************************
// Private Methods
// *********************************************************************
 
 
TDirectory*
HanConfig::
ChangeInputDir( TDirectory* dir, const std::string& path )
{
  if( dir == 0 )
    return 0;
 
  TKey* key(0);
 
  std::string::size_type i = path.find_first_of('/');
  if( i != std::string::npos ) {
    std::string dName( path, 0, i );
    std::string pName( path, i+1, std::string::npos );
    if( dName != "" ) {
      TDirectory* subDir(0);
      key = dir->FindKey( dName.c_str() );
      if( key != 0 ) {
        subDir = dynamic_cast<TDirectory*>( key->ReadObj() );
      }
      else {
        return 0;
      }
      TDirectory* retval = ChangeInputDir( subDir, pName );
      return retval;
    }
    return ChangeInputDir( dir, pName );
  }
 
  return dir;
}
 
 
TDirectory*
HanConfig::
ChangeOutputDir( TFile* file, const std::string& path, DirMap_t& directories )
{
    if( file == 0 )
        return 0;
 
  std::string::size_type i = path.find_last_of('/');
  if( i != std::string::npos ) {
    std::string subPath( path, 0, i );
    DirMap_t::const_iterator j = directories.find( subPath );
    if( j != directories.end() ) {
      TDirectory* dir = j->second;
      return dir;
    }
    else {
      TDirectory* parDir = ChangeOutputDir( file, subPath, directories );
      std::string dirName;
      std::string::size_type k = subPath.find_last_of('/');
      dirName = (k != std::string::npos) ? std::string( subPath, k+1, std::string::npos ) : subPath;
      TDirectory* dir = nullptr;
      if (!parDir->FindKey(dirName.c_str())) {
    dir = parDir->mkdir( dirName.c_str() );
      }
      else{
    std::cout << "Failed to make directory " << dirName.c_str() << std::endl;
      }
      DirMap_t::value_type dirVal( subPath, dir );
      directories.insert( dirVal );
      return dir;
    }
  }
 
  return file;
}
 
} // namespace dqi