associator.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 ASSOCIATOR_H
#define ASSOCIATOR_H

#include <json.h>
#include <IGlassSend.h>
#include <inputinterface.h>
#include <outputinterface.h>
#include <associatorinterface.h>
#include <threadbaseclass.h>
#include <queue.h>
#include <ctime>
#include <memory>

namespace glass3 {

namespace process {
class Associator : public glasscore::IGlassSend,
        public glass3::util::iAssociator, public glass3::util::ThreadBaseClass {
 public:
    Associator(glass3::util::iInput* inputint,
                glass3::util::iOutput* outputint);

    ~Associator();

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

    void clear() override;

    void recieveGlassMessage(std::shared_ptr<json::Object> communication)
            override;

    void sendToAssociator(std::shared_ptr<json::Object> &message) override;

    bool healthCheck() override;

 protected:
    glass3::util::WorkState work() override;

 private:
    int m_iInputCounter;

    int m_iTotalInputCounter;

    int m_iRunningAverageCounter;

    double m_dRunningDPSAverage;

    std::chrono::duration<double> tGlasscoreDuration;

    time_t tLastPerformanceReport;

    int m_iReportInterval;

    glass3::util::Queue* m_MessageQueue;

    glass3::util::iInput* m_Input;

    glass3::util::iOutput* m_Output;
};
}  // namespace process
}  // namespace glass3
#endif  // ASSOCIATOR_H