T2Life.cc

Go to the documentation of this file.

#include "T2Life.h"
#include <string>
#include <fstream>
#include <sstream>
#include <vector>
#include <iostream>
#include <utl/Reader.h>
#include <fwk/CentralConfig.h>

using namespace utl;
using namespace sdet;
using namespace std;


T2Life* T2Life::gfT2Life = nullptr;


T2Life::T2Life()
{
  Branch tb =
    fwk::CentralConfig::GetInstance()->GetTopBranch("T2LifeFileManager").GetChild("T2Files").GetFirstChild();

  while (tb) {
    tb.GetChild("start").GetData(fCurrentFileStart);
    tb.GetChild("end").GetData(fCurrentFileEnd);
    string filename;
    tb.GetChild("filename").GetData(filename);

    fFile = new ifstream(filename.c_str());

    fFiles.insert(make_pair(fCurrentFileStart, make_pair(fCurrentFileEnd, fFile)));
    tb = tb.GetNextSibling();
  }
}


T2Life&
T2Life::GetT2Life()
{
  if (!gfT2Life)
    gfT2Life = new T2Life();

  return *gfT2Life;
}


const vector<unsigned int>&
T2Life::GetValidStations(unsigned int theGPSSecond)
{
  SetFile(theGPSSecond);

  if (theGPSSecond < fCurrentStop && theGPSSecond >= fCurrentStart)
    return fValidStations;

  if (theGPSSecond < fCurrentStart) { // requested earlier time
    fFile->seekg(0);
    cerr << "Rewinding T2Life file. Why?" << endl;
  }

  fValidStations.clear();
  string line;
  istringstream buffer;
  bool found = false;
  int line_number = 0;
  while (getline(*fFile, line)) { // find next valid line
    ++line_number;
    buffer.str(line);
    unsigned int start;
    unsigned int end;
    buffer >> start >> end;

    if (theGPSSecond < start)
      break;

    if (theGPSSecond < end) {
      found = true;
      fCurrentStart = start;
      fCurrentStop = end;
      break;
    }
  }

  if (!found) {
    cerr << theGPSSecond << " out of range in T2Life. Why?\n"
         << "line " << line_number << '\n'
         << line << endl;
    fCurrentStart = 0;
    fCurrentStop = 0;
    fFile->seekg(0);
    return fValidStations;
  }

  for (unsigned i = 0; i < 101; ++i)
    fValidStations.push_back(0);

  int flag;
  while (buffer >> flag)
    fValidStations.push_back(flag);

  return fValidStations;
}


void
T2Life::SetFile(unsigned int theGPSSecond)
{
  if (theGPSSecond < fCurrentFileEnd && theGPSSecond > fCurrentFileStart)
    return;

  std::map<unsigned int, std::pair<unsigned int, std::ifstream*> >::iterator file =
    --fFiles.upper_bound(theGPSSecond);

  fFile = file->second.second;
  fCurrentFileStart = file->first;
  fCurrentFileEnd = file->second.first;
  fCurrentStart = file->first;
  fCurrentStop = file->first;
}


namespace sdet {

  const std::vector<unsigned int>&
  GetStationsStatusFromT2Files(unsigned int theGPSSecond)
  {
    return T2Life::GetT2Life().GetValidStations(theGPSSecond);
  }

}