QFileReader.cc

Go to the documentation of this file.

#include "QFileReader.hh"
#include "QFileList.hh"
#include "QGlobalReaderDispatcher.hh"
#include <fstream>
 
Q_BEGIN_NAMESPACE
 
QFileReader::QFileReader() : QReader()
{
}
 
QFileReader::~QFileReader()
{
}
 
void QFileReader::Init(QEventAssembler& evi)
{
    fFileNumber = 0;
    fFileEventNumber = 0;
    fFileList.clear();
    fFullPathFilesList.clear();
 
    fReadFileList = false;
    std::string inFile = GetString("InputFile","NODEFAULT");
    std::string fileExtension = "";
    size_t dotpos =  inFile.find_last_of(".");
    if(dotpos != std::string::npos)
        fileExtension = inFile.substr( dotpos+1 );
    if(fileExtension == "list") fReadFileList = true;
 
    if(GetIteration() == 1)   fRWCommon->fTempOutputFileList= "";
    if(GetIteration() == 1 && fReadFileList)  {
        fFileListPath = inFile;
        fRWCommon->fTempOutputFileList=fFileListPath;
    }
    if( fRWCommon->fTempOutputFileList == "") {
        // Open single file
        fFileList.push_back(inFile);
        Debug("InputFileName is %s", inFile.c_str());
    } else {
        // open file list
        std::string listPath = fRWCommon->fTempOutputFileList;
        fFileList = QFileList::Read(listPath,"FULLPATH");
        Debug("FileList is %s",listPath.c_str());
    }
 
    if(fFileList.empty()) { Panic("No files given"); }
 
    fFileListIter = fFileList.begin();
 
    fFullPathFilesList.clear();
    fRWCommon->fReaderFileNumber = 0;
 
    Add(*fFileListIter,evi);
}
 
bool QFileReader::Do(QEventAssembler& eva)
{
        bool ret = true;
        if(fFileEventNumber == 0 || Fill(eva) == false) {
 
                if(fFileListIter != fFileList.begin()) Close();
 
                if(fFileListIter != fFileList.end()) {
                        fFileEventNumber = 0;
                        Open(*fFileListIter,eva);
                        OpenNewFile(*fFileListIter);
                        Info("Current input is %s", fFileListIter->c_str());
            fFileListIter++;
            ret = Fill(eva);
        } else {
            ret = false;
        }
        
   }
   fFileEventNumber++;
 
   return ret;
}
 
void QFileReader::Done()
{
}
 
const QError& QFileReader::JumpToEvent(Long64_t event) 
{
    fErr=QERR_NOT_IMPLEMENTED;
    std::string errDescr;
    errDescr = "JumpToEvent is not implemented with reader " + GetName();
    fErr.SetDescription(errDescr);
    return fErr;
}
 
Q_END_NAMESPACE