]> git.uio.no Git - u/mrichter/AliRoot.git/blame - STEER/CDB/AliCDBLocal.cxx
git://git.uio.no / u / mrichter / AliRoot.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
AliShuttle can set mirror SEs for OCDB uploads via static method
[u/mrichter/AliRoot.git] / STEER / CDB / AliCDBLocal.cxx
CommitLineData
fe913d8f 1/**************************************************************************
2 * Copyright(c) 1998-1999, ALICE Experiment at CERN, All rights reserved. *
3 * *
4 * Author: The ALICE Off-line Project. *
5 * Contributors are mentioned in the code where appropriate. *
6 * *
7 * Permission to use, copy, modify and distribute this software and its *
8 * documentation strictly for non-commercial purposes is hereby granted *
9 * without fee, provided that the above copyright notice appears in all *
10 * copies and that both the copyright notice and this permission notice *
11 * appear in the supporting documentation. The authors make no claims *
12 * about the suitability of this software for any purpose. It is *
13 * provided "as is" without express or implied warranty. *
14 **************************************************************************/
15
fe913d8f 16/////////////////////////////////////////////////////////////////////////////////////////////////
17// //
9e1ceb13 18// AliCDBLocal //
19// access class to a DataBase in a local storage //
fe913d8f 20// //
21/////////////////////////////////////////////////////////////////////////////////////////////////
22
b09247a2 23#include <cstdlib>
fe913d8f 24#include <TSystem.h>
fe913d8f 25#include <TObjString.h>
26#include <TRegexp.h>
9e1ceb13 27#include <TFile.h>
28#include <TKey.h>
fe913d8f 29
fe913d8f 30#include "AliCDBLocal.h"
9e1ceb13 31#include "AliCDBEntry.h"
32#include "AliLog.h"
fe913d8f 33
34ClassImp(AliCDBLocal)
35
36//_____________________________________________________________________________
9e1ceb13 37AliCDBLocal::AliCDBLocal(const char* baseDir):
38fBaseDirectory(baseDir)
fe913d8f 39{
40// constructor
9e1ceb13 41
820b4d9e 42 AliDebug(1, Form("fBaseDirectory = %s",fBaseDirectory.Data()));
43
9e1ceb13 44 // check baseDire: trying to cd to baseDir; if it does not exist, create it
45 void* dir = gSystem->OpenDirectory(baseDir);
46 if (dir == NULL) {
47 if (gSystem->mkdir(baseDir, kTRUE)) {
48 AliError(Form("Can't open directory <%s>!", baseDir));
49 }
50
51 } else {
52 AliDebug(2,Form("Folder <%s> found",fBaseDirectory.Data()));
53 gSystem->FreeDirectory(dir);
54 }
62032124 55 fType="local";
56 fBaseFolder = fBaseDirectory;
fe913d8f 57}
58
59//_____________________________________________________________________________
9e1ceb13 60AliCDBLocal::~AliCDBLocal() {
61// destructor
fe913d8f 62
63}
64
9e1ceb13 65
fe913d8f 66//_____________________________________________________________________________
9e1ceb13 67Bool_t AliCDBLocal::FilenameToId(const char* filename, AliCDBRunRange& runRange,
4b5e0dce 68 Int_t& version, Int_t& subVersion) {
9e1ceb13 69// build AliCDBId from filename numbers
70
9e1ceb13 71
72 Ssiz_t mSize;
fe913d8f 73
9e1ceb13 74 // valid filename: Run#firstRun_#lastRun_v#version_s#subVersion.root
75 TRegexp keyPattern("^Run[0-9]+_[0-9]+_v[0-9]+_s[0-9]+.root$");
76 keyPattern.Index(filename, &mSize);
77 if (!mSize) {
78 AliDebug(2, Form("Bad filename <%s>.", filename));
79 return kFALSE;
80 }
81
82 TString idString(filename);
83 idString.Resize(idString.Length() - sizeof(".root") + 1);
84
85 TObjArray* strArray = (TObjArray*) idString.Tokenize("_");
86
87 TString firstRunString(((TObjString*) strArray->At(0))->GetString());
88 runRange.SetFirstRun(atoi(firstRunString.Data() + 3));
89 runRange.SetLastRun(atoi(((TObjString*) strArray->At(1))->GetString()));
90
91 TString verString(((TObjString*) strArray->At(2))->GetString());
92 version = atoi(verString.Data() + 1);
93
94 TString subVerString(((TObjString*) strArray->At(3))->GetString());
95 subVersion = atoi(subVerString.Data() + 1);
96
97 delete strArray;
98
99 return kTRUE;
fe913d8f 100}
101
9e1ceb13 102
fe913d8f 103//_____________________________________________________________________________
c3a7b59a 104Bool_t AliCDBLocal::IdToFilename(const AliCDBId& id, TString& filename) const {
9e1ceb13 105// build file name from AliCDBId data (run range, version, subVersion)
106
820b4d9e 107 AliDebug(1, Form("fBaseDirectory = %s",fBaseDirectory.Data()));
108
c3a7b59a 109 if (!id.GetAliCDBRunRange().IsValid()) {
b05400be 110 AliDebug(2,Form("Invalid run range <%d, %d>.",
c3a7b59a 111 id.GetFirstRun(), id.GetLastRun()));
9e1ceb13 112 return kFALSE;
113 }
114
c3a7b59a 115 if (id.GetVersion() < 0) {
116 AliDebug(2,Form("Invalid version <%d>.", id.GetVersion()));
9e1ceb13 117 return kFALSE;
118 }
fe913d8f 119
c3a7b59a 120 if (id.GetSubVersion() < 0) {
6720fa1f 121 AliDebug(2,Form("Invalid subversion <%d>.", id.GetSubVersion()));
9e1ceb13 122 return kFALSE;
123 }
124
c3a7b59a 125 filename = Form("Run%d_%d_v%d_s%d.root", id.GetFirstRun(), id.GetLastRun(),
126 id.GetVersion(), id.GetSubVersion());
127
128 filename.Prepend(fBaseDirectory +'/' + id.GetPath() + '/');
9e1ceb13 129
130 return kTRUE;
fe913d8f 131}
132
133//_____________________________________________________________________________
9e1ceb13 134Bool_t AliCDBLocal::PrepareId(AliCDBId& id) {
135// prepare id (version, subVersion) of the object that will be stored (called by PutEntry)
136
c3a7b59a 137 TString dirName = Form("%s/%s", fBaseDirectory.Data(), id.GetPath().Data());
9e1ceb13 138
139 // go to the path; if directory does not exist, create it
140 void* dirPtr = gSystem->OpenDirectory(dirName);
141 if (!dirPtr) {
142 gSystem->mkdir(dirName, kTRUE);
143 dirPtr = gSystem->OpenDirectory(dirName);
144
145 if (!dirPtr) {
146 AliError(Form("Can't create directory <%s>!",
147 dirName.Data()));
148 return kFALSE;
149 }
150 }
fe913d8f 151
9e1ceb13 152 const char* filename;
4667c116 153 AliCDBRunRange aRunRange; // the runRange got from filename
9e1ceb13 154 AliCDBRunRange lastRunRange(-1,-1); // highest runRange found
155 Int_t aVersion, aSubVersion; // the version subVersion got from filename
156 Int_t lastVersion = 0, lastSubVersion = -1; // highest version and subVersion found
157
158 if (!id.HasVersion()) { // version not specified: look for highest version & subVersion
159
160 while ((filename = gSystem->GetDirEntry(dirPtr))) { // loop on the files
161
162 TString aString(filename);
163 if (aString == "." || aString == "..") continue;
164
165 if (!FilenameToId(filename, aRunRange, aVersion,
166 aSubVersion)) {
b05400be 167 AliDebug(2,Form(
9e1ceb13 168 "Bad filename <%s>! I'll skip it.",
169 filename));
170 continue;
171 }
172
173 if (!aRunRange.Overlaps(id.GetAliCDBRunRange())) continue;
174 if(aVersion < lastVersion) continue;
175 if(aVersion > lastVersion) lastSubVersion = -1;
176 if(aSubVersion < lastSubVersion) continue;
177 lastVersion = aVersion;
178 lastSubVersion = aSubVersion;
179 lastRunRange = aRunRange;
180 }
181
182 id.SetVersion(lastVersion);
183 id.SetSubVersion(lastSubVersion + 1);
184
185 } else { // version specified, look for highest subVersion only
186
187 while ((filename = gSystem->GetDirEntry(dirPtr))) { // loop on the files
188
189 TString aString(filename);
190 if (aString == "." || aString == "..") {
191 continue;
192 }
193
194 if (!FilenameToId(filename, aRunRange, aVersion,
195 aSubVersion)) {
b05400be 196 AliDebug(2,Form(
9e1ceb13 197 "Bad filename <%s>!I'll skip it.",
198 filename));
199 continue;
200 }
201
202 if (aRunRange.Overlaps(id.GetAliCDBRunRange())
203 && aVersion == id.GetVersion()
204 && aSubVersion > lastSubVersion) {
205 lastSubVersion = aSubVersion;
206 lastRunRange = aRunRange;
207 }
208
209 }
210
211 id.SetSubVersion(lastSubVersion + 1);
212 }
fe913d8f 213
9e1ceb13 214 gSystem->FreeDirectory(dirPtr);
fe913d8f 215
9e1ceb13 216 TString lastStorage = id.GetLastStorage();
217 if(lastStorage.Contains(TString("grid"), TString::kIgnoreCase) &&
218 id.GetSubVersion() > 0 ){
219 AliError(Form("Grid to Local Storage error! local object with version v%d_s%d found:",id.GetVersion(), id.GetSubVersion()-1));
220 AliError(Form("This object has been already transferred from Grid (check v%d_s0)!",id.GetVersion()));
221 return kFALSE;
222 }
223
224 if(lastStorage.Contains(TString("new"), TString::kIgnoreCase) &&
225 id.GetSubVersion() > 0 ){
84090f85 226 AliDebug(2, Form("A NEW object is being stored with version v%d_s%d",
9e1ceb13 227 id.GetVersion(),id.GetSubVersion()));
84090f85 228 AliDebug(2, Form("and it will hide previously stored object with v%d_s%d!",
9e1ceb13 229 id.GetVersion(),id.GetSubVersion()-1));
230 }
231
232 if(!lastRunRange.IsAnyRange() && !(lastRunRange.IsEqual(& id.GetAliCDBRunRange())))
233 AliWarning(Form("Run range modified w.r.t. previous version (Run%d_%d_v%d_s%d)",
234 lastRunRange.GetFirstRun(), lastRunRange.GetLastRun(),
235 id.GetVersion(), id.GetSubVersion()-1));
236
237 return kTRUE;
fe913d8f 238}
239
4667c116 240// //_____________________________________________________________________________
241// Bool_t AliCDBLocal::GetId(const AliCDBId& query, AliCDBId& result) {
242// // look for filename matching query (called by GetEntry)
243//
244// TString dirName = Form("%s/%s", fBaseDirectory.Data(), query.GetPath().Data());
245//
246// void* dirPtr = gSystem->OpenDirectory(dirName);
247// if (!dirPtr) {
248// AliDebug(2,Form("Directory <%s> not found", (query.GetPath()).Data()));
249// AliDebug(2,Form("in DB folder %s", fBaseDirectory.Data()));
250// return kFALSE;
251// }
252//
253// const char* filename;
254//
255// AliCDBRunRange aRunRange; // the runRange got from filename
256// Int_t aVersion, aSubVersion; // the version and subVersion got from filename
257//
258// if (!query.HasVersion()) { // neither version and subversion specified -> look for highest version and subVersion
259//
260// while ((filename = gSystem->GetDirEntry(dirPtr))) { // loop on files
261//
262// TString aString(filename);
263// if (aString == "." || aString == "..") continue;
264//
265// if (!FilenameToId(filename, aRunRange, aVersion, aSubVersion)) continue;
266// // aRunRange, aVersion, aSubVersion filled from filename
267//
268// if (!aRunRange.Comprises(query.GetAliCDBRunRange())) continue;
269// // aRunRange contains requested run!
270//
271// if (result.GetVersion() < aVersion) {
272// result.SetVersion(aVersion);
273// result.SetSubVersion(aSubVersion);
274//
275// result.SetFirstRun(
276// aRunRange.GetFirstRun());
277// result.SetLastRun(
278// aRunRange.GetLastRun());
279//
280// } else if (result.GetVersion() == aVersion
281// && result.GetSubVersion()
282// < aSubVersion) {
283//
284// result.SetSubVersion(aSubVersion);
285//
286// result.SetFirstRun(
287// aRunRange.GetFirstRun());
288// result.SetLastRun(
289// aRunRange.GetLastRun());
290// } else if (result.GetVersion() == aVersion
291// && result.GetSubVersion() == aSubVersion){
292// AliDebug(2,Form("More than one object valid for run %d, version %d_%d!",
293// query.GetFirstRun(), aVersion, aSubVersion));
294// gSystem->FreeDirectory(dirPtr);
295// return kFALSE;
296// }
297// }
298//
299// } else if (!query.HasSubVersion()) { // version specified but not subversion -> look for highest subVersion
300//
301// result.SetVersion(query.GetVersion());
302//
303// while ((filename = gSystem->GetDirEntry(dirPtr))) { // loop on files
304//
305// TString aString(filename);
306// if (aString == "." || aString == "..") continue;
307//
308// if (!FilenameToId(filename, aRunRange, aVersion, aSubVersion)) continue;
309// // aRunRange, aVersion, aSubVersion filled from filename
310//
311// if (!aRunRange.Comprises(query.GetAliCDBRunRange())) continue;
312// // aRunRange contains requested run!
313//
314// if(query.GetVersion() != aVersion) continue;
315// // aVersion is requested version!
316//
317// if(result.GetSubVersion() == aSubVersion){
318// AliDebug(2,Form("More than one object valid for run %d, version %d_%d!",
319// query.GetFirstRun(), aVersion, aSubVersion));
320// gSystem->FreeDirectory(dirPtr);
321// return kFALSE;
322// }
323// if( result.GetSubVersion() < aSubVersion) {
324//
325// result.SetSubVersion(aSubVersion);
326//
327// result.SetFirstRun(
328// aRunRange.GetFirstRun());
329// result.SetLastRun(
330// aRunRange.GetLastRun());
331// }
332// }
333//
334// } else { // both version and subversion specified
335//
336// while ((filename = gSystem->GetDirEntry(dirPtr))) { // loop on files
337//
338// TString aString(filename);
339// if (aString == "." || aString == "..") continue;
340//
341// if (!FilenameToId(filename, aRunRange, aVersion, aSubVersion)) continue;
342// // aRunRange, aVersion, aSubVersion filled from filename
343//
344// if (!aRunRange.Comprises(query.GetAliCDBRunRange())) continue;
345// // aRunRange contains requested run!
346//
347// if(query.GetVersion() != aVersion || query.GetSubVersion() != aSubVersion) continue;
348// // aVersion and aSubVersion are requested version and subVersion!
349//
350// if(result.GetVersion() == aVersion && result.GetSubVersion() == aSubVersion){
351// AliDebug(2,Form("More than one object valid for run %d, version %d_%d!",
352// query.GetFirstRun(), aVersion, aSubVersion));
353// gSystem->FreeDirectory(dirPtr);
354// return kFALSE;
355// }
356// result.SetVersion(aVersion);
357// result.SetSubVersion(aSubVersion);
358// result.SetFirstRun(aRunRange.GetFirstRun());
359// result.SetLastRun(aRunRange.GetLastRun());
360//
361// }
362// }
363//
364// gSystem->FreeDirectory(dirPtr);
365//
366// return kTRUE;
367// }
368
9e1ceb13 369//_____________________________________________________________________________
4667c116 370AliCDBId* AliCDBLocal::GetId(const AliCDBId& query) {
371// look for filename matching query (called by GetEntryId)
9e1ceb13 372
c3a7b59a 373 TString dirName = Form("%s/%s", fBaseDirectory.Data(), query.GetPath().Data());
9e1ceb13 374
c3a7b59a 375 void* dirPtr = gSystem->OpenDirectory(dirName);
9e1ceb13 376 if (!dirPtr) {
024cf675 377 AliDebug(2,Form("Directory <%s> not found", (query.GetPath()).Data()));
378 AliDebug(2,Form("in DB folder %s", fBaseDirectory.Data()));
4667c116 379 return NULL;
9e1ceb13 380 }
381
c3a7b59a 382 const char* filename;
4667c116 383 AliCDBId *result = new AliCDBId();
384 result->SetPath(query.GetPath());
c3a7b59a 385
9e1ceb13 386 AliCDBRunRange aRunRange; // the runRange got from filename
387 Int_t aVersion, aSubVersion; // the version and subVersion got from filename
388
389 if (!query.HasVersion()) { // neither version and subversion specified -> look for highest version and subVersion
c3a7b59a 390
9e1ceb13 391 while ((filename = gSystem->GetDirEntry(dirPtr))) { // loop on files
c3a7b59a 392
9e1ceb13 393 TString aString(filename);
394 if (aString == "." || aString == "..") continue;
395
396 if (!FilenameToId(filename, aRunRange, aVersion, aSubVersion)) continue;
397 // aRunRange, aVersion, aSubVersion filled from filename
398
399 if (!aRunRange.Comprises(query.GetAliCDBRunRange())) continue;
400 // aRunRange contains requested run!
c3a7b59a 401
2f43a5ff 402 AliDebug(1,Form("Filename %s matches\n",filename));
403
4667c116 404 if (result->GetVersion() < aVersion) {
405 result->SetVersion(aVersion);
406 result->SetSubVersion(aSubVersion);
9e1ceb13 407
4667c116 408 result->SetFirstRun(
9e1ceb13 409 aRunRange.GetFirstRun());
4667c116 410 result->SetLastRun(
9e1ceb13 411 aRunRange.GetLastRun());
412
4667c116 413 } else if (result->GetVersion() == aVersion
414 && result->GetSubVersion()
9e1ceb13 415 < aSubVersion) {
416
4667c116 417 result->SetSubVersion(aSubVersion);
9e1ceb13 418
4667c116 419 result->SetFirstRun(
9e1ceb13 420 aRunRange.GetFirstRun());
4667c116 421 result->SetLastRun(
9e1ceb13 422 aRunRange.GetLastRun());
4667c116 423 } else if (result->GetVersion() == aVersion
424 && result->GetSubVersion() == aSubVersion){
425 AliError(Form("More than one object valid for run %d, version %d_%d!",
9e1ceb13 426 query.GetFirstRun(), aVersion, aSubVersion));
4b5e0dce 427 gSystem->FreeDirectory(dirPtr);
4667c116 428 delete result;
429 return NULL;
9e1ceb13 430 }
431 }
4667c116 432
9e1ceb13 433 } else if (!query.HasSubVersion()) { // version specified but not subversion -> look for highest subVersion
434
4667c116 435 result->SetVersion(query.GetVersion());
9e1ceb13 436
437 while ((filename = gSystem->GetDirEntry(dirPtr))) { // loop on files
438
439 TString aString(filename);
440 if (aString == "." || aString == "..") continue;
441
4667c116 442 if (!FilenameToId(filename, aRunRange, aVersion, aSubVersion)) continue;
9e1ceb13 443 // aRunRange, aVersion, aSubVersion filled from filename
444
445 if (!aRunRange.Comprises(query.GetAliCDBRunRange())) continue;
446 // aRunRange contains requested run!
4667c116 447
9e1ceb13 448 if(query.GetVersion() != aVersion) continue;
449 // aVersion is requested version!
4667c116 450
451 if(result->GetSubVersion() == aSubVersion){
452 AliError(Form("More than one object valid for run %d, version %d_%d!",
9e1ceb13 453 query.GetFirstRun(), aVersion, aSubVersion));
4b5e0dce 454 gSystem->FreeDirectory(dirPtr);
4667c116 455 delete result;
456 return NULL;
9e1ceb13 457 }
4667c116 458 if( result->GetSubVersion() < aSubVersion) {
9e1ceb13 459
4667c116 460 result->SetSubVersion(aSubVersion);
9e1ceb13 461
4667c116 462 result->SetFirstRun(
9e1ceb13 463 aRunRange.GetFirstRun());
4667c116 464 result->SetLastRun(
9e1ceb13 465 aRunRange.GetLastRun());
466 }
467 }
468
469 } else { // both version and subversion specified
470
4667c116 471 //AliCDBId dataId(queryId.GetAliCDBPath(), -1, -1, -1, -1);
472 //Bool_t result;
473 while ((filename = gSystem->GetDirEntry(dirPtr))) { // loop on files
9e1ceb13 474
475 TString aString(filename);
476 if (aString == "." || aString == "..") continue;
477
478 if (!FilenameToId(filename, aRunRange, aVersion, aSubVersion)) continue;
479 // aRunRange, aVersion, aSubVersion filled from filename
4667c116 480
9e1ceb13 481 if (!aRunRange.Comprises(query.GetAliCDBRunRange())) continue;
482 // aRunRange contains requested run!
483
4667c116 484 if(query.GetVersion() != aVersion || query.GetSubVersion() != aSubVersion) continue;
9e1ceb13 485 // aVersion and aSubVersion are requested version and subVersion!
4667c116 486
487 if(result->GetVersion() == aVersion && result->GetSubVersion() == aSubVersion){
488 AliError(Form("More than one object valid for run %d, version %d_%d!",
9e1ceb13 489 query.GetFirstRun(), aVersion, aSubVersion));
4b5e0dce 490 gSystem->FreeDirectory(dirPtr);
4667c116 491 delete result;
492 return NULL;
9e1ceb13 493 }
4667c116 494 result->SetVersion(aVersion);
495 result->SetSubVersion(aSubVersion);
496 result->SetFirstRun(aRunRange.GetFirstRun());
497 result->SetLastRun(aRunRange.GetLastRun());
9e1ceb13 498
499 }
500 }
501
502 gSystem->FreeDirectory(dirPtr);
503
4667c116 504 return result;
9e1ceb13 505}
fe913d8f 506
507//_____________________________________________________________________________
9e1ceb13 508AliCDBEntry* AliCDBLocal::GetEntry(const AliCDBId& queryId) {
509// get AliCDBEntry from the database
510
4667c116 511 AliCDBId* dataId = GetEntryId(queryId);
9e1ceb13 512
4667c116 513 if (!dataId || !dataId->IsSpecified()) return NULL;
9e1ceb13 514
515 TString filename;
4667c116 516 if (!IdToFilename(*dataId, filename)) {
9e1ceb13 517
024cf675 518 AliDebug(2,Form("Bad data ID encountered! Subnormal error!"));
4667c116 519 delete dataId;
520 return NULL;
9e1ceb13 521 }
9e1ceb13 522
523 TFile file(filename, "READ"); // open file
524 if (!file.IsOpen()) {
024cf675 525 AliDebug(2,Form("Can't open file <%s>!", filename.Data()));
4667c116 526 delete dataId;
527 return NULL;
9e1ceb13 528 }
529
530 // get the only AliCDBEntry object from the file
531 // the object in the file is an AliCDBEntry entry named "AliCDBEntry"
4667c116 532
62032124 533 AliCDBEntry* anEntry = dynamic_cast<AliCDBEntry*> (file.Get("AliCDBEntry"));
534 if (!anEntry) {
535 AliDebug(2,Form("Bad storage data: No AliCDBEntry in file!"));
536 file.Close();
4667c116 537 delete dataId;
9e1ceb13 538 return NULL;
539 }
540
4667c116 541 AliCDBId& entryId = anEntry->GetId();
ed343d5e 542
9e1ceb13 543 // The object's Id are not reset during storage
544 // If object's Id runRange or version do not match with filename,
545 // it means that someone renamed file by hand. In this case a warning msg is issued.
62032124 546
547 anEntry-> SetLastStorage("local");
4667c116 548
549 if(!entryId.IsEqual(dataId)){
b8ec52f6 550 AliWarning(Form("Mismatch between file name and object's Id!"));
4667c116 551 AliWarning(Form("File name: %s", dataId->ToString().Data()));
b8ec52f6 552 AliWarning(Form("Object's Id: %s", entryId.ToString().Data()));
9e1ceb13 553 }
b8ec52f6 554
145f45a2 555 // Check whether entry contains a TTree. In case load the tree in memory!
556 LoadTreeFromFile(anEntry);
557
9e1ceb13 558 // close file, return retieved entry
559 file.Close();
4667c116 560 delete dataId;
62032124 561 return anEntry;
9e1ceb13 562}
fe913d8f 563
4667c116 564//_____________________________________________________________________________
565AliCDBId* AliCDBLocal::GetEntryId(const AliCDBId& queryId) {
566// get AliCDBId from the database
567
568 AliCDBId* dataId = 0;
569
570 // look for a filename matching query requests (path, runRange, version, subVersion)
571 if (!queryId.HasVersion()) {
572 // if version is not specified, first check the selection criteria list
573 AliCDBId selectedId(queryId);
574 GetSelection(&selectedId);
575 dataId = GetId(selectedId);
576 } else {
577 dataId = GetId(queryId);
578 }
579
580 if (dataId && !dataId->IsSpecified()) {
581 delete dataId;
582 return NULL;
583 }
584
585 return dataId;
586}
587
9e1ceb13 588//_____________________________________________________________________________
589void AliCDBLocal::GetEntriesForLevel0(const char* level0,
590 const AliCDBId& queryId, TList* result) {
591// multiple request (AliCDBStorage::GetAll)
592
c3a7b59a 593 TString level0Dir = Form("%s/%s", fBaseDirectory.Data(), level0);
594
9e1ceb13 595 void* level0DirPtr = gSystem->OpenDirectory(level0Dir);
596 if (!level0DirPtr) {
c3a7b59a 597 AliDebug(2,Form("Can't open level0 directory <%s>!",
9e1ceb13 598 level0Dir.Data()));
599 return;
c3a7b59a 600 }
9e1ceb13 601
602 const char* level1;
e53c6949 603 Long_t flag=0;
9e1ceb13 604 while ((level1 = gSystem->GetDirEntry(level0DirPtr))) {
605
606 TString level1Str(level1);
607 if (level1Str == "." || level1Str == "..") {
608 continue;
609 }
e53c6949 610
611 TString fullPath = Form("%s/%s",level0Dir.Data(), level1);
9e1ceb13 612
e53c6949 613 Int_t res=gSystem->GetPathInfo(fullPath.Data(), 0, (Long64_t*) 0, &flag, 0);
614
615 if(res){
616 AliDebug(2, Form("Error reading entry %s !",level1Str.Data()));
617 continue;
618 }
619 if(!(flag&2)) continue; // bit 1 of flag = directory!
620
9e1ceb13 621 if (queryId.GetAliCDBPath().Level1Comprises(level1)) {
622 GetEntriesForLevel1(level0, level1, queryId, result);
623 }
624 }
fe913d8f 625
9e1ceb13 626 gSystem->FreeDirectory(level0DirPtr);
fe913d8f 627}
628
9e1ceb13 629//_____________________________________________________________________________
630void AliCDBLocal::GetEntriesForLevel1(const char* level0, const char* level1,
631 const AliCDBId& queryId, TList* result) {
632// multiple request (AliCDBStorage::GetAll)
633
c3a7b59a 634 TString level1Dir = Form("%s/%s/%s", fBaseDirectory.Data(), level0,level1);
9e1ceb13 635
636 void* level1DirPtr = gSystem->OpenDirectory(level1Dir);
637 if (!level1DirPtr) {
c3a7b59a 638 AliDebug(2,Form("Can't open level1 directory <%s>!",
9e1ceb13 639 level1Dir.Data()));
640 return;
641 }
fe913d8f 642
9e1ceb13 643 const char* level2;
e53c6949 644 Long_t flag=0;
9e1ceb13 645 while ((level2 = gSystem->GetDirEntry(level1DirPtr))) {
646
647 TString level2Str(level2);
648 if (level2Str == "." || level2Str == "..") {
649 continue;
650 }
651
e53c6949 652 TString fullPath = Form("%s/%s",level1Dir.Data(), level2);
653
654 Int_t res=gSystem->GetPathInfo(fullPath.Data(), 0, (Long64_t*) 0, &flag, 0);
655
656 if(res){
657 AliDebug(2, Form("Error reading entry %s !",level2Str.Data()));
658 continue;
659 }
660 if(!(flag&2)) continue; // bit 1 of flag = directory!
661
9e1ceb13 662 if (queryId.GetAliCDBPath().Level2Comprises(level2)) {
62032124 663
9e1ceb13 664 AliCDBPath entryPath(level0, level1, level2);
665 AliCDBId entryId(entryPath, queryId.GetAliCDBRunRange(),
666 queryId.GetVersion(), queryId.GetSubVersion());
667
668 AliCDBEntry* anEntry = GetEntry(entryId);
669 if (anEntry) {
670 result->Add(anEntry);
671 }
672 }
673 }
fe913d8f 674
9e1ceb13 675 gSystem->FreeDirectory(level1DirPtr);
676}
fe913d8f 677
9e1ceb13 678//_____________________________________________________________________________
679TList* AliCDBLocal::GetEntries(const AliCDBId& queryId) {
680// multiple request (AliCDBStorage::GetAll)
e53c6949 681
9e1ceb13 682 void* storageDirPtr = gSystem->OpenDirectory(fBaseDirectory);
683 if (!storageDirPtr) {
024cf675 684 AliDebug(2,Form("Can't open storage directory <%s>",
9e1ceb13 685 fBaseDirectory.Data()));
686 return NULL;
c3a7b59a 687 }
9e1ceb13 688
689 TList* result = new TList();
690 result->SetOwner();
691
692 const char* level0;
e53c6949 693 Long_t flag=0;
9e1ceb13 694 while ((level0 = gSystem->GetDirEntry(storageDirPtr))) {
c3a7b59a 695
9e1ceb13 696 TString level0Str(level0);
697 if (level0Str == "." || level0Str == "..") {
698 continue;
699 }
e53c6949 700
701 TString fullPath = Form("%s/%s",fBaseDirectory.Data(), level0);
702
703 Int_t res=gSystem->GetPathInfo(fullPath.Data(), 0, (Long64_t*) 0, &flag, 0);
704
705 if(res){
706 AliDebug(2, Form("Error reading entry %s !",level0Str.Data()));
707 continue;
708 }
709
710 if(!(flag&2)) continue; // bit 1 of flag = directory!
9e1ceb13 711
712 if (queryId.GetAliCDBPath().Level0Comprises(level0)) {
c3a7b59a 713 GetEntriesForLevel0(level0, queryId, result);
9e1ceb13 714 }
c3a7b59a 715 }
716
9e1ceb13 717 gSystem->FreeDirectory(storageDirPtr);
718
719 return result;
fe913d8f 720}
721
722//_____________________________________________________________________________
06eeadea 723Bool_t AliCDBLocal::PutEntry(AliCDBEntry* entry, const char* mirrors) {
9e1ceb13 724// put an AliCDBEntry object into the database
725
726 AliCDBId& id = entry->GetId();
727
728 // set version and subVersion for the entry to be stored
c3a7b59a 729 if (!PrepareId(id)) return kFALSE;
9e1ceb13 730
731
732 // build filename from entry's id
62032124 733 TString filename="";
c3a7b59a 734 if (!IdToFilename(id, filename)) {
9e1ceb13 735
024cf675 736 AliDebug(2,Form("Bad ID encountered! Subnormal error!"));
9e1ceb13 737 return kFALSE;
738 }
c3a7b59a 739
06eeadea 740 TString mirrorsString(mirrors);
741 if(!mirrorsString.IsNull())
3338c05e 742 AliWarning("AliCDBLocal storage cannot take mirror SEs into account. They will be ignored.");
06eeadea 743
9e1ceb13 744 // open file
745 TFile file(filename, "CREATE");
746 if (!file.IsOpen()) {
747 AliError(Form("Can't open file <%s>!", filename.Data()));
748 return kFALSE;
749 }
750
ed343d5e 751 //SetTreeToFile(entry, &file);
145f45a2 752
9e1ceb13 753 entry->SetVersion(id.GetVersion());
754 entry->SetSubVersion(id.GetSubVersion());
0f678e35 755
9e1ceb13 756 // write object (key name: "AliCDBEntry")
757 Bool_t result = file.WriteTObject(entry, "AliCDBEntry");
024cf675 758 if (!result) AliDebug(2,Form("Can't write entry to file: %s", filename.Data()));
9e1ceb13 759
760 file.Close();
0f678e35 761 if(result) {
0f678e35 762 if(!(id.GetPath().Contains("SHUTTLE/STATUS")))
763 AliInfo(Form("CDB object stored into file %s",filename.Data()));
764 }
b05400be 765
766 return result;
767}
768
769//_____________________________________________________________________________
770TList* AliCDBLocal::GetIdListFromFile(const char* fileName){
771
772 TString fullFileName(fileName);
773 fullFileName.Prepend(fBaseDirectory+'/');
774 TFile *file = TFile::Open(fullFileName);
775 if (!file) {
776 AliError(Form("Can't open selection file <%s>!", fullFileName.Data()));
777 return NULL;
778 }
779 file->cd();
780
781 TList *list = new TList();
782 list->SetOwner();
783 int i=0;
784 TString keycycle;
785
786 AliCDBId *id;
787 while(1){
788 i++;
789 keycycle = "AliCDBId;";
790 keycycle+=i;
791
792 id = (AliCDBId*) file->Get(keycycle);
793 if(!id) break;
794 list->AddFirst(id);
795 }
796 file->Close(); delete file; file=0;
797 return list;
798}
799
800//_____________________________________________________________________________
801Bool_t AliCDBLocal::Contains(const char* path) const{
802// check for path in storage's fBaseDirectory
803
c3a7b59a 804 TString dirName = Form("%s/%s", fBaseDirectory.Data(), path);
b05400be 805 Bool_t result=kFALSE;
806
807 void* dirPtr = gSystem->OpenDirectory(dirName);
808 if (dirPtr) result=kTRUE;
809 gSystem->FreeDirectory(dirPtr);
9e1ceb13 810
811 return result;
fe913d8f 812}
813
62032124 814//_____________________________________________________________________________
815void AliCDBLocal::QueryValidFiles()
816{
c3a7b59a 817// Query the CDB for files valid for AliCDBStorage::fRun
818// fills list fValidFileIds with AliCDBId objects created from file name
819
820 if(fVersion != -1) AliWarning ("Version parameter is not used by local storage query!");
821 if(fMetaDataFilter) {
822 AliWarning ("CDB meta data parameters are not used by local storage query!");
823 delete fMetaDataFilter; fMetaDataFilter=0;
824 }
825
826 void* storageDirPtr = gSystem->OpenDirectory(fBaseDirectory);
827
828 const char* level0;
829 while ((level0 = gSystem->GetDirEntry(storageDirPtr))) {
830
831 TString level0Str(level0);
832 if (level0Str == "." || level0Str == "..") {
833 continue;
834 }
835
836 if (fPathFilter.Level0Comprises(level0)) {
837 TString level0Dir = Form("%s/%s",fBaseDirectory.Data(),level0);
838 void* level0DirPtr = gSystem->OpenDirectory(level0Dir);
839 const char* level1;
840 while ((level1 = gSystem->GetDirEntry(level0DirPtr))) {
841
842 TString level1Str(level1);
843 if (level1Str == "." || level1Str == "..") {
844 continue;
845 }
846
847 if (fPathFilter.Level1Comprises(level1)) {
848 TString level1Dir = Form("%s/%s/%s",
849 fBaseDirectory.Data(),level0,level1);
850
851 void* level1DirPtr = gSystem->OpenDirectory(level1Dir);
852 const char* level2;
853 while ((level2 = gSystem->GetDirEntry(level1DirPtr))) {
854
855 TString level2Str(level2);
856 if (level2Str == "." || level2Str == "..") {
857 continue;
858 }
859
860 if (fPathFilter.Level2Comprises(level2)) {
861 TString dirName = Form("%s/%s/%s/%s",
862 fBaseDirectory.Data(),level0,level1,level2);
863
864 void* dirPtr = gSystem->OpenDirectory(dirName);
865
866 const char* filename;
867
868 AliCDBRunRange aRunRange; // the runRange got from filename
869 Int_t aVersion, aSubVersion; // the version and subVersion got from filename
870
871 while ((filename = gSystem->GetDirEntry(dirPtr))) { // loop on files
872
873 TString aString(filename);
874 if (aString == "." || aString == "..") continue;
875
876 if (!FilenameToId(filename, aRunRange, aVersion, aSubVersion)) continue;
877 AliCDBRunRange runrg(fRun,fRun);
878 if (!aRunRange.Comprises(runrg)) continue;
879 // aRunRange contains requested run!
880 AliCDBPath validPath(level0,level1,level2);
881 AliCDBId validId(validPath,aRunRange,aVersion,aSubVersion);
882 fValidFileIds.AddLast(validId.Clone());
883 }
884 gSystem->FreeDirectory(dirPtr);
885 }
886 }
887 gSystem->FreeDirectory(level1DirPtr);
888 }
889 }
890 gSystem->FreeDirectory(level0DirPtr);
891 }
892 }
893 gSystem->FreeDirectory(storageDirPtr);
894
895}
896
897//_____________________________________________________________________________
898Int_t AliCDBLocal::GetLatestVersion(const char* path, Int_t run){
899// get last version found in the database valid for run and path
900
901 AliCDBPath aCDBPath(path);
902 if(!aCDBPath.IsValid() || aCDBPath.IsWildcard()) {
903 AliError(Form("Invalid path in request: %s", path));
904 return -1;
905 }
906
907 AliCDBId query(path, run, run, -1, -1);
4667c116 908 AliCDBId* dataId = GetId(query);
909
910 if(!dataId) return -1;
c3a7b59a 911
4667c116 912 Int_t version = dataId->GetVersion();
913 delete dataId;
c3a7b59a 914
4667c116 915 return version;
c3a7b59a 916
917}
918
919//_____________________________________________________________________________
920Int_t AliCDBLocal::GetLatestSubVersion(const char* path, Int_t run, Int_t version){
921// get last version found in the database valid for run and path
922
923 AliCDBPath aCDBPath(path);
924 if(!aCDBPath.IsValid() || aCDBPath.IsWildcard()) {
925 AliError(Form("Invalid path in request: %s", path));
926 return -1;
927 }
928
929 AliCDBId query(path, run, run, version, -1);
4667c116 930 AliCDBId *dataId = GetId(query);
931
932 if(!dataId) return -1;
c3a7b59a 933
4667c116 934 Int_t subVersion = dataId->GetSubVersion();
c3a7b59a 935
4667c116 936 delete dataId;
937 return subVersion;
62032124 938
939}
940
9e1ceb13 941/////////////////////////////////////////////////////////////////////////////////////////////////
942// //
943// AliCDBLocal factory //
944// //
945/////////////////////////////////////////////////////////////////////////////////////////////////
946
947ClassImp(AliCDBLocalFactory)
948
949//_____________________________________________________________________________
950Bool_t AliCDBLocalFactory::Validate(const char* dbString) {
951// check if the string is valid local URI
952
647d2bb8 953 TRegexp dbPatternLocal("^local://.+$");
9e1ceb13 954
647d2bb8 955 return (TString(dbString).Contains(dbPatternLocal) || TString(dbString).BeginsWith("snapshot://folder="));
fe913d8f 956}
957
9e1ceb13 958//_____________________________________________________________________________
959AliCDBParam* AliCDBLocalFactory::CreateParameter(const char* dbString) {
960// create AliCDBLocalParam class from the URI string
961
962 if (!Validate(dbString)) {
963 return NULL;
964 }
965
647d2bb8 966 TString checkSS(dbString);
967 if(checkSS.BeginsWith("snapshot://"))
968 {
969 TString snapshotPath("OCDB");
970 snapshotPath.Prepend(TString(gSystem->WorkingDirectory()) + '/');
971 checkSS.Remove(0,checkSS.First(':')+3);
972 return new AliCDBLocalParam(snapshotPath,checkSS);
973 }
974
975 // if the string argument is not a snapshot URI, than it is a plain local URI
9e1ceb13 976 TString pathname(dbString + sizeof("local://") - 1);
977
647d2bb8 978 if(gSystem->ExpandPathName(pathname))
979 return NULL;
9e1ceb13 980
981 if (pathname[0] != '/') {
982 pathname.Prepend(TString(gSystem->WorkingDirectory()) + '/');
983 }
647d2bb8 984 //pathname.Prepend("local://");
9e1ceb13 985
4667c116 986 return new AliCDBLocalParam(pathname);
fe913d8f 987}
988
9e1ceb13 989//_____________________________________________________________________________
990AliCDBStorage* AliCDBLocalFactory::Create(const AliCDBParam* param) {
991// create AliCDBLocal storage instance from parameters
992
993 if (AliCDBLocalParam::Class() == param->IsA()) {
994
995 const AliCDBLocalParam* localParam =
996 (const AliCDBLocalParam*) param;
997
998 return new AliCDBLocal(localParam->GetPath());
999 }
fe913d8f 1000
9e1ceb13 1001 return NULL;
fe913d8f 1002}
89004e35 1003//_____________________________________________________________________________
0d3fff93 1004void AliCDBLocal::SetRetry(Int_t /* nretry */, Int_t /* initsec */) {
89004e35 1005
1006 // Function to set the exponential retry for putting entries in the OCDB
1007
1008 AliInfo("This function sets the exponential retry for putting entries in the OCDB - to be used ONLY for AliCDBGrid --> returning without doing anything");
1009 return;
1010}
1011
1012
fe913d8f 1013
9e1ceb13 1014/////////////////////////////////////////////////////////////////////////////////////////////////
1015// //
1016// AliCDBLocal Parameter class // //
1017// //
1018/////////////////////////////////////////////////////////////////////////////////////////////////
1019
1020ClassImp(AliCDBLocalParam)
1021
fe913d8f 1022//_____________________________________________________________________________
62032124 1023AliCDBLocalParam::AliCDBLocalParam():
1024 AliCDBParam(),
1025 fDBPath()
1026 {
9e1ceb13 1027// default constructor
fe913d8f 1028
fe913d8f 1029}
1030
9e1ceb13 1031//_____________________________________________________________________________
1032AliCDBLocalParam::AliCDBLocalParam(const char* dbPath):
62032124 1033 AliCDBParam(),
1034 fDBPath(dbPath)
1035{
9e1ceb13 1036// constructor
1037
1038 SetType("local");
1039 SetURI(TString("local://") + dbPath);
1040}
1041
647d2bb8 1042//_____________________________________________________________________________
1043AliCDBLocalParam::AliCDBLocalParam(const char* dbPath, const char* uri):
1044 AliCDBParam(),
1045 fDBPath(dbPath)
1046{
1047// constructor
1048
1049 SetType("local");
1050 SetURI(TString("alien://") + uri);
1051}
1052
9e1ceb13 1053//_____________________________________________________________________________
1054AliCDBLocalParam::~AliCDBLocalParam() {
1055// destructor
1056
1057}
fe913d8f 1058
1059//_____________________________________________________________________________
9e1ceb13 1060AliCDBParam* AliCDBLocalParam::CloneParam() const {
1061// clone parameter
1062
1063 return new AliCDBLocalParam(fDBPath);
fe913d8f 1064}
fe913d8f 1065
9e1ceb13 1066//_____________________________________________________________________________
1067ULong_t AliCDBLocalParam::Hash() const {
1068// return Hash function
1069
1070 return fDBPath.Hash();
fe913d8f 1071}
9e1ceb13 1072
1073//_____________________________________________________________________________
1074Bool_t AliCDBLocalParam::IsEqual(const TObject* obj) const {
1075// check if this object is equal to AliCDBParam obj
1076
1077 if (this == obj) {
1078 return kTRUE;
1079 }
1080
1081 if (AliCDBLocalParam::Class() != obj->IsA()) {
1082 return kFALSE;
1083 }
1084
1085 AliCDBLocalParam* other = (AliCDBLocalParam*) obj;
1086
1087 return fDBPath == other->fDBPath;
1088}
1089