file_parser.cpp

Go to the documentation of this file.

// Copyright (C) 2011 Lutz Foucar

/**
 * @file file_parser.cpp contains the base class for all file parsers
 *
 * @author Lutz Foucar
 */

#include <sstream>
#include <stdexcept>
#include <iostream>

#include "file_parser.h"

#include "lma_parser.h"
#include "raw_sss_parser.h"
#include "frms6_parser.h"
#include "txt_parser.h"
#include "file_reader.h"
#include "log.h"

#ifdef LCLSLIBRARY
#include "xtc_parser.h"
#endif

using namespace cass;
using namespace std;
using namespace std::tr1;

FileParser::FileParser(const filereaderpointerpair_t readerpointerpair,
                       event2positionreaders_t &event2posreader,
                       QReadWriteLock &lock)
  : lmf::PausableThread(),
    _readerpointerpair(readerpointerpair),
    _event2posreader(event2posreader),
    _lock(lock)
{}

FileParser::~FileParser()
{}

FileParser::shared_pointer FileParser::instance(const std::string type,
                                                const filereaderpointerpair_t readerpointerpair,
                                                event2positionreaders_t &event2posreader,
                                                QReadWriteLock &lock)
{
  shared_pointer ptr;
  if (type == "lma")
    ptr = shared_pointer(new ACQIRIS::LMAParser(readerpointerpair,event2posreader, lock));
  else if (type == "txt")
    ptr = shared_pointer(new TxtParser(readerpointerpair,event2posreader, lock));
#ifdef LCLSLIBRARY
  else if (type == "xtc")
    ptr = shared_pointer(new XtcParser(readerpointerpair,event2posreader, lock));
#endif
  else
    throw invalid_argument("FileParser::instance: file extension '"+ type +
                           "' is unknown.");
  return ptr;
}

void FileParser::savePos(const std::streampos& eventStartPos, const uint64_t eventId)
{
  _readerpointerpair.second._pos = eventStartPos;
  if (!eventId)
  {
    Log::add(Log::WARNING,"FileParser::savePos: EventId '"+ toString(eventId) +
             "' from parser type '"+type()+"' of seems to be wrong; skipping event.");
    return;
  }
  QWriteLocker lock(&_lock);
  _event2posreader[eventId].push_back(_readerpointerpair);
}