10 #include "KVDataRepository.h"
11 #include "KVDataRepositoryManager.h"
12 #include "KVDataSetManager.h"
16 #include "KVDBSystem.h"
19 #include "KVAvailableRunsFile.h"
20 #include "KVNumberList.h"
23 #include "KVRunFile.h"
38 fRepository =
nullptr;
40 fAllTasks.SetOwner(
kTRUE);
55 if (!fRepository)
return nullptr;
59 avrf = fRepository->NewAvailableRunsFile(
type,
this);
60 fAvailableRuns.
Add(avrf);
99 n.Append(
Form(
".%d.%d", GetKVMajorVersion(),
100 GetKVMinorVersion()));
115 return (fDBName !=
"" ? fDBName.Data() : GetName());
129 fDBase.reset(
new TFile(full_path_to_dbfile,
"READ"));
131 if (fDBase->IsOpen()) {
132 fDataBase =
dynamic_cast<KVExpDB*
>(fDBase->Get(GetDBName()));
134 Error(
"OpenDBFile",
"%s not found in file %s", GetDBName().Data(),
135 GetDBFileName().Data());
138 fDataBase->ReadObjects(fDBase.get());
154 TString dbfile = GetDBFileName();
161 TString dataset_alias = GetDataSetEnv(
"DataSet.Directory", GetName());
167 return dbfile_fullpath;
186 if (envar !=
"") t->
SetTitle(envar);
187 envar = GetDataSetEnv(
Form(
"%s.DataAnalysisTask.Analyser", t->
GetName()));
189 envar = GetDataSetEnv(
Form(
"%s.DataAnalysisTask.UserClass.Base", t->
GetName()));
191 envar = GetDataSetEnv(
Form(
"%s.DataAnalysisTask.Prereq", t->
GetName()));
193 envar = GetDataSetEnv(
Form(
"%s.DataAnalysisTask.UserClass.ExtraACliCIncludes", t->
GetName()));
195 Int_t nev = (
Int_t)GetDataSetEnv(
Form(
"%s.DataAnalysisTask.StatusUpdateInterval", t->
GetName()), 0.0);
225 TString dbfile_fullpath = GetFullPathToDB();
237 Error(
"SaveDataBase",
"Cannot create directory %s required to save database",
244 Error(
"SaveDataBase",
"Cannot create directory %s required to save database, even though %s exists: check disk space ?",
250 Error(
"SaveDataBase",
"Cannot create directory %s required to save database",
263 WriteDBFile(dbfile_fullpath.
Data());
282 Error(
"WriteDBFile",
"Database has not been built");
285 fDBase.reset(
new TFile(full_path_to_dbfile,
"recreate"));
287 fDataBase->Write(GetDBName());
288 fDataBase->WriteObjects(fDBase.get());
322 if (_opt ==
"UPDATE") {
323 OpenDataBase(_opt.
Data());
378 if ((!strcmp(opt,
"UPDATE")) || DataBaseNeedsUpdate()) {
381 Info(
"OpenDataBase",
"Updating database file");
382 fDataBaseUpdateInProgress =
true;
383 is_glob_db = (fDataBase == gExpDB);
393 Info(
"OpenDataBase",
"No database defined for dataset");
397 if (fDataBase && is_glob_db) fDataBase->cd();
398 fDataBaseUpdateInProgress =
false;
400 else if (!fDataBase) {
405 if (!LoadPlugin(
"KVExpDB", GetDBName())) {
406 Error(
"GetDataBase",
"Cannot load required plugin library");
410 TString dbfile_fullpath = GetFullPathToDB();
412 OpenDBFile(dbfile_fullpath.
Data());
425 cout <<
"Dataset name=" << GetName() <<
" (" << GetTitle() <<
")";
427 cout <<
" [ AVAILABLE: ";
428 cout << fDatatypes.Data();
432 cout <<
" [UNAVAILABLE]";
453 cout <<
" *** No available analysis tasks ***"
458 for (
int i = 1; i <= GetNtasks(); i++) {
460 cout <<
"\t" << i <<
". " << dat->
GetTitle() << endl;
466 cout <<
"Available data types: " << fDatatypes.Data() << endl;
517 SetAvailable(fRepository->CheckSubdirExists(GetDataPathSubdir()));
521 KVString data_types = GetDataSetEnv(
"KVDataSet.DataTypes",
"");
522 if (data_types ==
"") {
523 Warning(
"CheckAvailable",
"No datatypes defined for this dataset: %s\nCheck value of KVDataSet.DataTypes or %s.KVDataSet.DataTypes",
524 GetName(), GetName());
529 data_types.
Begin(
" ");
530 while (!data_types.
End()) {
533 (fRepository && fRepository->CheckSubdirExists(GetDataPathSubdir(), GetDataTypeSubdir(
type.Data())))
535 AddAvailableDataType(
type.Data());
539 SetAvailable(fDatatypes !=
"");
541 if (!CheckUserCanAccess()) {
553 if (fDatatypes !=
"") fDatatypes +=
" ";
579 TIter nxt(task_list);
586 SetDataSetSpecificTaskParameters(new_task);
587 fAllTasks.Add(new_task);
589 if (HasDataType(new_task->
GetPrereq())) {
590 fTasks.Add(new_task);
607 return fTasks.GetSize();
656 if (!GetAvailableRunsFile(datatype)) {
657 Error(
"GetListOfAvailableSystems(const Char_t*)",
658 "No available runs file for type %s", datatype);
661 return GetAvailableRunsFile(datatype)->GetListOfAvailableSystems(systol);
695 return GetListOfAvailableSystems(datan->
GetPrereq(), systol);
729 TString path = GetDataSetEnv(
"DataSet.Directory",
name);
734 fCalibDir = GetDATADIRFilePath(path);
750 return fCalibDir.Data();
771 if (fRepository) fRepository->
cd();
906 if (!strcmp(
type,
"raw") && !strcmp(GetDataSetEnv(
"MFM.WithEbyedat",
""),
"yes")) {
907 TString ebydir = GetDataSetDir();
908 ebydir +=
"/ebyedat";
909 gEnv->
SetValue(
"KVMFMDataFileReader.ActionsDirectory", ebydir);
910 if (strcmp(GetDataSetEnv(
"MFM.EbyedatActionsExpName",
""),
""))
911 gEnv->
SetValue(
"KVMFMDataFileReader.ActionsExpName", GetDataSetEnv(
"MFM.EbyedatActionsExpName",
""));
912 TObject*
f = GetRepository()->OpenDataSetRunFile(
this,
type, run, GetName());
914 gEnv->
SetValue(
"KVMFMDataFileReader.ActionsDirectory",
"");
915 gEnv->
SetValue(
"KVMFMDataFileReader.ActionsExpName",
"");
918 return GetRepository()->OpenDataSetRunFile(
this,
type, run, GetName());
941 if (fRepository)
file = GetRunfileName(
type, run);
944 return fRepository->GetFullPathToOpenFile(
this,
type,
file.Data());
965 if (!HasDataType(
type)) {
966 Error(
"GetRunfileName",
967 "No data of type \"%s\" available for dataset %s", (
const char*)
type,
972 return GetAvailableRunsFile(
type)->GetFileName(run);
994 date.
Set(1995, 1, 1, 0, 0, 0);
996 if (!HasDataType(
type)) {
997 Error(
"GetRunfileDate",
998 "No data of type \"%s\" available for dataset %s", (
const char*)
type,
1004 if (!GetAvailableRunsFile(
type)->GetRunInfo(run, date,
filename)) {
1005 Error(
"GetRunfileDate",
1006 "Runfile not found for run %d index %d (data type: %s)", run.
run(), run.
index(), (
const char*)
type);
1025 if (!HasDataType(
type)) {
1026 Error(
"CheckRunfileAvailable",
1027 "No data of type \"%s\" available for dataset %s", (
const char*)
type,
1031 return GetAvailableRunsFile(
type)->CheckAvailable(run);
1095 if (!HasDataType(
type)) {
1096 Error(
"UpdateAvailableRuns",
1097 "No data of type \"%s\" available for dataset %s", (
const char*)
type,
1118 if (!fRepository)
return nullptr;
1122 return fRepository->CreateNewFile(
this,
type, tmp.
Data());
1147 if (!fRepository)
return;
1152 Error(
"DeleteRunfile",
"Run %s of type %s does not exist.",
1158 KVString doNotDelete = GetDataSetEnv(
"DataSet.RunFile.DoNotDelete",
"all");
1159 if (doNotDelete ==
"all" || doNotDelete.
Contains(
type)) {
1160 Error(
"DeleteRunFile",
"%s files cannot be deleted", (
const char*)
type);
1163 fRepository->DeleteFile(
this,
type,
filename.Data(), confirm);
1165 if (!fRepository->CheckFileStatus(
this,
type,
filename.Data()))
1166 GetAvailableRunsFile(
type)->Remove(run);
1198 if (NL.IsEmpty()) NL = GetRunList(
type);
1199 if (NL.IsEmpty())
return;
1201 DeleteRunfile(
type,
r, confirm);
1224 if (!
min && !
max)
return {};
1226 if (
min) printf(
"date minimum %s\n",
min->AsString());
1227 if (
max) printf(
"date maximum %s\n",
max->AsString());
1229 run_index_list numb;
1231 auto ll = GetListOfAvailableSystems(
type);
1234 for (
Int_t nl = 0; nl < ll->GetEntries(); nl += 1) {
1236 auto lrun = GetListOfAvailableSystems(
type, sys);
1237 auto oldList = numb;
1238 for (
Int_t nr = 0; nr < lrun->GetEntries(); nr += 1) {
1247 if (*min < run->GetFileWrittenDatime()) {
1258 if (numb.GetEntries() > oldList.GetEntries())
1259 printf(
"%s : %s\n", sys->
GetName(), (numb - oldList).AsString().Data());
1287 run_index_list manquant;
1288 auto ll = GetListOfAvailableSystems(ref_type);
1289 if (!ll || !ll->GetEntries()) {
1291 Info(
"GetRunList_StageSelection",
"No data available of type \"%s\"", ref_type);
1295 Info(
"GetRunList_StageSelection",
"No data available of type \"%s\" for system %s", ref_type, system->
GetName());
1299 Info(
"GetRunList_StageSelection",
"Liste des runs presents dans \"%s\" mais absent dans \"%s\"", ref_type,
type);
1303 for (
Int_t nl = 0; nl < ll->GetEntries(); nl += 1) {
1306 if (system && sys != system)
continue;
1308 auto nsys = GetRunList(
type, sys);
1309 auto nsys_ref = GetRunList(ref_type, sys);
1310 Int_t nref = nsys_ref.GetNValues();
1312 nsys_ref.Remove(nsys);
1314 Info(
"GetRunList_StageSelection",
"\nKVDBSystem : %s --> %d runs manquants sur %d : %s",
1316 nsys_ref.GetNValues(),
1318 nsys_ref.AsString().Data()
1320 manquant.Add(nsys_ref);
1336 run_index_list runs;
1338 unique_ptr<TList> lrun(GetListOfAvailableSystems(
type, sys));
1339 TIter next(lrun.get());
1346 unique_ptr<TList> ll(GetListOfAvailableSystems(
type));
1347 if (!ll.get() || !ll->GetEntries()) {
1349 Info(
"GetRunList_VersionSelection",
"No data available of type \"%s\"",
type);
1352 Int_t nsys = ll->GetEntries();
1353 for (
Int_t nl = 0; nl < nsys; nl += 1) {
1355 unique_ptr<TList> lrun(GetListOfAvailableSystems(
type, sys));
1356 TIter next(lrun.get());
1378 if (!fRepository)
return;
1383 fRepository->CommitFile(
file,
type,
this);
1392 TString oldfile = GetAvailableRunsFile(
type)->GetFileName(run);
1393 if (oldfile !=
"" && oldfile != newfile) {
1395 fRepository->DeleteFile(
this,
type, oldfile.
Data(),
1398 if (!fRepository->CheckFileStatus(
this,
type, oldfile.
Data()))
1399 GetAvailableRunsFile(
type)->Remove(run);
1401 if (oldfile != newfile) {
1403 GetAvailableRunsFile(
type)->Add(run, newfile.
Data());
1423 if (fUserGroups ==
"")
1427 unique_ptr<TObjArray> toks(fUserGroups.Tokenize(
' '));
1429 TIter next_name(toks.get());
1430 while ((group_name = (
TObjString*) next_name())) {
1432 if (!fRepository || (fRepository && fRepository->GetDataSetManager()->
1479 auto doubles = GetAvailableRunsFile(data_type)->CheckMultiRunfiles();
1480 if (doubles.empty()) {
1481 cout <<
"OK. No runs appear more than once." << endl;
1484 cout <<
"Runs which appear more than once: " << endl << endl;
1487 for (
auto& rr : doubles) {
1491 GetAvailableRunsFile(data_type)->GetRunInfos(rr, &dates, &filenames);
1493 cout <<
"Run " << rr <<
" : " << dates.
GetEntries() <<
" files >>>>>>" << endl;
1494 for (
int i = 0; i < dates.
GetEntries(); i++) {
1527 if (!fRepository)
return;
1531 if (doubles.empty()) {
1532 cout <<
"OK. No runs appear more than once." << endl;
1535 cout <<
"Runs which appear more than once: " << endl << endl;
1539 for (
auto& rr : doubles) {
1542 TDatime most_recent(
"1998-12-25 00:00:00");
1543 Int_t i_most_recent = 0;
1544 cout <<
"Run " << rr <<
" : " << dates.
GetEntries() <<
" files >>>>>>" << endl;
1545 for (
int i = 0; i < dates.
GetEntries(); i++) {
1548 if (rundate > most_recent) {
1549 most_recent = rundate;
1555 for (
int i = 0; i < dates.
GetEntries(); i++) {
1556 if (i == i_most_recent) {
1560 cout <<
"DELETE : ";
1565 if (i != i_most_recent) {
1567 fRepository->DeleteFile(
this, data_type,
1569 String().Data(), confirm);
1601 Error(
"CheckRunfileUpToDate",
1602 "Dataset \"%s\" not found in repository \"%s\"", GetName(),
1607 if (GetRunfileDate(data_type, run) < ds->
GetRunfileDate(data_type, run))
1634 return CheckRunfileUpToDate(data_type, run, _or);
1635 Error(
"CheckRunfileUpToDate",
1636 "No data repository known with this name : %s", (
const char*) other_repos);
1648 const Char_t* other_repos)
1653 if (!fRepository)
return;
1658 Error(
"CheckUpToDate",
1659 "No data repository known with this name : %s", other_repos);
1662 auto runlist = GetAvailableRunsFile(data_type)->GetRunList();
1663 Int_t need_update = 0;
1664 for (
auto& rr : runlist) {
1666 if (!CheckRunfileUpToDate(data_type, rr, _or)) {
1667 cout <<
" *** run " << rr <<
" needs update ***" <<
1669 cout <<
"\t\tREPOSITORY: " << fRepository->
1670 GetName() <<
"\tDATE: " << GetRunfileDate(data_type,
1673 cout <<
"\t\tREPOSITORY: " << other_repos <<
"\tDATE: " << _or->
1674 GetDataSetManager()->GetDataSet(GetName())->
1675 GetRunfileDate(data_type,
1676 rr).AsString() << endl;
1681 cout <<
" *** All runfiles are up to date for data type " <<
1694 const Char_t* other_repos)
1699 run_index_list updates;
1700 if (!fRepository)
return updates;
1705 Error(
"CheckUpToDate",
1706 "No data repository known with this name : %s", other_repos);
1709 auto runlist = GetAvailableRunsFile(data_type)->GetRunList();
1710 for (
auto& rr : runlist) {
1712 if (!CheckRunfileUpToDate(data_type, rr, _or)) {
1735 if (!fRepository || !HasDataType(data_type)) {
1737 "No data of type %s available. Runlist will be empty.",
1742 return GetAvailableRunsFile(data_type)->GetRunList(system);
1845 if (!_task.
Contains(
"nalysis")) _task +=
" analysis";
1848 auto dat = GetAnalysisTaskAny(_task.
Data());
1850 Error(
"MakeAnalysisClass",
1851 "called for unknown or unavailable analysis task : %s", _task.
Data());
1854 if (!dat->WithUserClass()) {
1855 Error(
"MakeAnalysisClass",
1856 "no user analysis class for analysis task : %s", dat->GetTitle());
1865 if (dat->CheckUserBaseClassIsLoaded()) cl =
TClass::GetClass(dat->GetUserBaseClass());
1870 unique_ptr<TMethodCall> methcall(
new TMethodCall(cl,
"Make",
Form(
"\"%s\"", classname)));
1872 if (!methcall->IsValid()) {
1873 Error(
"MakeAnalysisClass",
"static Make(const Char_t*) method for class %s is not valid",
1879 methcall->Execute();
1894 return OpenDataSetFile(GetName(), filename,
file);
1913 abspath.
Form(
"%s/%s", datasetdir.
Data(), filename);
1914 return SearchAndOpenKVFile(abspath,
file);
1917 return SearchAndOpenKVFile(filename,
file, datasetdir);
1931 return GetFullPathToDataSetFile(GetName(),
filename);
1947 if (!SearchKVFile(
filename, fullpath, datasetdir)) {
1948 ::Warning(
"KVDataSet::GetFullPathToDataSetFile",
"File %s not found in dataset subdirectory %s",
filename, datasetdir.
Data());
1967 return SearchKVFile(
filename, fullpath, datasetdir);
1981 return FindDataSetFile(GetName(),
filename);
2008 Error(
"GetAnalysisTaskAny",
"No task found with the following keywords in its title : %s", keywords);
2032 if (!SearchKVFile(GetDataSetDir(), path)) {
2034 Info(
"DataBaseNeedsUpdate",
"%s: Creating new dataset directory %s",
2035 GetName(), GetDataSetDir());
2038 Error(
"DataBaseNeedsUpdate",
2039 "%s: Dataset directory %s does not exist and cannot be created ?",
2040 GetName(), GetDataSetDir());
2044 SearchKVFile(GetDataSetDir(), path);
2048 of1 <<
"$(KV_WORK_DIR)/db/" << GetName() <<
"/DataBase.root : Runlist.csv Systems.dat" << endl;
2049 of1 <<
"\t@echo Database needs update" << endl;
2053 of2 <<
"# Automatically generated dummy Runlist.csv file" << endl;
2057 of3 <<
"# Automatically generated dummy Systems.dat file" << endl;
2104 if (
gEnv->
Defined(
Form(
"%s.DataRepository.DefaultOutputRepository", GetRepository()->GetName())))
2105 return TString(
gEnv->
GetValue(
Form(
"%s.DataRepository.DefaultOutputRepository", GetRepository()->GetName()),
""));
2106 TString orep = GetDataSetEnv(
Form(
"%s.DataAnalysisTask.OutputRepository", taskname), GetRepository()->GetName());
2121 for (
auto& run : runs) {
2145 Error(
"CopyRunfilesToRepository",
"Unknown destination repository : %s", destrepo);
2146 gDataRepositoryManager->
Print();
2152 for (
auto& run : runs) {
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t Int_t Int_t Window_t TString Int_t GCValues_t GetPrimarySelectionOwner GetDisplay GetScreen GetColormap GetNativeEvent const char const char dpyName wid window const char font_name cursor keysym reg const char only_if_exist regb h Point_t winding char text const char depth char const char Int_t count const char ColorStruct_t color const char filename
Option_t Option_t TPoint TPoint const char GetTextMagnitude GetFillStyle GetLineColor GetLineWidth GetMarkerStyle GetTextAlign GetTextColor GetTextSize void char Point_t Rectangle_t WindowAttributes_t Float_t Float_t Float_t Int_t Int_t UInt_t UInt_t Rectangle_t Int_t Int_t Window_t TString Int_t GCValues_t GetPrimarySelectionOwner GetDisplay GetScreen GetColormap GetNativeEvent const char const char dpyName wid window const char font_name cursor keysym reg const char only_if_exist regb h Point_t winding char text const char depth char const char Int_t count const char ColorStruct_t color const char Pixmap_t Pixmap_t PictureAttributes_t attr const char char ret_data h unsigned char height h Atom_t Int_t ULong_t ULong_t unsigned char prop_list Atom_t Atom_t Atom_t Time_t type
char * Form(const char *fmt,...)
void AssignAndDelete(TString &target, char *tobedeleted)
R__EXTERN TSystem * gSystem
Handles lists of available runs for different datasets and types of data.
virtual void Remove(const run_index_t &run, const KVString &filename="")
Remove from the db ALL entries corresponding to the given run/index (and filename if given)
std::forward_list< run_index_t > CheckMultiRunfiles()
Returns a list with all run/indexes for which more than one file is in the available runs db.
void GetRunInfos(const run_index_t &run, KVList *dates, KVList *names)
virtual void Add(const run_index_t &run, const KVString &filename)
static ValType GetDataSetEnv(const KVString &dataset, const KVString &type, const ValType &defval)
Database class used to store information on different colliding systems studied during an experiment....
Bool_t IsCollision() const
retourne kTRUE, si le systeme est une collision ie projectile+cible
Define and manage data analysis tasks.
virtual void SetDataAnalyser(const Char_t *d)
virtual void SetPrereq(const Char_t *p)
virtual void SetStatusUpdateInterval(Long64_t n)
void SetExtraAClicIncludes(const KVString &list)
virtual const Char_t * GetPrereq() const
virtual void SetUserBaseClass(const Char_t *d)
KVDataRepository * GetRepository(const Char_t *name) const
void Print(Option_t *opt="") const
Base class for managing repositories of experimental data.
virtual KVDataSetManager * GetDataSetManager() const
Return pointer to data set manager for this repository.
virtual void CopyFileFromRepository(const KVDataSet *dataset, const Char_t *datatype, const Char_t *filename, const Char_t *destination)
void CreateAllNeededSubdirectories(const KVDataSet *DataSet, const Char_t *DataType)
virtual const Char_t * GetFullPathToTransferFile(const KVDataSet *dataset, const Char_t *datatype, const Char_t *runfile)
KVDataSet * GetDataSet(Int_t) const
Return pointer to DataSet using index in list of all datasets, index>=0.
Manage an experimental dataset corresponding to a given experiment or campaign.
TString GetFullPathToRunfile(const KVString &type, const run_index_t &run) const
TString GetFullPathToDB() const
Returns full path to file where database is written on disk.
void ls(Option_t *opt="") const override
Print dataset information.
TString GetOutputRepository(const Char_t *taskname) const
virtual void OpenDBFile(const Char_t *full_path_to_dbfile) const
Open the database from a file on disk.
run_index_list GetRunList_VersionSelection(const Char_t *type, const Char_t *version, KVDBSystem *sys=0)
TString GetDBName() const
void CheckMultiRunfiles(const Char_t *data_type)
Bool_t CheckRunfileAvailable(const KVString &type, const run_index_t &run)
virtual const Char_t * GetBaseFileName(const Char_t *type, const run_index_t &run) const
void CheckUpToDate(const Char_t *data_type, const Char_t *other_repos)
run_index_list GetRunList(const Char_t *data_type, const KVDBSystem *sys=0) const
void CopyRunfilesFromRepository(const Char_t *type, const run_index_list &runs, const Char_t *destdir)
Copies the runfiles of given "type" into the local directory "destdir".
KVDataRepository * GetRepository() const
Get pointer to data repository in which dataset is stored.
const Char_t * GetDataSetDir() const
KVAvailableRunsFile * GetAvailableRunsFile(const Char_t *type) const
void CommitRunfile(const KVString &type, const run_index_t &run, TFile *file)
TDatime GetRunfileDate(const KVString &type, const run_index_t &run)
virtual void AddAvailableDataType(const Char_t *)
KVDataAnalysisTask * GetAnalysisTask(Int_t) const
virtual void SaveDataBase() const
virtual std::unique_ptr< TList > GetListOfAvailableSystems(const Char_t *datatype, KVDBSystem *systol=0)
virtual KVDataAnalysisTask * GetAnalysisTaskAny(const Char_t *keywords) const
run_index_list GetRunList_DateSelection(const Char_t *type, TDatime *min=0, TDatime *max=0)
virtual void SetAnalysisTasks(const KVSeqCollection *)
TFile * NewRunfile(const KVString &type, const run_index_t &run)
Bool_t CheckRunfileUpToDate(const KVString &data_type, const run_index_t &run, KVDataRepository *other_repos)
virtual void CheckAvailable()
void DeleteRunfile(const KVString &type, const run_index_t &run, Bool_t confirm=kTRUE)
virtual Int_t GetNtasks() const
KVString GetDataSetEnv(const Char_t *type, const Char_t *defval="") const
run_index_list GetRunList_StageSelection(const Char_t *other_type, const Char_t *base_type, KVDBSystem *sys=0, Bool_t OnlyCol=kFALSE)
TString GetFullPathToDataSetFile(const Char_t *filename)
virtual void MakeAnalysisClass(const Char_t *task, const Char_t *classname)
void DeleteRunfiles(const Char_t *type, const run_index_list &lrun={}, Bool_t confirm=kTRUE)
TObject * open_runfile(const KVString &type, const run_index_t &run)
void CopyRunfilesToRepository(const Char_t *type, const run_index_list &runs, const Char_t *destrepo)
KVString GetRunfileName(const KVString &type, const run_index_t &run) const
KVExpDB * GetDataBase(Option_t *opt="") const
virtual Bool_t DataBaseNeedsUpdate() const
Bool_t OpenDataSetFile(const Char_t *filename, std::ifstream &file)
void SetDataSetSpecificTaskParameters(KVDataAnalysisTask *) const
virtual void WriteDBFile(const Char_t *full_path_to_dbfile) const
void Print(Option_t *opt="") const override
void SetName(const char *name) override
virtual Bool_t CheckUserCanAccess()
void UpdateAvailableRuns(const KVString &type)
run_index_list GetUpdatableRuns(const Char_t *data_type, const Char_t *other_repos)
void SetRepository(KVDataRepository *)
Set pointer to data repository in which dataset is stored.
KVDataSet()
Default constructor.
void CleanMultiRunfiles(const Char_t *data_type, Bool_t confirm=kTRUE)
virtual void OpenDataBase(Option_t *opt="") const
static Bool_t FindDataSetFile(const TString &dataset, const Char_t *filename)
TString GetDBFileName() const
Extension of TDatime to handle various useful date formats.
Base class to describe database of an experiment ,,.
static KVExpDB * MakeDataBase(const Char_t *name, const Char_t *datasetdir)
Extended TList class which owns its objects by default.
Description of an individual data file in an experimental dataset.
const Char_t * GetVersion() const
const KVDatime & GetFileWrittenDatime() const
const run_index_t & GetRunIndex() const
KaliVeda extensions to ROOT collection classes.
TObject * At(Int_t idx) const override
Extension of ROOT TString class which allows backwards compatibility with ROOT v3....
void Begin(TString delim) const
KVString Next(Bool_t strip_whitespace=kFALSE) const
static TClass * GetClass(Bool_t load=kTRUE, Bool_t silent=kFALSE)
virtual Int_t GetEntries() const
const char * AsSQLString() const
virtual const char * GetValue(const char *name, const char *dflt) const
virtual void SetValue(const char *name, const char *value, EEnvLevel level=kEnvChange, const char *type=nullptr)
Bool_t Defined(const char *name) const
TObject * FindObject(const char *name) const override
virtual void SetTitle(const char *title="")
const char * GetName() const override
const char * GetTitle() const override
virtual void SetName(const char *name)
const char * Data() const
void Form(const char *fmt,...)
TString & Remove(EStripType s, char c)
Bool_t Contains(const char *pat, ECaseCompare cmp=kExact) const
TString & ReplaceAll(const char *s1, const char *s2)
Bool_t cd(const char *path)
virtual int Chmod(const char *file, UInt_t mode)
virtual const char * DirName(const char *pathname)
virtual char * ConcatFileName(const char *dir, const char *name)
virtual int mkdir(const char *name, Bool_t recursive=kFALSE)
virtual Int_t Exec(const char *shellcmd)
virtual Bool_t AccessPathName(const char *path, EAccessMode mode=kFileExists)
virtual const char * BaseName(const char *pathname)
virtual Bool_t IsAbsoluteFileName(const char *dir)
Specifies a runfile according to run number and file index ,.
TString as_string() const
int index(int no_index=-1) const
double min(double x, double y)
double max(double x, double y)