SDPFiller.h

Go to the documentation of this file.

#ifndef CARMA_SDP_SDPFILLER_H
#define CARMA_SDP_SDPFILLER_H

// Carma includes
#include <carma/util/Time.h>
#include "carma/monitor/DataflowSubsystem.h"

// Carma tools includes

// C++ standard library includes
#include <string>
#include <vector>
#include <map>

// Namespace using directives

// Class definitions
namespace carma {
  namespace sdp {
    class SDPFiller
      {
      public:
        SDPFiller(const std::string& astroHeaderDir,
                  const std::string& visBrickDir,
                  const std::string& scienceDataFormatDir,
                  const std::string& recycleDir,
                  const int& sleep,
                  const std::string& stopFile,
                  const bool writeFloats = false,
                  const bool getScript = true,
                  const bool force = false);

        ~SDPFiller();

        void reset();

        void processFiles(const std::vector<std::string>& inputAstroHdrFiles,
                          const carma::util::frameType& startFrame, 
                          const carma::util::frameType& endFrame,
                          const std::string& corrType,
                          const std::string& outputSDPFile,
                          const bool& append, const bool& pdb);

        void processFiles(const std::vector<std::string>& inputAstroHdrFiles,
                          const carma::util::frameType& startFrame, 
                          const carma::util::frameType& endFrame,
                          const std::string& corrType,
                          const bool& append, const bool& pdb);

        void processFrameCountRange(const carma::util::frameType& startFrame,
                                    const carma::util::frameType& endFrame,
                                    const std::string& corrType,
                                    const std::string& outputSDPFile,
                                    const bool& append, const bool& rt,
                                    const bool& pdb);

        void processAll(const carma::util::frameType& startFrame, 
                        const carma::util::frameType& endFrame,
                        const std::string& corrType, const bool& rt,
                        const bool& pdb);

      private: 

        carma::monitor::DataflowSubsystem dataflow_;
        std::string astroHeaderDir_p;

        std::string visBrickDir_p;

        std::string scienceDataFormatDir_p;

        std::string recycleDir_p;

        int sleep_p;

        static std::vector<std::string> badFiles;

        std::string stopFile_p;

        std::map<std::string, carma::util::frameType> lastFrameWritten_p;

    bool writeFloats_;
    bool getScript_;
    bool force_;


        std::vector<std::string> dirlist(const std::string& dir);


        bool in(std::string & file);

        carma::util::frameType extractFirstFrameCount(const std::string& 
                                                      fileName);

        std::vector<std::string> 
          refreshInputFileList(const carma::util::frameType& startFrame,
                               const carma::util::frameType& endFrame,
                               bool ignoreDone=true, bool ignoreWrite=true);

        std::string sdpFileName(const std::string& astroHdrFile);

        std::string extractObsBlockId(const std::string& astroHdrFile);

        void updateReadState(const std::string& state, 
                             std::string& astroHdrFile);

        void deleteSDPFile(const std::string& outputSDPFile);

        int moveCorruptedFile(const std::string& corruptedFile);

      };
  }; // namespace sdp
}; // namespace carma


#endif //CARMA_SDP_SDPFILLER_H