ExporterQueue.h

#pragma once

#include <queue>

#include <Poco/AtomicCounter.h>
#include <Poco/Mutex.h>
#include <Poco/SharedPtr.h>

#include "core/Exporter.h"
#include "model/SensorData.h"
#include "util/Loggable.h"
#include "util/FailDetector.h"

namespace BeeeOn {

class ExporterQueue : protected Loggable {
public:
        typedef Poco::SharedPtr<ExporterQueue> Ptr;

        const static int UNLIMITED_BATCH_SIZE = 0;
        const static int UNLIMITED_CAPACITY = 0;
        const static int UNLIMITED_THRESHOLD = FailDetector::TRESHOLD_UNLIMITED;

        ExporterQueue(
                Poco::SharedPtr<Exporter> exporter,
                int batchSize,
                int capacity,
                int treshold);

        ~ExporterQueue();

        void enqueue(const SensorData &sensorData);
        unsigned int exportBatch();

        unsigned int sent() const;
        unsigned int dropped() const;

        bool canExport(const Poco::Timespan &deadTimeout) const;

        bool working() const;

private:
        bool deadTooLong(const Poco::Timespan deadTimeout) const;

        bool isEmpty() const;

        SensorData &front();
        void pop();

private:
        mutable Poco::FastMutex m_queueMutex;

        Poco::SharedPtr<Exporter> m_exporter;

        Poco::AtomicCounter m_dropped;
        Poco::AtomicCounter m_sent;

        FailDetector m_failDetector;
        std::queue<SensorData> m_queue;
        unsigned int m_capacity;
        unsigned int m_batchSize;
};

}