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);
876 if (!HasDataType(
type)) {
877 Error(
"CheckRunfileAvailable",
878 "No data of type \"%s\" available for dataset %s", (
const char*)
type,
882 return GetAvailableRunsFile(
type)->CheckAvailable(run);
946 if (!HasDataType(
type)) {
947 Error(
"UpdateAvailableRuns",
948 "No data of type \"%s\" available for dataset %s", (
const char*)
type,
969 if (!fRepository)
return nullptr;
973 return fRepository->CreateNewFile(
this,
type, tmp.
Data());
998 if (!fRepository)
return;
1003 Error(
"DeleteRunfile",
"Run %s of type %s does not exist.",
1009 KVString doNotDelete = GetDataSetEnv(
"DataSet.RunFile.DoNotDelete",
"all");
1010 if (doNotDelete ==
"all" || doNotDelete.
Contains(
type)) {
1011 Error(
"DeleteRunFile",
"%s files cannot be deleted", (
const char*)
type);
1014 fRepository->DeleteFile(
this,
type,
filename.Data(), confirm);
1016 if (!fRepository->CheckFileStatus(
this,
type,
filename.Data()))
1017 GetAvailableRunsFile(
type)->Remove(run);
1049 if (NL.IsEmpty()) NL = GetRunList(
type);
1050 if (NL.IsEmpty())
return;
1052 DeleteRunfile(
type,
r, confirm);
1075 if (!
min && !
max)
return {};
1077 if (
min) printf(
"date minimum %s\n",
min->AsString());
1078 if (
max) printf(
"date maximum %s\n",
max->AsString());
1080 run_index_list numb;
1082 auto ll = GetListOfAvailableSystems(
type);
1085 for (
Int_t nl = 0; nl < ll->GetEntries(); nl += 1) {
1087 auto lrun = GetListOfAvailableSystems(
type, sys);
1088 auto oldList = numb;
1089 for (
Int_t nr = 0; nr < lrun->GetEntries(); nr += 1) {
1098 if (*min < run->GetFileWrittenDatime()) {
1109 if (numb.GetEntries() > oldList.GetEntries())
1110 printf(
"%s : %s\n", sys->
GetName(), (numb - oldList).AsString().Data());
1138 run_index_list manquant;
1139 auto ll = GetListOfAvailableSystems(ref_type);
1140 if (!ll || !ll->GetEntries()) {
1142 Info(
"GetRunList_StageSelection",
"No data available of type \"%s\"", ref_type);
1146 Info(
"GetRunList_StageSelection",
"No data available of type \"%s\" for system %s", ref_type, system->
GetName());
1150 Info(
"GetRunList_StageSelection",
"Liste des runs presents dans \"%s\" mais absent dans \"%s\"", ref_type,
type);
1154 for (
Int_t nl = 0; nl < ll->GetEntries(); nl += 1) {
1157 if (system && sys != system)
continue;
1159 auto nsys = GetRunList(
type, sys);
1160 auto nsys_ref = GetRunList(ref_type, sys);
1161 Int_t nref = nsys_ref.GetNValues();
1163 nsys_ref.Remove(nsys);
1165 Info(
"GetRunList_StageSelection",
"\nKVDBSystem : %s --> %d runs manquants sur %d : %s",
1167 nsys_ref.GetNValues(),
1169 nsys_ref.AsString().Data()
1171 manquant.Add(nsys_ref);
1187 run_index_list runs;
1189 unique_ptr<TList> lrun(GetListOfAvailableSystems(
type, sys));
1190 TIter next(lrun.get());
1197 unique_ptr<TList> ll(GetListOfAvailableSystems(
type));
1198 if (!ll.get() || !ll->GetEntries()) {
1200 Info(
"GetRunList_VersionSelection",
"No data available of type \"%s\"",
type);
1203 Int_t nsys = ll->GetEntries();
1204 for (
Int_t nl = 0; nl < nsys; nl += 1) {
1206 unique_ptr<TList> lrun(GetListOfAvailableSystems(
type, sys));
1207 TIter next(lrun.get());
1229 if (!fRepository)
return;
1234 fRepository->CommitFile(
file,
type,
this);
1243 TString oldfile = GetAvailableRunsFile(
type)->GetFileName(run);
1244 if (oldfile !=
"" && oldfile != newfile) {
1246 fRepository->DeleteFile(
this,
type, oldfile.
Data(),
1249 if (!fRepository->CheckFileStatus(
this,
type, oldfile.
Data()))
1250 GetAvailableRunsFile(
type)->Remove(run);
1252 if (oldfile != newfile) {
1254 GetAvailableRunsFile(
type)->Add(run, newfile.
Data());
1274 if (fUserGroups ==
"")
1278 unique_ptr<TObjArray> toks(fUserGroups.Tokenize(
' '));
1280 TIter next_name(toks.get());
1281 while ((group_name = (
TObjString*) next_name())) {
1283 if (!fRepository || (fRepository && fRepository->GetDataSetManager()->
1330 auto doubles = GetAvailableRunsFile(data_type)->CheckMultiRunfiles();
1331 if (doubles.empty()) {
1332 cout <<
"OK. No runs appear more than once." << endl;
1335 cout <<
"Runs which appear more than once: " << endl << endl;
1338 for (
auto& rr : doubles) {
1342 GetAvailableRunsFile(data_type)->GetRunInfos(rr, &dates, &filenames);
1344 cout <<
"Run " << rr <<
" : " << dates.
GetEntries() <<
" files >>>>>>" << endl;
1345 for (
int i = 0; i < dates.
GetEntries(); i++) {
1378 if (!fRepository)
return;
1382 if (doubles.empty()) {
1383 cout <<
"OK. No runs appear more than once." << endl;
1386 cout <<
"Runs which appear more than once: " << endl << endl;
1390 for (
auto& rr : doubles) {
1393 TDatime most_recent(
"1998-12-25 00:00:00");
1394 Int_t i_most_recent = 0;
1395 cout <<
"Run " << rr <<
" : " << dates.
GetEntries() <<
" files >>>>>>" << endl;
1396 for (
int i = 0; i < dates.
GetEntries(); i++) {
1399 if (rundate > most_recent) {
1400 most_recent = rundate;
1406 for (
int i = 0; i < dates.
GetEntries(); i++) {
1407 if (i == i_most_recent) {
1411 cout <<
"DELETE : ";
1416 if (i != i_most_recent) {
1418 fRepository->DeleteFile(
this, data_type,
1420 String().Data(), confirm);
1452 Error(
"CheckRunfileUpToDate",
1453 "Dataset \"%s\" not found in repository \"%s\"", GetName(),
1458 if (GetRunfileDate(data_type, run) < ds->
GetRunfileDate(data_type, run))
1485 return CheckRunfileUpToDate(data_type, run, _or);
1486 Error(
"CheckRunfileUpToDate",
1487 "No data repository known with this name : %s", (
const char*) other_repos);
1499 const Char_t* other_repos)
1504 if (!fRepository)
return;
1509 Error(
"CheckUpToDate",
1510 "No data repository known with this name : %s", other_repos);
1513 auto runlist = GetAvailableRunsFile(data_type)->GetRunList();
1514 Int_t need_update = 0;
1515 for (
auto& rr : runlist) {
1517 if (!CheckRunfileUpToDate(data_type, rr, _or)) {
1518 cout <<
" *** run " << rr <<
" needs update ***" <<
1520 cout <<
"\t\tREPOSITORY: " << fRepository->
1521 GetName() <<
"\tDATE: " << GetRunfileDate(data_type, rr).value().AsString() << endl;
1522 cout <<
"\t\tREPOSITORY: " << other_repos <<
"\tDATE: " << _or->
1523 GetDataSetManager()->GetDataSet(GetName())->
1524 GetRunfileDate(data_type, rr).value().AsString() << endl;
1529 cout <<
" *** All runfiles are up to date for data type " <<
1542 const Char_t* other_repos)
1547 run_index_list updates;
1548 if (!fRepository)
return updates;
1553 Error(
"CheckUpToDate",
1554 "No data repository known with this name : %s", other_repos);
1557 auto runlist = GetAvailableRunsFile(data_type)->GetRunList();
1558 for (
auto& rr : runlist) {
1560 if (!CheckRunfileUpToDate(data_type, rr, _or)) {
1583 if (!fRepository || !HasDataType(data_type)) {
1585 "No data of type %s available. Runlist will be empty.",
1590 return GetAvailableRunsFile(data_type)->GetRunList(system);
1670 Error(
"MakeAnalysisClass",
1671 "No user class required for analysis task \"%s\"", dat->
GetTitle());
1685 unique_ptr<TMethodCall> methcall(
new TMethodCall(cl,
"Make",
Form(
"\"%s\"", classname)));
1687 if (!methcall->IsValid()) {
1688 Error(
"MakeAnalysisClass",
"static Make(const Char_t*) method for class %s is not valid",
1694 methcall->Execute();
1729 if (!_task.
Contains(
"nalysis")) _task +=
" analysis";
1732 auto dat = GetAnalysisTaskAny(_task.
Data());
1734 Error(
"MakeAnalysisClass",
1735 "called for unknown or unavailable analysis task : %s", _task.
Data());
1738 return make_analysis_class(dat, classname);
1758 auto dat = GetAnalysisTask(task);
1760 Error(
"MakeAnalysisClass",
1761 "called for unknown or unavailable analysis task index : %d", task);
1764 return make_analysis_class(dat, classname);
1779 return OpenDataSetFile(GetName(), filename,
file);
1798 abspath.
Form(
"%s/%s", datasetdir.
Data(), filename);
1799 return SearchAndOpenKVFile(abspath,
file);
1802 return SearchAndOpenKVFile(filename,
file, datasetdir);
1816 return GetFullPathToDataSetFile(GetName(),
filename);
1832 if (!SearchKVFile(
filename, fullpath, datasetdir)) {
1833 ::Warning(
"KVDataSet::GetFullPathToDataSetFile",
"File %s not found in dataset subdirectory %s",
filename, datasetdir.
Data());
1852 return SearchKVFile(
filename, fullpath, datasetdir);
1866 return FindDataSetFile(GetName(),
filename);
1893 Error(
"GetAnalysisTaskAny",
"No task found with the following keywords in its title : %s", keywords);
1917 if (!SearchKVFile(GetDataSetDir(), path)) {
1919 Info(
"DataBaseNeedsUpdate",
"%s: Creating new dataset directory %s",
1920 GetName(), GetDataSetDir());
1923 Error(
"DataBaseNeedsUpdate",
1924 "%s: Dataset directory %s does not exist and cannot be created ?",
1925 GetName(), GetDataSetDir());
1929 SearchKVFile(GetDataSetDir(), path);
1933 of1 <<
"$(KV_WORK_DIR)/db/" << GetName() <<
"/DataBase.root : Runlist.csv Systems.dat" << endl;
1934 of1 <<
"\t@echo Database needs update" << endl;
1938 of2 <<
"# Automatically generated dummy Runlist.csv file" << endl;
1942 of3 <<
"# Automatically generated dummy Systems.dat file" << endl;
1989 if (
gEnv->
Defined(
Form(
"%s.DataRepository.DefaultOutputRepository", GetRepository()->GetName())))
1990 return TString(
gEnv->
GetValue(
Form(
"%s.DataRepository.DefaultOutputRepository", GetRepository()->GetName()),
""));
1991 TString orep = GetDataSetEnv(
Form(
"%s.DataAnalysisTask.OutputRepository", taskname), GetRepository()->GetName());
2006 for (
auto& run : runs) {
2030 Error(
"CopyRunfilesToRepository",
"Unknown destination repository : %s", destrepo);
2031 gDataRepositoryManager->
Print();
2037 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.
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)