dedicatedthreadmediaio.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_PROAV
#include <promeki/atomic.h>
#include <promeki/commandmediaio.h>
#include <promeki/list.h>
#include <promeki/mutex.h>
#include <promeki/thread.h>
#include <promeki/timestamp.h>
#include <promeki/waitcondition.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class DedicatedThreadMediaIO : public CommandMediaIO {
                PROMEKI_OBJECT(DedicatedThreadMediaIO, CommandMediaIO)
        public:
                DedicatedThreadMediaIO(ObjectBase *parent = nullptr);
 
                ~DedicatedThreadMediaIO() override;
 
                bool isIdle() const override;
 
        protected:
                void submit(MediaIOCommand::Ptr cmd) override;
 
        private:
                struct QueueEntry {
                                MediaIOCommand::Ptr cmd;
                                TimeStamp           submitTime;
                };
 
                // Private nested @ref Thread subclass so we get the
                // library's OS-name / priority / affinity controls
                // without dragging an EventLoop into the worker (the
                // override of @c run drains the queue directly).
                class Worker : public Thread {
                                public:
                                        Worker(DedicatedThreadMediaIO *owner) : _owner(owner) {}
 
                                protected:
                                        void run() override { _owner->workerMain(); }
 
                                private:
                                        DedicatedThreadMediaIO *_owner;
                };
 
                void workerMain();
 
                mutable Mutex            _mutex;
                WaitCondition            _cond;
                List<QueueEntry>         _queue;
                List<QueueEntry>         _urgentQueue;
                Atomic<bool>             _shutdown{false};
                Atomic<bool>             _busy{false};
                Worker                   _worker;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_PROAV