AbstractSeeker.h

#pragma once

#include <Poco/Clock.h>
#include <Poco/Mutex.h>
#include <Poco/RunnableAdapter.h>
#include <Poco/SharedPtr.h>
#include <Poco/Timespan.h>
#include <Poco/Thread.h>

#include "util/AsyncWork.h"
#include "util/Joiner.h"
#include "util/Loggable.h"
#include "loop/StopControl.h"

namespace BeeeOn {

class AbstractSeeker : public AsyncWork<>, protected Loggable {
public:
        typedef Poco::SharedPtr<AbstractSeeker> Ptr;

        AbstractSeeker(const Poco::Timespan &duration);

        Poco::Timespan duration() const;

        Poco::Timespan elapsed() const;

        Poco::Timespan remaining() const;

        void start();

        bool tryJoin(const Poco::Timespan &timeout) override;

        void cancel() override;

protected:
        void seek();
        virtual void seekLoop(StopControl &control) = 0;

private:
        Poco::Timespan m_duration;
        Poco::RunnableAdapter<AbstractSeeker> m_runnable;
        Poco::Thread m_thread;
        mutable Poco::FastMutex m_lock;
        Poco::Clock m_started;
        bool m_hasStarted;
        StopControl m_stopControl;
        Joiner m_joiner;
};

}