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);
56 if (!fRepository)
return nullptr;
60 avrf = fRepository->NewAvailableRunsFile(
type,
this);
61 fAvailableRuns.
Add(avrf);
100 n.Append(
Form(
".%d.%d", GetKVMajorVersion(),
101 GetKVMinorVersion()));
118 return (fDBName !=
"" ? fDBName.Data() : GetName());
132 fDBase.reset(
new TFile(full_path_to_dbfile,
"READ"));
134 if (fDBase->IsOpen()) {
135 fDataBase =
dynamic_cast<KVExpDB*
>(fDBase->Get(GetDBName()));
137 Error(
"OpenDBFile",
"%s not found in file %s", GetDBName().Data(),
138 GetDBFileName().Data());
141 fDataBase->ReadObjects(fDBase.get());
157 TString dbfile = GetDBFileName();
164 TString dataset_alias = GetDataSetEnv(
"DataSet.Directory", GetName());
170 return dbfile_fullpath;
183 if (envar !=
"") t->
SetTitle(envar);
184 envar = GetDataSetEnv(
Form(
"%s.DataAnalysisTask.Analyser", t->
GetName()));
186 envar = GetDataSetEnv(
Form(
"%s.DataAnalysisTask.UserClass.Base", t->
GetName()));
188 envar = GetDataSetEnv(
Form(
"%s.DataAnalysisTask.Prereq", t->
GetName()));
190 envar = GetDataSetEnv(
Form(
"%s.DataAnalysisTask.UserClass.ExtraACliCIncludes", t->
GetName()));
192 Int_t nev = (
Int_t)GetDataSetEnv(
Form(
"%s.DataAnalysisTask.StatusUpdateInterval", t->
GetName()), 0.0);
208 TString dbfile_fullpath = GetFullPathToDB();
220 Error(
"SaveDataBase",
"Cannot create directory %s required to save database",
227 Error(
"SaveDataBase",
"Cannot create directory %s required to save database, even though %s exists: check disk space ?",
233 Error(
"SaveDataBase",
"Cannot create directory %s required to save database",
246 WriteDBFile(dbfile_fullpath.
Data());
261 Error(
"WriteDBFile",
"Database has not been built");
264 fDBase.reset(
new TFile(full_path_to_dbfile,
"recreate"));
266 fDataBase->Write(GetDBName());
267 fDataBase->WriteObjects(fDBase.get());
297 if (_opt ==
"UPDATE") {
298 OpenDataBase(_opt.
Data());
333 if ((!strcmp(opt,
"UPDATE")) || DataBaseNeedsUpdate()) {
336 Info(
"OpenDataBase",
"Updating database file");
337 fDataBaseUpdateInProgress =
true;
338 is_glob_db = (fDataBase == gExpDB);
348 Info(
"OpenDataBase",
"No database defined for dataset");
352 if (fDataBase && is_glob_db) fDataBase->cd();
353 fDataBaseUpdateInProgress =
false;
355 else if (!fDataBase) {
360 if (!LoadPlugin(
"KVExpDB", GetDBName())) {
361 Error(
"GetDataBase",
"Cannot load required plugin library");
365 TString dbfile_fullpath = GetFullPathToDB();
367 OpenDBFile(dbfile_fullpath.
Data());
380 cout <<
"Dataset name=" << GetName() <<
" (" << GetTitle() <<
")";
382 cout <<
" [ AVAILABLE: ";
383 cout << fDatatypes.Data();
387 cout <<
" [UNAVAILABLE]";
412 cout <<
" *** No available analysis tasks ***"
417 for (
int i = 1; i <= GetNtasks(); i++) {
419 cout <<
"\t" << i <<
". " << dat->
GetTitle() << endl;
425 cout <<
"Available data types: " << fDatatypes.Data() << endl;
456 SetAvailable(fRepository->CheckSubdirExists(GetDataPathSubdir()));
460 KVString data_types = GetDataSetEnv(
"KVDataSet.DataTypes",
"");
461 if (data_types ==
"") {
462 Warning(
"CheckAvailable",
"No datatypes defined for this dataset: %s\nCheck value of KVDataSet.DataTypes or %s.KVDataSet.DataTypes",
463 GetName(), GetName());
468 data_types.
Begin(
" ");
469 while (!data_types.
End()) {
472 (fRepository && fRepository->CheckSubdirExists(GetDataPathSubdir(), GetDataTypeSubdir(
type.Data())))
474 AddAvailableDataType(
type.Data());
478 SetAvailable(fDatatypes !=
"");
480 if (!CheckUserCanAccess()) {
492 if (fDatatypes !=
"") fDatatypes +=
" ";
518 TIter nxt(task_list);
525 SetDataSetSpecificTaskParameters(new_task);
526 fAllTasks.Add(new_task);
528 if (HasDataType(new_task->
GetPrereq())) {
529 fTasks.Add(new_task);
546 return fTasks.GetSize();
581 if (!GetAvailableRunsFile(datatype)) {
582 Error(
"GetListOfAvailableSystems(const Char_t*)",
583 "No available runs file for type %s", datatype);
586 return GetAvailableRunsFile(datatype)->GetListOfAvailableSystems(systol);
606 return GetListOfAvailableSystems(datan->
GetPrereq(), systol);
654 TString path = GetDataSetEnv(
"DataSet.Directory",
name);
659 fCalibDir = GetDATADIRFilePath(path);
674 return fCalibDir.Data();
707 if (fRepository) fRepository->
cd();
772 if (!strcmp(
type,
"raw") && !strcmp(GetDataSetEnv(
"MFM.WithEbyedat",
""),
"yes")) {
773 TString ebydir = GetDataSetDir();
774 ebydir +=
"/ebyedat";
775 gEnv->
SetValue(
"KVMFMDataFileReader.ActionsDirectory", ebydir);
776 if (strcmp(GetDataSetEnv(
"MFM.EbyedatActionsExpName",
""),
""))
777 gEnv->
SetValue(
"KVMFMDataFileReader.ActionsExpName", GetDataSetEnv(
"MFM.EbyedatActionsExpName",
""));
778 TObject*
f = GetRepository()->OpenDataSetRunFile(
this,
type, run, GetName());
780 gEnv->
SetValue(
"KVMFMDataFileReader.ActionsDirectory",
"");
781 gEnv->
SetValue(
"KVMFMDataFileReader.ActionsExpName",
"");
784 return GetRepository()->OpenDataSetRunFile(
this,
type, run, GetName());
801 if (fRepository)
file = GetRunfileName(
type, run);
804 return fRepository->GetFullPathToOpenFile(
this,
type,
file.Data());
819 if (!HasDataType(
type)) {
820 Error(
"GetRunfileName",
821 "No data of type \"%s\" available for dataset %s", (
const char*)
type,
826 return GetAvailableRunsFile(
type)->GetFileName(run);
845 if (!HasDataType(
type)) {
846 Error(
"GetRunfileDate",
847 "No data of type \"%s\" available for dataset %s", (
const char*)
type,
854 if (!GetAvailableRunsFile(
type)->GetRunInfo(run, date,
filename)) {
855 Error(
"GetRunfileDate",
856 "Runfile not found for run %d index %d (data type: %s)", run.
run(), run.
index(), (
const char*)
type);
911 auto arf = GetAvailableRunsFile(datatype);
915 if (
v.value().has_index())
return v;
916 int r =
v.value().run();
918 if (GetDataBase()->HasIndexMultiplier() &&
r > GetDataBase()->GetIndexMultiplier()) {
919 r /= GetDataBase()->GetIndexMultiplier();
920 int i =
v.value().run() % GetDataBase()->GetIndexMultiplier();
940 if (!HasDataType(
type)) {
941 Error(
"CheckRunfileAvailable",
942 "No data of type \"%s\" available for dataset %s", (
const char*)
type,
946 return GetAvailableRunsFile(
type)->CheckAvailable(run);
1010 if (!HasDataType(
type)) {
1011 Error(
"UpdateAvailableRuns",
1012 "No data of type \"%s\" available for dataset %s", (
const char*)
type,
1033 if (!fRepository)
return nullptr;
1037 return fRepository->CreateNewFile(
this,
type, tmp.
Data());
1062 if (!fRepository)
return;
1067 Error(
"DeleteRunfile",
"Run %s of type %s does not exist.",
1073 KVString doNotDelete = GetDataSetEnv(
"DataSet.RunFile.DoNotDelete",
"all");
1074 if (doNotDelete ==
"all" || doNotDelete.
Contains(
type)) {
1075 Error(
"DeleteRunFile",
"%s files cannot be deleted", (
const char*)
type);
1078 fRepository->DeleteFile(
this,
type,
filename.Data(), confirm);
1080 if (!fRepository->CheckFileStatus(
this,
type,
filename.Data()))
1081 GetAvailableRunsFile(
type)->Remove(run);
1113 if (NL.IsEmpty()) NL = GetRunList(
type);
1114 if (NL.IsEmpty())
return;
1116 DeleteRunfile(
type,
r, confirm);
1139 if (!
min && !
max)
return {};
1141 if (
min) printf(
"date minimum %s\n",
min->AsString());
1142 if (
max) printf(
"date maximum %s\n",
max->AsString());
1144 run_index_list numb;
1146 auto ll = GetListOfAvailableSystems(
type);
1149 for (
Int_t nl = 0; nl < ll->GetEntries(); nl += 1) {
1151 auto lrun = GetListOfAvailableSystems(
type, sys);
1152 auto oldList = numb;
1153 for (
Int_t nr = 0; nr < lrun->GetEntries(); nr += 1) {
1162 if (*min < run->GetFileWrittenDatime()) {
1173 if (numb.GetEntries() > oldList.GetEntries())
1174 printf(
"%s : %s\n", sys->
GetName(), (numb - oldList).AsString().Data());
1202 run_index_list manquant;
1203 auto ll = GetListOfAvailableSystems(ref_type);
1204 if (!ll || !ll->GetEntries()) {
1206 Info(
"GetRunList_StageSelection",
"No data available of type \"%s\"", ref_type);
1210 Info(
"GetRunList_StageSelection",
"No data available of type \"%s\" for system %s", ref_type, system->
GetName());
1214 Info(
"GetRunList_StageSelection",
"Liste des runs presents dans \"%s\" mais absent dans \"%s\"", ref_type,
type);
1218 for (
Int_t nl = 0; nl < ll->GetEntries(); nl += 1) {
1221 if (system && sys != system)
continue;
1223 auto nsys = GetRunList(
type, sys);
1224 auto nsys_ref = GetRunList(ref_type, sys);
1225 Int_t nref = nsys_ref.GetNValues();
1227 nsys_ref.Remove(nsys);
1229 Info(
"GetRunList_StageSelection",
"\nKVDBSystem : %s --> %d runs manquants sur %d : %s",
1231 nsys_ref.GetNValues(),
1233 nsys_ref.AsString().Data()
1235 manquant.Add(nsys_ref);
1251 run_index_list runs;
1253 unique_ptr<TList> lrun(GetListOfAvailableSystems(
type, sys));
1254 TIter next(lrun.get());
1261 unique_ptr<TList> ll(GetListOfAvailableSystems(
type));
1262 if (!ll.get() || !ll->GetEntries()) {
1264 Info(
"GetRunList_VersionSelection",
"No data available of type \"%s\"",
type);
1267 Int_t nsys = ll->GetEntries();
1268 for (
Int_t nl = 0; nl < nsys; nl += 1) {
1270 unique_ptr<TList> lrun(GetListOfAvailableSystems(
type, sys));
1271 TIter next(lrun.get());
1293 if (!fRepository)
return;
1298 fRepository->CommitFile(
file,
type,
this);
1307 TString oldfile = GetAvailableRunsFile(
type)->GetFileName(run);
1308 if (oldfile !=
"" && oldfile != newfile) {
1310 fRepository->DeleteFile(
this,
type, oldfile.
Data(),
1313 if (!fRepository->CheckFileStatus(
this,
type, oldfile.
Data()))
1314 GetAvailableRunsFile(
type)->Remove(run);
1316 if (oldfile != newfile) {
1318 GetAvailableRunsFile(
type)->Add(run, newfile.
Data());
1338 if (fUserGroups ==
"")
1342 unique_ptr<TObjArray> toks(fUserGroups.Tokenize(
' '));
1344 TIter next_name(toks.get());
1345 while ((group_name = (
TObjString*) next_name())) {
1347 if (!fRepository || (fRepository && fRepository->GetDataSetManager()->
1394 auto doubles = GetAvailableRunsFile(data_type)->CheckMultiRunfiles();
1395 if (doubles.empty()) {
1396 cout <<
"OK. No runs appear more than once." << endl;
1399 cout <<
"Runs which appear more than once: " << endl << endl;
1402 for (
auto& rr : doubles) {
1406 GetAvailableRunsFile(data_type)->GetRunInfos(rr, &dates, &filenames);
1408 cout <<
"Run " << rr <<
" : " << dates.
GetEntries() <<
" files >>>>>>" << endl;
1409 for (
int i = 0; i < dates.
GetEntries(); i++) {
1442 if (!fRepository)
return;
1446 if (doubles.empty()) {
1447 cout <<
"OK. No runs appear more than once." << endl;
1450 cout <<
"Runs which appear more than once: " << endl << endl;
1454 for (
auto& rr : doubles) {
1457 TDatime most_recent(
"1998-12-25 00:00:00");
1458 Int_t i_most_recent = 0;
1459 cout <<
"Run " << rr <<
" : " << dates.
GetEntries() <<
" files >>>>>>" << endl;
1460 for (
int i = 0; i < dates.
GetEntries(); i++) {
1463 if (rundate > most_recent) {
1464 most_recent = rundate;
1470 for (
int i = 0; i < dates.
GetEntries(); i++) {
1471 if (i == i_most_recent) {
1475 cout <<
"DELETE : ";
1480 if (i != i_most_recent) {
1482 fRepository->DeleteFile(
this, data_type,
1484 String().Data(), confirm);
1516 Error(
"CheckRunfileUpToDate",
1517 "Dataset \"%s\" not found in repository \"%s\"", GetName(),
1522 if (GetRunfileDate(data_type, run) < ds->
GetRunfileDate(data_type, run))
1549 return CheckRunfileUpToDate(data_type, run, _or);
1550 Error(
"CheckRunfileUpToDate",
1551 "No data repository known with this name : %s", (
const char*) other_repos);
1563 const Char_t* other_repos)
1568 if (!fRepository)
return;
1573 Error(
"CheckUpToDate",
1574 "No data repository known with this name : %s", other_repos);
1577 auto runlist = GetAvailableRunsFile(data_type)->GetRunList();
1578 Int_t need_update = 0;
1579 for (
auto& rr : runlist) {
1581 if (!CheckRunfileUpToDate(data_type, rr, _or)) {
1582 cout <<
" *** run " << rr <<
" needs update ***" <<
1584 cout <<
"\t\tREPOSITORY: " << fRepository->
1585 GetName() <<
"\tDATE: " << GetRunfileDate(data_type, rr).value().AsString() << endl;
1586 cout <<
"\t\tREPOSITORY: " << other_repos <<
"\tDATE: " << _or->
1587 GetDataSetManager()->GetDataSet(GetName())->
1588 GetRunfileDate(data_type, rr).value().AsString() << endl;
1593 cout <<
" *** All runfiles are up to date for data type " <<
1606 const Char_t* other_repos)
1611 run_index_list updates;
1612 if (!fRepository)
return updates;
1617 Error(
"CheckUpToDate",
1618 "No data repository known with this name : %s", other_repos);
1621 auto runlist = GetAvailableRunsFile(data_type)->GetRunList();
1622 for (
auto& rr : runlist) {
1624 if (!CheckRunfileUpToDate(data_type, rr, _or)) {
1647 if (!fRepository || !HasDataType(data_type)) {
1649 "No data of type %s available. Runlist will be empty.",
1654 return GetAvailableRunsFile(data_type)->GetRunList(system);
1734 Error(
"MakeAnalysisClass",
1735 "No user class required for analysis task \"%s\"", dat->
GetTitle());
1749 unique_ptr<TMethodCall> methcall(
new TMethodCall(cl,
"Make",
Form(
"\"%s\"", classname)));
1751 if (!methcall->IsValid()) {
1752 Error(
"MakeAnalysisClass",
"static Make(const Char_t*) method for class %s is not valid",
1758 methcall->Execute();
1793 if (!_task.
Contains(
"nalysis")) _task +=
" analysis";
1796 auto dat = GetAnalysisTaskAny(_task.
Data());
1798 Error(
"MakeAnalysisClass",
1799 "called for unknown or unavailable analysis task : %s", _task.
Data());
1802 return make_analysis_class(dat, classname);
1822 auto dat = GetAnalysisTask(task);
1824 Error(
"MakeAnalysisClass",
1825 "called for unknown or unavailable analysis task index : %d", task);
1828 return make_analysis_class(dat, classname);
1843 return OpenDataSetFile(GetName(), filename,
file);
1862 abspath.
Form(
"%s/%s", datasetdir.
Data(), filename);
1863 return SearchAndOpenKVFile(abspath,
file);
1866 return SearchAndOpenKVFile(filename,
file, datasetdir);
1880 return GetFullPathToDataSetFile(GetName(),
filename);
1896 if (!SearchKVFile(
filename, fullpath, datasetdir)) {
1897 ::Warning(
"KVDataSet::GetFullPathToDataSetFile",
"File %s not found in dataset subdirectory %s",
filename, datasetdir.
Data());
1916 return SearchKVFile(
filename, fullpath, datasetdir);
1930 return FindDataSetFile(GetName(),
filename);
1957 Error(
"GetAnalysisTaskAny",
"No task found with the following keywords in its title : %s", keywords);
1981 if (!SearchKVFile(GetDataSetDir(), path)) {
1983 Info(
"DataBaseNeedsUpdate",
"%s: Creating new dataset directory %s",
1984 GetName(), GetDataSetDir());
1987 Error(
"DataBaseNeedsUpdate",
1988 "%s: Dataset directory %s does not exist and cannot be created ?",
1989 GetName(), GetDataSetDir());
1993 SearchKVFile(GetDataSetDir(), path);
1997 of1 <<
"$(KV_WORK_DIR)/db/" << GetName() <<
"/DataBase.root : Runlist.csv Systems.dat" << endl;
1998 of1 <<
"\t@echo Database needs update" << endl;
2002 of2 <<
"# Automatically generated dummy Runlist.csv file" << endl;
2006 of3 <<
"# Automatically generated dummy Systems.dat file" << endl;
2053 if (
gEnv->
Defined(
Form(
"%s.DataRepository.DefaultOutputRepository", GetRepository()->GetName())))
2054 return TString(
gEnv->
GetValue(
Form(
"%s.DataRepository.DefaultOutputRepository", GetRepository()->GetName()),
""));
2055 TString orep = GetDataSetEnv(
Form(
"%s.DataAnalysisTask.OutputRepository", taskname), GetRepository()->GetName());
2070 for (
auto& run : runs) {
2094 Error(
"CopyRunfilesToRepository",
"Unknown destination repository : %s", destrepo);
2095 gDataRepositoryManager->
Print();
2101 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 Bool_t WithUserClass() const
virtual void SetPrereq(const Char_t *p)
virtual void SetStatusUpdateInterval(Long64_t n)
virtual const Char_t * GetUserBaseClass() const
virtual Bool_t CheckUserBaseClassIsLoaded() const
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.
std::optional< TDatime > GetRunfileDate(const KVString &type, const run_index_t &run)
TString GetFullPathToRunfile(const KVString &type, const run_index_t &run) const
TString GetFullPathToDB() const
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)
virtual void AddAvailableDataType(const Char_t *)
bool make_analysis_class(const KVDataAnalysisTask *, const Char_t *classname)
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
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)
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
Check configuration variables to see if the task parameters have been "tweaked" for the dataset.
virtual void WriteDBFile(const Char_t *full_path_to_dbfile) const
Write the database to disk.
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.
bool MakeAnalysisClass(const Char_t *task, const Char_t *classname)
KVDataSet()
Default constructor.
std::optional< run_index_t > GetRunNumberFromFileName(const TString &datatype, const TString &filename)
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)