dqi Namespace Reference

Classes
class	CompositeAlgorithm
class	ConditionsSingleton
class	CorrelationYX
class	CountsBinsGreaterThan
class	DatabaseConfig
class	DisableMustClean
class	HanAlgorithmConfig
class	HanApp
class	HanConfig
class	HanConfigAlgLimit
class	HanConfigAlgPar
class	HanConfigAssessor
class	HanConfigCompAlg
class	HanConfigGroup
class	HanConfigMetadata
class	HanConfigParMap
class	HanHistogramLink
class	HanInputRootFile
class	HanOutput
class	HanRuntimeConfigSingleton
class	MiniConfig
	description More...
class	MiniConfigTreeNode
	A node of a tree structure holding a configuration, where each node may be given attributes, and a node inherits the attributes of parent nodes if those attributes are not redefined. More...

Functions
nlohmann::ordered_json	to_JSON (TSeqCollection *tseq)
	Converts sequense, containing TDirectories and strings to JSON file.
TSeqCollection *	newTList (const char *name, TObject *obj=0)
TSeqCollection *	newTObjArray (const char *name, TObject *obj=0, Int_t size=TCollection::kInitCapacity)
TKey *	getObjKey (TDirectory *dir, const std::string &path)
void	dolsr (const TDirectory *dir, std::vector< std::string > &hists, const TDirectory *topdir=nullptr)
bool	setNameGeneral (TObject *obj, const std::string &name)
static bool	include_hist (TObject *obj)
static void	WriteListToDirectory (TDirectory *dir, TSeqCollection *list, TFile *file, int level, int HanOutput_FileVersion)

Variables
std::mutex	root_mutex

Function Documentation

dolsr()

void dqi::dolsr	(	const TDirectory *	dir,
		std::vector< std::string > &	hists,
		const TDirectory *	topdir = nullptr )

Definition at line 80 of file HanUtils.cxx.

{
    // permit calling with two arguments
    if (topdir == NULL) {
        topdir = dir;
    }
  TIter keys(dir->GetListOfKeys());
  TKey* key;
  std::string fullpath(dir->GetPath());
  std::string toppath(topdir->GetPath());
  std::string::size_type toppathlen = toppath.length();
  while ((key = dynamic_cast<TKey*>(keys())) != NULL) {
    if (std::string(key->GetClassName()).starts_with( "TDirectory")) {
      TDirectory* newdir = dynamic_cast<TDirectory*>(key->ReadObj());
      if (!newdir) {
        std::cerr << "WARNING: cannot read directory " 
            << fullpath << "/" << key->GetName()
            << "; skipping" << std::endl;
      } else {
        dolsr(newdir, hists, topdir);
      }
      delete newdir;
    } else {
      if (std::string(key->GetName()) == "metadata") {
        continue;
      }
      std::string path;
      if (fullpath.substr(0, toppathlen) == toppath) {
        int extra = 1;
        if (toppath[toppathlen-1] == '/') extra = 0;
        path = fullpath.substr(toppathlen + extra, std::string::npos);
      } else {
        path = fullpath;
      }
      hists.push_back(path+"/"+std::string(key->GetName()));
    }      
  }
}

getObjKey()

TKey * dqi::getObjKey	(	TDirectory *	dir,
		const std::string &	path )

Definition at line 36 of file HanUtils.cxx.

{
  if( dir == 0 )
    return 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 = dir->GetDirectory(dName.c_str());
      if (subDir != 0) {
        TKey* rv = getObjKey( subDir, pName );
        //delete subDir;
        return rv;
      }
      // TKey* key = dir->FindKey( dName.c_str() );
      // if( key != 0 ) {
      //   TDirectory* subDir = dynamic_cast<TDirectory*>( key->ReadObj() );
      //   TKey* rv = getObjKey( subDir, pName );
      //    //  delete subDir;
      //    return rv;
      // }
      return 0;
    }
    return getObjKey( dir, pName );
  }
 
  return dir->FindKey( path.c_str() );
}

include_hist()

bool dqi::include_hist ( TObject * obj )

static

Definition at line 393 of file HanOutput.cxx.

                                         { //Check if object a hist or include hist
    bool result = false;
 
    if ((strncmp(obj->ClassName(), "TH", 2) == 0) || (strncmp(obj->ClassName(), "TGraph", 6) == 0) ||
        (strncmp(obj->ClassName(), "TProfile", 8) == 0) || (strncmp(obj->ClassName(), "TEfficiency", 11) == 0))
    {
      return true;
    }
 
    TSeqCollection* tmpList{};
    tmpList = dynamic_cast<TSeqCollection*>(obj);
    if (tmpList != 0)
    { //If it is collection - check, that it contains histograms or not
      TIter nextElem(tmpList);
      TObject* tmpobj{};
      while ((tmpobj = nextElem()) != 0)
      {
        result = include_hist(tmpobj);
        if (result == true)
        {
          return result;
        }
      }
    }
    return result;
  }

newTList()

TSeqCollection * dqi::newTList	(	const char *	name,
		TObject *	obj = 0 )

Definition at line 18 of file HanUtils.cxx.

{
  TList *ret = new TList();
  ret->SetName(name);
  if (obj != 0)
    ret->Add(obj);
  return ret;
}

newTObjArray()

TSeqCollection * dqi::newTObjArray	(	const char *	name,
		TObject *	obj = 0,
		Int_t	size = TCollection::kInitCapacity )

Definition at line 27 of file HanUtils.cxx.

{
  TObjArray *ret = new TObjArray(size);
  ret->SetName(name);
  if (obj != NULL)
    ret->Add(obj);
  return ret;
}

setNameGeneral()

bool dqi::setNameGeneral	(	TObject *	obj,
		const std::string &	name )

Definition at line 44 of file HanOutput.cxx.

  {
    if (obj != 0)
    {
      // some special cases, to avoid interpreter
      if (TH1* h = dynamic_cast<TH1*>(obj))
      {
        h->SetName(name.c_str());
        return true;
      }
      else if (TObjArray* a = dynamic_cast<TObjArray*>(obj))
      {
        a->SetName(name.c_str());
        return true;
      }
      else if (TGraph* g = dynamic_cast<TGraph*>(obj))
      {
        g->SetName(name.c_str());
        return true;
      }
      else if (TEfficiency* e = dynamic_cast<TEfficiency*>(obj))
      {
        e->SetName(name.c_str());
        return true;
      }
      else
      {
        TClass* kl = obj->IsA();
        TMethod* klm = kl->GetMethod("SetName", "\"Reference\"");
        if (!klm)
        {
          std::cerr << "Error: attempt to change object name to " << name << " failed as its name is not settable"
                    << std::endl;
        }
        else
        {
          std::cout << "Manually doing cast for " << name << " of class " << kl->GetName() << std::endl;
          obj->Execute("SetName", ("\"" + name + "\"").c_str());
          return true;
        }
      }
    }
    return false;
  }

to_JSON()

nlohmann::ordered_json dqi::to_JSON

(

TSeqCollection *

tseq

)

Converts sequense, containing TDirectories and strings to JSON file.

Definition at line 543 of file HanOutput.cxx.

  {
    using json = nlohmann::ordered_json;
    json j;
 
    TIter nextElem(tseq);
    TObject* obj;
    while ((obj = nextElem()) != 0)
    {
      // If Results (or Config) directory contatins hist - ignore it (do not write in to the file), it
      // should to be writen to the outer level before
      if ((strncmp(obj->ClassName(), "TH", 2) == 0) || (strncmp(obj->ClassName(), "TGraph", 6) == 0) ||
          (strncmp(obj->ClassName(), "TProfile", 8) == 0) || (strncmp(obj->ClassName(), "TEfficiency", 11) == 0) ||
          (strncmp(obj->GetName(), "Reference", 9) == 0))
 
      {
        continue;
      }
      TSeqCollection* tmpList = dynamic_cast<TSeqCollection*>(obj);
      if (tmpList != 0)
      {  // Nested object
        // Write TSeqCollection_names as keys and content of them as a values
        // Convert TString to string
        std::string key_name_string(obj->GetName());
        j.emplace(key_name_string, to_JSON(tmpList));
      }
      else
      {  // leaf
        j = obj->GetName();
      }
    }
    return j;
  }

WriteListToDirectory()

void dqi::WriteListToDirectory ( TDirectory * dir, TSeqCollection * list, TFile * file, int level, int HanOutput_FileVersion )

static

First: we need to know - are there any histograms storing in this dir (e.g. References).

Definition at line 420 of file HanOutput.cxx.

  {
    TIter nextElem(list);
    TObject* obj{};
    TSeqCollection* tmpList{};
 
    while ((obj = nextElem()) != 0)
    {
      bool delete_when_done = false;
      HanHistogramLink* hhl = dynamic_cast<HanHistogramLink*>(obj);
      if (hhl != 0)
      {
        obj = hhl->getObject();
        if (!obj) continue;
        delete_when_done = true;
        if (not setNameGeneral(obj, hhl->GetName()))
        {
          std::cerr << "HanOutput.cxx, WriteListToDirectory : setNameGeneral failed\n";
          delete obj;
          continue;
        };
      }
      if (strncmp(obj->GetName(), "Reference", 9) == 0 || strncmp(obj->GetName(), "ResultObject", 12) == 0)
      {
        dir->WriteTObject(obj);
        if (delete_when_done) delete obj;
        continue;
      }
      tmpList = dynamic_cast<TSeqCollection*>(obj);
      if (tmpList != 0)
      {
        // Find last directory name
        std::vector<std::string> dirs;
        std::string str;
        boost::split(dirs, tmpList->GetName(), boost::is_any_of("/"));
        if (!dirs.empty())
        {
          if (dirs.back().empty()) dirs.pop_back();  // empty item if trailing "/"
          str = dirs.back();
        }
 
        if (HanOutput_FileVersion == 2)
        {
          TString listname = tmpList->GetName();
          if (listname == "Config" || listname == "Results")
          {  
            //If yes - we should save them in the upper level
            TIter nextElemConfRes(tmpList);
            TObject* objInResultConfig;
            while ((objInResultConfig = nextElemConfRes()) != 0)
            {
              if (include_hist(objInResultConfig))
              {
                //If the element consist of histograms
                TSeqCollection* tmpList_ResConf{}; //it should be a collection type
                tmpList_ResConf = dynamic_cast<TSeqCollection*>(objInResultConfig);
                if ((tmpList_ResConf != 0) && (strncmp(tmpList_ResConf->GetName(), "TObjArray", 9) == 0))
                { //Here is the special case. In case the object is an Array with the name "TObjArray", containing histograms,
                  //we should not only store it on the upper level, but also extract all the hists from it.
                  TIter nextEleminTObjArray(tmpList_ResConf);
                  TObject* objInTObjArray;
                  while ((objInTObjArray = nextEleminTObjArray()) != 0){
                    dir->WriteTObject(objInTObjArray);
                  }
                  tmpList->Remove(objInResultConfig); //This Array should not participate in JSON formation
                }
                else //If the element is histogram (or other Array, containing hist)- just store this obj in a higher level
                {
                  dir->WriteTObject(objInResultConfig);
                }
              }
            }
            // For the rest of the content - Convert them to JSON 
            nlohmann::ordered_json j = to_JSON(tmpList);
            // Then, save JSON to file as TObjString
            // Convert json to string
            std::string string = j.dump(4);
            // Convert string to char *
            char* cstr = new char[string.length() + 1];
            std::strcpy(cstr, string.c_str());
            // Write JSON to TObjString
            TObjString string_to_tfile;
            string_to_tfile.SetString(cstr);
            dir->cd();
            string_to_tfile.Write(listname);
            delete[] cstr;
            continue;
          }
        }
 
        TDirectory* daughter;
        if (!dir->FindKey(str.c_str()))
        {
          daughter = dir->mkdir(str.c_str());
        }
        else
        {
          std::cout << "Failed to make " << str << " from " << tmpList->GetName() << std::endl;
          continue;
        }
        WriteListToDirectory(daughter, tmpList, file, level - 1, HanOutput_FileVersion);
        if (level > 0)
        {
          file->Write();
          delete daughter;
        }
      }
      else if ((strncmp(obj->ClassName(), "TH", 2) == 0) || (strncmp(obj->ClassName(), "TGraph", 6) == 0) ||
               (strncmp(obj->ClassName(), "TProfile", 8) == 0) || (strncmp(obj->ClassName(), "TEfficiency", 11) == 0))
      {
        dir->GetMotherDir()->WriteTObject(obj);
      }
      else
      {
        // anything else put it in current directory
        dir->WriteTObject(obj);
      }
      if (delete_when_done) delete obj;
    }
  }

Variable Documentation

root_mutex

std::mutex dqi::root_mutex

Definition at line 16 of file HanUtils.cxx.