fileInput.h

Go to the documentation of this file.

/*****************************************
 * This file is documented for Doxygen.
 * If you modify this file please update
 * the comments so that Doxygen will still
 * be able to work.
 ****************************************/
#ifndef FILEINPUT_H
#define FILEINPUT_H

#include <json.h>
#include <threadbaseclass.h>
#include <input.h>

#include <chrono>
#include <mutex>
#include <string>
#include <memory>

#define GPICK_EXTENSION "gpick"
#define GPICKS_EXTENSION "gpicks"
#define JSON_EXTENSION "json"
#define CC_EXTENSION "dat"

namespace glass3 {
class fileInput : public glass3::input::Input {
 public:
    fileInput();

    explicit fileInput(const std::shared_ptr<const json::Object> &config);

    ~fileInput();

    bool setup(std::shared_ptr<const json::Object> config) override;

    void clear() override;

    const std::string getInputDir();

    void setInputDir(const std::string &dir);

    const std::string getArchiveDir();

    void setArchiveDir(const std::string &dir);

    const std::string getFormat();

    void setFormat(const std::string &format);

    void setShutdownWhenNoData(bool shutdown);

    bool getShutdownWhenNoData();

    void setShutdownWait(int waitTime);

    int getShutdownWait();

 protected:
    std::string fetchRawData(std::string* pOutType) override;

    void cleanupFile(std::string filename, bool move,
                        std::string destinationdir);

 private:
    std::string m_sInputDir;

    std::string m_sArchiveDir;

    std::string m_sFormat;

    std::atomic<bool> m_bShutdownWhenNoData;

    std::atomic<int> m_iShutdownWait;

    std::ifstream m_InputFile;

    std::string m_sFileName;

    std::chrono::high_resolution_clock::time_point m_tFileStartTime;

    int m_iDataCount;

    std::mutex & getMutex();

    std::mutex m_Mutex;
};
}  // namespace glass3
#endif  // FILEINPUT_H