EdbDataSet Class Reference

#include <EdbDataSet.h>

Inheritance diagram for EdbDataSet:

Collaboration diagram for EdbDataSet:

Public Member Functions
	EdbDataSet ()
	============================================================================== More...
	EdbDataSet (const char *file)
EdbDataPiece *	FindPiece (const char *name)
const char *	GetAnaDir () const
const char *	GetParDir () const
EdbDataPiece *	GetPiece (int id)
int	GetRunList (const char *file)
int	N () const
void	Print ()
void	PrintRunList ()
int	ReadDataSetDef (const char *file)
void	Set0 ()
void	WriteRunList ()
virtual	~EdbDataSet ()

Private Attributes
TString	eAnaDir
TFile *	eDBFile
TString	eDBFileName
TString	eInputList
TString	eParDir
TObjArray	ePieces

Constructor & Destructor Documentation

EdbDataSet() [1/2]

EdbDataSet::EdbDataSet

(

)

==============================================================================

{
  Set0();
}

EdbDataSet() [2/2]

EdbDataSet::EdbDataSet

(

const char *

file

)

---

{
  Set0();
  if(ReadDataSetDef(file)<0);
  Set0();
}

~EdbDataSet()

EdbDataSet::~EdbDataSet ( )

virtual

---

{
  if(ePieces.GetEntries()) ePieces.Delete();
}

Member Function Documentation

FindPiece()

EdbDataPiece * EdbDataSet::FindPiece

(

const char *

name

)

---

{
  const char *nn;
  EdbDataPiece *piece=0;
  for(int i=0; i<ePieces.GetEntriesFast(); i++){
    piece = (EdbDataPiece*)ePieces.At(i);
    nn = piece->GetName();
    if(!strcmp(nn,name)) return piece;
  }
  return 0;
}

GetAnaDir()

const char* EdbDataSet::GetAnaDir ( ) const

inline

{return eAnaDir.Data();}

GetParDir()

const char* EdbDataSet::GetParDir ( ) const

inline

{return eParDir.Data();}

GetPiece()

EdbDataPiece* EdbDataSet::GetPiece ( int  id )

inline

    { if(id<ePieces.GetEntriesFast()) return (EdbDataPiece *)ePieces.At(id); else return 0;}

GetRunList()

int EdbDataSet::GetRunList

(

const char *

file

)

---

{
  char            buf[256];
  char            filename[256];
  int             nrun=0;
 
  FILE *fp=fopen(file,"r");
  if (!fp)   {
    Log(1,"EdbDataSet::GetRunList","ERROR open file: %s", file);
    return(-1);
  }
  else Log(2,"EdbDataSet::GetRunList", "Read runs list from file: %s", file );
 
  EdbDataPiece *piece=0;
  EdbDataPiece *pp=0;
  int plateID,pieceID,flag;
 
  int ntok=0;
  while( fgets(buf,256,fp)!=NULL ) {
    ntok = sscanf(buf,"%d %d %s %d",&plateID,&pieceID,filename,&flag);
    if(ntok!=4) break;
    if(flag<=0) continue;
    nrun++;
    piece = new EdbDataPiece(plateID,pieceID,filename,flag);
    piece->MakeName();
    if( (pp=FindPiece(piece->GetName())) ) {
      pp->AddRunFile( filename );
      delete piece;
    } else {
      piece->MakeNameCP(GetAnaDir());
      piece->MakeNamePar(GetParDir());
      if(piece->TakePiecePar()>=0)
    ePieces.Add(piece);
      else {
    Log(1,"EdbDataSet::GetRunList","Missing par file for piece!!!");
    if(fp) fclose(fp);
    return -1;
      }
    }
  }
  fclose(fp);
 
  return nrun;
}

N()

int EdbDataSet::N ( ) const

inline

{ return ePieces.GetEntriesFast(); }

Print()

void EdbDataSet::Print

(

)

---

{
  EdbDataPiece *p=0;
  printf("EdbDataSet with %d pieces:",N());
  for(int i=0; i<N(); i++){
    p = ((EdbDataPiece*)ePieces.At(i));
    printf("%s %s\n",p->GetName(), p->GetRunFile(0));
  }
}

PrintRunList()

void EdbDataSet::PrintRunList

(

)

---

{
  for(int i=0; i<ePieces.GetEntriesFast(); i++){
    ((EdbDataPiece*)ePieces.At(i))->Print();
  }
}

ReadDataSetDef()

int EdbDataSet::ReadDataSetDef

(

const char *

file

)

---

{
  char            buf[256];
  char            key[256];
  char            name[256];
 
  FILE *fp=fopen(file,"r");
  if (fp==NULL)   {
    Log(1,"EdbDataSet::ReadDataSetDef","ERROR open file: %s", file);
    return(-1);
  }else
    Log(2,"EdbDataSet::ReadDataSetDef", "Read Data Set Definitions from: %s", file );
 
  while( fgets(buf,256,fp)!=NULL ) {
    for( int i=0; i<(int)strlen(buf); i++ ) 
      if( buf[i]=='#' )  {
    buf[i]='\0';                       // cut out comments starting from #
    break;
      }
 
   if( sscanf(buf,"%s",key)!=1 )                             continue;
 
   if      ( !strcmp(key,"OUTPUT_DATA_DIR")   )
      {
    sscanf(buf+strlen(key),"%s",name);
    eAnaDir = name;
      }
   else if ( !strcmp(key,"INPUT_RUNS_LIST")   )
      {
    sscanf(buf+strlen(key),"%s",name);
    eInputList=name;
      }
   else if ( !strcmp(key,"PARAMETERS_DIR")   )
      {
    sscanf(buf+strlen(key),"%s",name);
    eParDir=name;
      }
   else if ( !strcmp(key,"DBFILNAME")   )
      {
    sscanf(buf+strlen(key),"%s",name);
    eDBFileName=name;
      }
  }
  fclose(fp);
  return GetRunList(eInputList.Data());
}

Set0()

void EdbDataSet::Set0

(

)

---

{
  eInputList  = "runs.lst";
  eAnaDir     = "./";
  eParDir     = "./";
  eDBFileName = "pieces_DB.root";
  eDBFile     = 0;
  ePieces.SetOwner();
}

WriteRunList()

void EdbDataSet::WriteRunList

(

)

---

{
  if(!eDBFile) eDBFile = new TFile(eDBFileName.Data(),"UPDATE");
  //else eDBFile->Cd();
 
  for(int i=0; i<ePieces.GetEntriesFast(); i++){
    ((EdbDataPiece*)ePieces.At(i))->MakeName();
  }
 
  ePieces.Write("pieces",1);
}

Member Data Documentation

eAnaDir

TString EdbDataSet::eAnaDir

private

eDBFile

TFile* EdbDataSet::eDBFile

private

eDBFileName

TString EdbDataSet::eDBFileName

private

eInputList

TString EdbDataSet::eInputList

private

eParDir

TString EdbDataSet::eParDir

private

ePieces

TObjArray EdbDataSet::ePieces

private

---

The documentation for this class was generated from the following files:

• src/libEIO/EdbDataSet.h
• src/libEIO/EdbDataSet.cxx