QGlobalReaderDispatcher.cc

Go to the documentation of this file.

#include "QGlobalReaderDispatcher.hh"
#include "QGlobalRWFactory.hh"
#include "QGlobalReader.hh"
#include "QMessage.hh"
#include "QError.hh"
 
using namespace Diana;
 
QGlobalReaderDispatcher& QGlobalReaderDispatcher::GetInstance()
{
    static QGlobalReaderDispatcher dispatcher;
    return dispatcher;
}
 
 
QGlobalReaderDispatcher::QGlobalReaderDispatcher() : QNamed("QGlobalReaderDispatcher")
{
    fLastReader = NULL;
    fCurrentReaderFilename = "";
}
 
QGlobalReader* QGlobalReaderDispatcher::GetReader(const std::string& filename, QError& err)
{
    err = QERR_SUCCESS;
    err.SetDescription("");
    std::string fname = filename;
    // check for already open files
    bool isReader = false;
    if(fname.find(Q_CURRENT_READER,0) != std::string::npos) {
        if(!fCurrentReaderFilename.empty())
            fname = fCurrentReaderFilename;
        else {
            err = QERR_CANNOT_OPEN_FILE;
            err.SetDescription("No files being read by the reader in this sequence");
        }
        isReader = true;
    }
 
    /* deprecated 
    if(fname == "same") {
        if(!fLastReader) QMessageHandler::Error(GetName(), std::string("Cannot read from the \"same\" file, as none has been previously well defined!"));
        return fLastReader;
    } else */
    if(fReaders.find(fname) != fReaders.end()) {
        fLastReader = fReaders[fname];
        return fLastReader;
    }
 
    // Create the GlobalReader for fname checking its extension
    fLastReader = NULL;
    size_t dotpos =  fname.find_last_of(".");
    std::string fileExtension = "";
    if(dotpos != std::string::npos)
        fileExtension = fname.substr( dotpos );
 
    std::list<const QGlobalReaderFactory*> readerFactories = QGlobalRWFactory::GetInstance().GetListOfGlobalReaders();
    std::list<const QGlobalReaderFactory*>::iterator iter;
    for(iter = readerFactories.begin(); iter!= readerFactories.end(); iter++)
       if((*iter)->GetExt() == fileExtension) 
        fLastReader = QGlobalRWFactory::GetInstance().CreateGlobalReader((*iter)->GetName());
    // defaults
    if(fLastReader == 0) {
        if(fileExtension == ".root") {
            QGlobalRWFactory::GetInstance().LoadPlugin("LRootGlobalReader");
            QMessageHandler::Info(GetName(), std::string("loaded default g-reader LRootGlobalReader"));
        }
        else if(fileExtension == ".txt") {
            QGlobalRWFactory::GetInstance().LoadPlugin("LASCIIGlobalReader");
            QMessageHandler::Info(GetName(), std::string("loaded default g-reader LASCIIGlobalReader"));
        }
        else if(fileExtension == ".hdr") {
            QGlobalRWFactory::GetInstance().LoadPlugin("LHDRGlobalReader");
            QMessageHandler::Info(GetName(), std::string("loaded default g-reader LHDRGlobalReader"));
        }
 
        else if(fileExtension == ".gui") {
            QGlobalRWFactory::GetInstance().LoadPlugin("LGuiSessionReader");
            QMessageHandler::Info(GetName(), std::string("loaded default g-reader LGUISessionReader"));
        }
        std::list<const QGlobalReaderFactory*> readerFactories = QGlobalRWFactory::GetInstance().GetListOfGlobalReaders();
        for(iter = readerFactories.begin(); iter!= readerFactories.end(); iter++)
            if((*iter)->GetExt() == fileExtension) 
                fLastReader = QGlobalRWFactory::GetInstance().CreateGlobalReader((*iter)->GetName());
    }
 
    // no reader found
    if(fLastReader == NULL) { 
        err = QERR_CANNOT_OPEN_FILE;
        err.SetDescription(GetName(),__LINE__, std::string("No reader found for extension: \"") + fileExtension + "\"" + " (file: "+ fname  +")");
        return NULL;
    }
 
    // open file and register it
    if(isReader)
        err = fLastReader->Open(fname, "CURRENT_READER");
    else
        err = fLastReader->Open(fname);
    if(err != QERR_SUCCESS) {
        delete fLastReader;
        return NULL;
    }
    fReaders[fname] = fLastReader;
    return fLastReader; 
}
 
QGlobalReaderDispatcher::~QGlobalReaderDispatcher()
{
    Clear();
}
 
 
void QGlobalReaderDispatcher::Clear()
{  
    std::map<std::string, QGlobalReader*>::iterator iter;
    for(iter=fReaders.begin(); iter!=fReaders.end(); iter++) {
        (*iter).second->Close();
        if((*iter).second) delete (*iter).second;
        (*iter).second = 0;
    }
    fReaders.clear();
    fLastReader = NULL;
}