casa6

#include <alma/ASDMBinaries/SDMDataObjectStreamReader.h>

​

#ifdef WITHOUT_BOOST

#include <regex>

#include <alma/ASDM/Misc.h>

#endif

​

using namespace CorrelationModeMod;

using namespace CorrelatorTypeMod;

using namespace PrimitiveDataTypeMod;

using namespace ProcessorTypeMod;

​

using namespace std;

​

namespace asdmbinaries {

​

  SDMDataObjectStreamReaderException::SDMDataObjectStreamReaderException():message("SDMDataObjectStreamReaderException:") {;}

​

  SDMDataObjectStreamReaderException::SDMDataObjectStreamReaderException(const string & message): message("SDMDataObjectStreamReaderException:" + message) {;}   

​

  const string& SDMDataObjectStreamReaderException::getMessage() { return message; }

​

  SDMDataObjectStreamReader::SDMDataObjectStreamReader()  {

  // cout << "SDMDataObjectStreamReader::SDMDataObjectStreamReader() : entering" << endl;

    const char *partNames[] = {"actualDurations", "actualTimes", "autoData", "crossData", "zeroLags", "flags"};

    set<string> dummy(partNames, partNames+6);

    s_partNames = dummy;

    sdmDataSubset = SDMDataSubset(&sdmDataObject);

​

    boundary_1 = "" ;

    currentState = S_NO_BDF;

  // cout << "SDMDataObjectStreamReader::SDMDataObjectStreamReader() : exiting" << endl;

  }

​

  SDMDataObjectStreamReader::~SDMDataObjectStreamReader() {

    //cout << "SDMDataObjectStreamReader::~SDMDataObjectStreamReader : entering" << endl;

    this->close();

    //cout << "SDMDataObjectStreamReader::~SDMDataObjectStreamReader : exiting" << endl;

  }

​

  void SDMDataObjectStreamReader::open(const string& path) {

    checkState(T_OPEN, "open");

    this->path = path;

    f.open(path.c_str(), ifstream::in);

    if (f.fail())

      throw SDMDataObjectStreamReaderException("could not open '" + path + "'.");

​

    boundary_1 = requireMIMEHeader();

    // cout << "Boundary = " << boundary_1 << endl;

    sdmDataObject.valid_ = true;

    requireSDMDataHeaderMIMEPart();

    sdmDataObject.owns();

    integrationIndex = -1; // We have not yet read any integration.

​

    currentState = S_AT_BEGINNING;

  }

​

  int64_t SDMDataObjectStreamReader::position() {

    return (int64_t) f.tellg();

  }

​

  void SDMDataObjectStreamReader::position(int64_t p) {

    f.seekg(p);

  }

​

  void SDMDataObjectStreamReader::close() {

    // cout << "SDMDataObjectStreamReader::close -- Entering" << endl;

    if (f.is_open()) {

      releaseMemory(sdmDataSubset);

      for (unsigned int i = 0; i < remainingSubsets.size(); i++)

    releaseMemory(remainingSubsets[i]);

      for (unsigned int i = 0; i < someSubsets.size(); i++)

    releaseMemory(someSubsets[i]);

      f.close();

      currentState = S_NO_BDF;

    }

    // cout << "SDMDataObjectStreamReader::close -- Exiting" << endl;

  }

​

  unsigned int SDMDataObjectStreamReader::currentIntegrationIndex() const { checkState(T_QUERY, "currentIntegrationIndex"); return integrationIndex; }

  unsigned long long SDMDataObjectStreamReader::currentIntegrationStartsAt() const { checkState(T_QUERY, "currentIntegrationStartAt"); return integrationStartsAt; }

  string                SDMDataObjectStreamReader::title() const { checkState(T_QUERY, "title"); return sdmDataObject.title(); }

  const ByteOrder*                      SDMDataObjectStreamReader::byteOrder() const { checkState(T_QUERY, "byteOrder"); return sdmDataObject.byteOrder(); }

  unsigned long long            SDMDataObjectStreamReader::startTime() const { checkState(T_QUERY, "startTime"); return sdmDataObject.startTime(); }

  unsigned int              SDMDataObjectStreamReader::numTime() const { checkState(T_QUERY, "numTime"); return sdmDataObject.numTime(); }

  string                SDMDataObjectStreamReader::dataOID() const { checkState(T_QUERY, "dataOID"); return sdmDataObject.dataOID(); }

  string                SDMDataObjectStreamReader::execBlockUID() const { checkState(T_QUERY, "execBlockUID"); return sdmDataObject.execBlockUID(); }

  unsigned int              SDMDataObjectStreamReader::execBlockNum() const { checkState(T_QUERY, "execBlockNum"); return sdmDataObject.execBlockNum(); }

  unsigned int              SDMDataObjectStreamReader::scanNum() const { checkState(T_QUERY, "scanNum"); return sdmDataObject.scanNum(); }

  unsigned int              SDMDataObjectStreamReader::subscanNum() const { checkState(T_QUERY, "subscanNum"); return sdmDataObject.subscanNum(); }

  unsigned int              SDMDataObjectStreamReader::numAntenna() const { checkState(T_QUERY, "numAntenna"); return sdmDataObject.numAntenna(); }