+//______________________________________________________________________________________________
+
+
+UInt_t AliTPCPreprocessor::ExtractAltro(Int_t sourceFXS, TMap* dcsMap)
+{
+ //
+ // Read Altro configuration file from file exchage server
+ // Keep original entry from OCDB in case no new pulser calibration is available
+ //
+ TObjArray *altroObjects=0;
+ AliTPCCalPad *acqStart=0;
+ AliTPCCalPad *zsThr=0;
+ AliTPCCalPad *acqStop=0;
+ AliTPCCalPad *FPED=0;
+ AliTPCCalPad *masked=0;
+ AliTPCCalPad *k1=0, *k2=0, *k3=0;
+ AliTPCCalPad *l1=0, *l2=0, *l3=0;
+ TMap *mapRCUconfig=0;
+
+ AliCDBEntry* entry = GetFromOCDB("Calib", "AltroConfig");
+ if (entry) altroObjects = (TObjArray*)entry->GetObject();
+ if ( altroObjects==NULL ) {
+ Log("AliTPCPreprocsessor: No previous TPC altro calibration entry available.\n");
+ altroObjects = new TObjArray;
+ }
+
+ acqStart = (AliTPCCalPad*)altroObjects->FindObject("AcqStart");
+ if ( !acqStart ) {
+ acqStart = new AliTPCCalPad("AcqStart","AcqStart");
+ altroObjects->Add(acqStart);
+ }
+ zsThr = (AliTPCCalPad*)altroObjects->FindObject("ZsThr");
+ if ( !zsThr ) {
+ zsThr = new AliTPCCalPad("ZsThr","ZsThr");
+ altroObjects->Add(zsThr);
+ }
+ FPED = (AliTPCCalPad*)altroObjects->FindObject("FPED");
+ if ( !FPED ) {
+ FPED = new AliTPCCalPad("FPED","FPED");
+ altroObjects->Add(FPED);
+ }
+ acqStop = (AliTPCCalPad*)altroObjects->FindObject("AcqStop");
+ if ( !acqStop ) {
+ acqStop = new AliTPCCalPad("AcqStop","AcqStop");
+ altroObjects->Add(acqStop);
+ }
+ masked = (AliTPCCalPad*)altroObjects->FindObject("Masked");
+ if ( !masked ) {
+ masked = new AliTPCCalPad("Masked","Masked");
+ altroObjects->Add(masked);
+ }
+ k1 = (AliTPCCalPad*)altroObjects->FindObject("K1");
+ if ( !k1 ) {
+ k1 = new AliTPCCalPad("K1","K1");
+ altroObjects->Add(k1);
+ }
+ k2 = (AliTPCCalPad*)altroObjects->FindObject("K2");
+ if ( !k2 ) {
+ k2 = new AliTPCCalPad("K2","K2");
+ altroObjects->Add(k2);
+ }
+ k3 = (AliTPCCalPad*)altroObjects->FindObject("K3");
+ if ( !k3 ) {
+ k3 = new AliTPCCalPad("K3","K3");
+ altroObjects->Add(k3);
+ }
+ l1 = (AliTPCCalPad*)altroObjects->FindObject("L1");
+ if ( !l1 ) {
+ l1 = new AliTPCCalPad("L1","L1");
+ altroObjects->Add(l1);
+ }
+ l2 = (AliTPCCalPad*)altroObjects->FindObject("L2");
+ if ( !l2 ) {
+ l2 = new AliTPCCalPad("L2","L2");
+ altroObjects->Add(l2);
+ }
+ l3 = (AliTPCCalPad*)altroObjects->FindObject("L3");
+ if ( !l3 ) {
+ l3 = new AliTPCCalPad("L3","L3");
+ altroObjects->Add(l3);
+ }
+ mapRCUconfig = (TMap*)altroObjects->FindObject("RCUconfig");
+ if (!mapRCUconfig) {
+ mapRCUconfig = new TMap();
+ mapRCUconfig->SetName("RCUconfig");
+ altroObjects->Add(mapRCUconfig);
+ }
+
+
+ UInt_t result=0;
+ TString idFXS[2]={"AltroConfigA","AltroConfigC"};
+
+ Int_t nSectors = fROC->GetNSectors();
+ Bool_t changed=false;
+ if (altroObjects == 0 ) altroObjects = new TObjArray;
+
+// extract list of active DDLs
+
+ if (dcsMap) {
+ Bool_t found;
+ TString arrDDL(kNumDDL);
+ arrDDL.Append('x',kNumDDL);
+ for ( Int_t iDDL = 0; iDDL<kNumDDL; iDDL++ ) {
+ TString stringID = Form (kAmandaDDL.Data(),iDDL+kFirstDDL);
+ TPair *pair = (TPair*)dcsMap->FindObject(stringID.Data());
+ found = false;
+ if ( pair ) {
+ TObjArray *valueSet=(TObjArray*)pair->Value();
+ if ( valueSet) {
+ AliDCSValue *val = (AliDCSValue*)valueSet->At(0);
+ if (val) {
+ found = val->GetBool();
+ if (found){
+ arrDDL[iDDL] = '1';
+ } else {
+ arrDDL[iDDL] = '0';
+ }
+ }
+ }
+ }
+ }
+ TObjString *ddlArray = new TObjString;
+ ddlArray->SetString(arrDDL);
+ TMap *activeDDL = new TMap;
+ activeDDL->SetName("DDLArray");
+ TObjString *key = new TObjString("DDLArray");
+ activeDDL->Add(key,ddlArray);
+ altroObjects->Add(activeDDL);
+ changed=true;
+ } else {
+ Log ("ExtractAltro: No DCS map available. Active DDL list cannot be obtained.");
+ result = 3;
+ }
+
+// extract Altro configuration files
+
+ for ( Int_t id=0; id<2; id++) {
+ TList* list = GetFileSources(sourceFXS,idFXS[id].Data());
+
+ if (list && list->GetEntries()>0) {
+
+// loop through all files from LDCs
+
+ UInt_t index = 0;
+ while (list->At(index)!=NULL) {
+ TObjString* fileNameEntry = (TObjString*) list->At(index);
+ if (fileNameEntry!=NULL) {
+ TString fileName = GetFile(sourceFXS, idFXS[id].Data(),
+ fileNameEntry->GetString().Data());
+ TFile *f = TFile::Open(fileName);
+ if (!f) {
+ const int mess_length=40;
+ char message[mess_length];
+ snprintf(message,mess_length,"Error opening Altro configuration file, id = %d",id);
+ Log (message);
+ result =2;
+ break;
+ }
+ TObjArray *altroFXS;
+ f->GetObject("AltroConfig",altroFXS);
+ if ( !altroFXS ) {
+ Log ("No Altro configuration object in file.");
+ result = 2;
+ break;
+ }
+
+ // replace entries for the sectors available in the present file
+ AliTPCCalPad *acqStartFXS=(AliTPCCalPad*)altroFXS->FindObject("AcqStart");
+ AliTPCCalPad *zsThrFXS=(AliTPCCalPad*)altroFXS->FindObject("ZsThr");
+ AliTPCCalPad *acqStopFXS=(AliTPCCalPad*)altroFXS->FindObject("AcqStop");
+ AliTPCCalPad *FPEDFXS=(AliTPCCalPad*)altroFXS->FindObject("FPED");
+ AliTPCCalPad *maskedFXS=(AliTPCCalPad*)altroFXS->FindObject("Masked");
+ AliTPCCalPad *k1FXS=(AliTPCCalPad*)altroFXS->FindObject("K1");
+ AliTPCCalPad *k2FXS=(AliTPCCalPad*)altroFXS->FindObject("K2");
+ AliTPCCalPad *k3FXS=(AliTPCCalPad*)altroFXS->FindObject("K3");
+ AliTPCCalPad *l1FXS=(AliTPCCalPad*)altroFXS->FindObject("L1");
+ AliTPCCalPad *l2FXS=(AliTPCCalPad*)altroFXS->FindObject("L2");
+ AliTPCCalPad *l3FXS=(AliTPCCalPad*)altroFXS->FindObject("L3");
+ TMap *mapRCUconfigFXS = (TMap*)altroFXS->FindObject("RCUconfig");
+ TIterator *mapFXSiter = mapRCUconfigFXS->MakeIterator();
+
+ changed=true;
+ for (Int_t sector=0; sector<nSectors; sector++) {
+
+ if (acqStartFXS) {
+ AliTPCCalROC *rocAcqStart=acqStartFXS->GetCalROC(sector);
+ if ( rocAcqStart ) acqStart->SetCalROC(rocAcqStart,sector);
+ }
+ if (zsThrFXS ) {
+ AliTPCCalROC *rocZsThr=zsThrFXS->GetCalROC(sector);
+ if ( rocZsThr ) zsThr->SetCalROC(rocZsThr,sector);
+ }
+ if (acqStopFXS) {
+ AliTPCCalROC *rocAcqStop=acqStopFXS->GetCalROC(sector);
+ if ( rocAcqStop ) acqStop->SetCalROC(rocAcqStop,sector);
+ }
+ if (FPEDFXS ) {
+ AliTPCCalROC *rocFPED=FPEDFXS->GetCalROC(sector);
+ if ( rocFPED ) FPED->SetCalROC(rocFPED,sector);
+ }
+ if (maskedFXS) {
+ AliTPCCalROC *rocMasked=maskedFXS->GetCalROC(sector);
+ if ( rocMasked ) masked->SetCalROC(rocMasked,sector);
+ }
+ if (k1FXS) {
+ AliTPCCalROC *rocK1=k1FXS->GetCalROC(sector);
+ if ( rocK1 ) k1->SetCalROC(rocK1,sector);
+ }
+ if (k2FXS) {
+ AliTPCCalROC *rocK2=k2FXS->GetCalROC(sector);
+ if ( rocK2 ) k2->SetCalROC(rocK2,sector);
+ }
+ if (k3FXS) {
+ AliTPCCalROC *rocK3=k3FXS->GetCalROC(sector);
+ if ( rocK3 ) k3->SetCalROC(rocK3,sector);
+ }
+ if (l1FXS) {
+ AliTPCCalROC *rocL1=l1FXS->GetCalROC(sector);
+ if ( rocL1 ) l1->SetCalROC(rocL1,sector);
+ }
+ if (l2FXS) {
+ AliTPCCalROC *rocL2=l2FXS->GetCalROC(sector);
+ if ( rocL2 ) l2->SetCalROC(rocL2,sector);
+ }
+ if (l3FXS) {
+ AliTPCCalROC *rocL3=l3FXS->GetCalROC(sector);
+ if ( rocL3 ) l3->SetCalROC(rocL3,sector);
+ }
+ }
+ if (mapRCUconfigFXS) {
+ Int_t mapEntries = mapRCUconfigFXS->GetEntries();
+ TObjString* keyFXS;
+ TVectorF* vecFXS;
+ TVectorF* vec; // nSectors = 72 (total number of inner/outer sectors)
+ for (Int_t i=0; i<mapEntries; ++i) {
+ keyFXS=(TObjString*)mapFXSiter->Next();
+ vecFXS=(TVectorF*)mapRCUconfigFXS->GetValue(keyFXS);
+ vec=(TVectorF*)mapRCUconfig->GetValue(keyFXS);
+ if (!vec) {
+ vec = new TVectorF(3*nSectors);
+ *vec = -1;
+ mapRCUconfig->Add(keyFXS,vec);
+ }
+ if (vec->GetNoElements() != 3*nSectors ) {
+ vec->ResizeTo(3*nSectors);
+ }
+ if (id==0) { // A side
+ vec->SetSub(0,vecFXS->GetSub(0,nSectors/2-1));
+ vec->SetSub(nSectors,vecFXS->GetSub(nSectors,2*nSectors-1));
+ } else { // C side
+ vec->SetSub(nSectors/2,vecFXS->GetSub(nSectors/2,nSectors-1));
+ vec->SetSub(2*nSectors,vecFXS->GetSub(2*nSectors,3*nSectors-1));
+ }
+ }
+ }
+ delete altroFXS;
+ f->Close();
+ }
+ ++index;
+ } // while(list)
+ } else {
+ Log ("Error: no entries in AltroConfig file list!");
+ result = 1;
+ }
+
+ } // for - id
+//
+// Store updated pedestal entry to OCDB
+//
+ if (changed) {
+ AliCDBMetaData metaData;
+ metaData.SetBeamPeriod(0);
+ metaData.SetResponsible("Haavard Helstrup");
+ metaData.SetAliRootVersion(ALIROOT_SVN_BRANCH);
+ metaData.SetComment("Preprocessor AliTPC data base entries.");
+
+ Bool_t storeOK = Store("Calib", "AltroConfig", altroObjects, &metaData, 0, kFALSE);
+ if ( !storeOK ) ++result;
+ }
+
+ altroObjects->Delete();
+ delete altroObjects;
+
+ return result;
+}