Function GetFromOCDB added to AliShuttle and AliTestShuttle.

[u/mrichter/AliRoot.git] / SHUTTLE / TestShuttle / AliTestPreprocessor.cxx

#include "AliTestPreprocessor.h"

#include "AliCDBMetaData.h"
#include "AliCDBEntry.h"
#include "AliDCSValue.h"
#include "AliLog.h"
#include "AliTestDataDCS.h"

#include <TTimeStamp.h>
#include <TObjString.h>

//
// This class is an example for a simple preprocessor.
// It takes data from DCS and passes it to the class AliTestDataDCS, which
// reformats its. This class is then written to the CDB.
//

ClassImp(AliTestPreprocessor)

//______________________________________________________________________________________________
AliTestPreprocessor::AliTestPreprocessor(AliShuttleInterface* shuttle) :
  AliPreprocessor("TPC", shuttle),
  fData(0)
{
  // constructor
}

//______________________________________________________________________________________________
AliTestPreprocessor::~AliTestPreprocessor()
{
  // destructor
}

//______________________________________________________________________________________________
void AliTestPreprocessor::Initialize(Int_t run, UInt_t startTime,
	UInt_t endTime)
{
  // Creates AliTestDataDCS object

  AliPreprocessor::Initialize(run, startTime, endTime);

	AliInfo(Form("\n\tRun %d \n\tStartTime %s \n\tEndTime %s", run,
		TTimeStamp(startTime).AsString(),
		TTimeStamp(endTime).AsString()));

	fData = new AliTestDataDCS(fRun, fStartTime, fEndTime);
}

//______________________________________________________________________________________________
UInt_t AliTestPreprocessor::Process(TMap* dcsAliasMap)
{
  // Fills data into a AliTestDataDCS object

  if (!dcsAliasMap)
    return 0;

  // The processing of the DCS input data is forwarded to AliTestDataDCS
	fData->ProcessData(*dcsAliasMap);

  const char* fileName = GetFile(kDAQ, "PEDESTALS", "GDC");
  if (fileName)
    AliInfo(Form("Got the file %s, now we can extract some values.", fileName));
  //TODO here the file could be opened, some values extracted and  written to e.g. fData

  TList* list = GetFileSources(kDAQ, "DRIFTVELOCITY");
  if (list)
  {
    AliInfo("The following sources produced files with the id DRIFTVELOCITY");
    list->Print();
    delete list;
  }
  //TODO here the files could be opened, some values extracted and  written to e.g. fData

  // Example of how to retrieve a run parameter using GetRunParameter function
  // TODO Here the parameter must be set manually with SetInputRunParameter function,
  // in reality it will be read from the run logbook!

  // note that the parameters are returned as character strings!
  const char* nEvents = GetRunParameter("totalEvents");
  if (nEvents) {
  	Log(Form("Number of events for run %d: %s",fRun, nEvents));
  } else {
	Log(Form("Number of events not put in logbook!"));
  }

  // Example of how to retrieve a condition object from OCDB

  AliCDBEntry *entry = GetFromOCDB("Calib", "Data");
  if (!entry)
  {
	Log("No object found in OCDB!");
  } else {
	TObjString *obj = dynamic_cast<TObjString*> (entry->GetObject());
	Log(Form("Got TPC/Calib/Data object from OCDB. The object says: %s",obj->GetName()));
  }


  //Now we have to store the final CDB file
  AliCDBMetaData metaData;
	metaData.SetBeamPeriod(0);
	metaData.SetResponsible("Alberto Colla");
	metaData.SetComment("This preprocessor fills an AliTestDataDCS object.");

	UInt_t result = Store("SHUTTLE", "Data", fData, &metaData, 0, 0);
	delete fData;
	fData = 0;

  return result;
}