SDMDataObjectStreamReader.h

Go to the documentation of this file.

#ifndef SDMDataObjectStreamReader_CLASS
#define SDMDataObjectStreamReader_CLASS
#include <utility>
#include <iostream>
#include <sstream>
#include <fstream>
#include <vector>
#include <map>
#include <set>
#include <bitset>
#ifndef WITHOUT_BOOST
#include <boost/algorithm/string.hpp>
#endif
#include <libxml/parser.h>
#include <libxml/tree.h>

#ifndef WITHOUT_BOOST
#include "boost/filesystem/operations.hpp"
#include <boost/regex.hpp>
#endif

#include <alma/ASDMBinaries/SDMDataObjectParser.h>
#include <alma/ASDMBinaries/SDMDataObject.h>
#include <alma/Enumerations/CPrimitiveDataType.h>

namespace asdmbinaries {
  class SDMDataObjectStreamReaderException {
  public:
    SDMDataObjectStreamReaderException();
    SDMDataObjectStreamReaderException(const std::string& message);
  
    const std::string& getMessage();
  
  private:
    std::string message;
  };
 
  class SDMDataObjectStreamReader {
  public:
    SDMDataObjectStreamReader() ;
    virtual ~SDMDataObjectStreamReader() ;
    void        open(const std::string& path);

    int64_t position();


    void position(int64_t p);
    
    void close();

    unsigned long long currentIntegrationStartsAt() const;

    unsigned int currentIntegrationIndex() const;

    std::string title() const;

    const ByteOrder* byteOrder() const ;

    unsigned long long startTime() const;

    unsigned int numTime() const;

    std::string dataOID() const;

    std::string execBlockUID() const;

    unsigned int execBlockNum() const;

    unsigned int scanNum() const;

    unsigned int subscanNum() const;

    std::string projectPath() const;

    unsigned int numAntenna() const;

    CorrelationModeMod::CorrelationMode correlationMode() const;


    OptionalSpectralResolutionType spectralResolutionType() const;

    ProcessorTypeMod::ProcessorType processorType() const;


    CorrelatorTypeMod::CorrelatorType correlatorType() const;

    bool hasPackedData() const;

    bool isTP() const ;

    bool isWVR() const ;


    bool isCorrelation() const;

    const SDMDataObject::DataStruct& dataStruct() const;

    bool aborted() const;

    unsigned long long abortTime() const;

    std::string abortReason() const;

    std::string toString() const;

    bool                        hasSubset();

    /*
     * Returns a reference to an SDMDataSubset.
     * This SDMDataSubset represents the (sub)integration read and parsed at the current position (see currentIntegrationIndex()
     * and currentIntegrationStartsAt()) in the sequence stored in the stream.
     * O
     * 
     * @return a reference to an SDMDataSubset
     */
    const SDMDataSubset&        getSubset();

    /*
     * Returns binary data found in the BDF file from the current location and contained in the next 
     * nDataSubsets at maximum.
     *
     * The result is returned as a reference to a vector of SDMDataSubset. Each element of this vector
     * is an instance of an SDMDataSubset obtained by a sequential read of the file opened with the method open
     * from the current position in that file.
     *
     * The size of the resulting vector determines how many SDMDataSubsets have been actually read. 
     *
     * @return const vector<SDMDataSubset>& 
     */
    const std::vector<SDMDataSubset>& nextSubsets(unsigned int nSubsets);

    /*
     * Returns all binary data found in the BDF file from the current location.
     *
     * The result is returned as a reference to a vector of SDMDataSubset. Each element of this vector
     * is an instance of an SDMDataSubset obtained by a sequential read of the file opened with the method open
     * from the current position in that file. 
     *
     * @return const vector<SDMDataSubset>& 
     */
    const std::vector<SDMDataSubset>& allRemainingSubsets();

    enum BINATTACHCODES {ACTUALDURATIONS=0, ACTUALTIMES=1, AUTODATA=2, FLAGS=3, CROSSDATA=4, ZEROLAGS=5};
    std::bitset<6> attachmentFlags;

  private:
    // Enumerations to manage the state of an instance of SDMDataObjectStreamReader.
    //
    enum States {S_NO_BDF, S_AT_BEGINNING, S_READING, S_AT_END};
    enum Transitions {T_OPEN, T_QUERY, T_TEST_END, T_READ, T_READ_NEXT, T_READ_ALL, T_CLOSE};

    // Private variables
    unsigned long long integrationStartsAt;
    unsigned int       integrationIndex;
    std::string path;
    std::ifstream       f;
    States      currentState;
    std::string currentLine;
    std::string boundary_1;
    std::string      boundary_2;
    bool        opened;

    std::map<std::string, int64_t>      binaryPartSize;
    std::set<std::string>                       s_partNames;
    char*                       actualTimesBuffer;
    char*                       actualDurationsBuffer;
    char*                       autoDataBuffer;
    char*                       crossDataBuffer;
    char*                       flagsBuffer;
    char*                       zeroLagsBuffer;

    SDMDataObjectParser   parser;
    SDMDataObject         sdmDataObject;
    SDMDataSubset         sdmDataSubset;
    std::vector<SDMDataSubset> remainingSubsets;
    std::vector<SDMDataSubset> someSubsets;

    // Private methods
    void                        checkState(Transitions t, const std::string& methodName) const; 
    std::string                 nextLine();
    std::pair<std::string, std::string> headerField2Pair(const std::string& hf);
    std::pair<std::string, std::string> requireHeaderField(const std::string& hf);
    std::string                 requireMIMEHeader();
    std::string                 requireBoundaryInCT(const std::string& ctValue);
    void                        skipAsLongAsLineStartsWith(const std::string& start);
    void                        skipUntilEmptyLine(int maxSkips);  
    std::string                 accumulateUntilBoundary(const std::string& boundary, int maxLines);
    void                        requireBoundary(const std::string&, int maxLines);
    void                        lookForBinaryPartSize(xmlNode*  aNode);
    std::string                 requireCrossDataType(xmlNode* parent);

    void        printElementNames(xmlNode * a_node);
    void        requireSDMDataHeaderMIMEPart();
    void        requireSDMDataSubsetMIMEPart(SDMDataSubset& sdmDataSubset);

    void        releaseMemory(SDMDataSubset & sdmDataSubset);
  };
} // end namespace asdmbinaries

#endif