mediaioreadcache.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_PROAV
#include <promeki/namespace.h>
#include <promeki/error.h>
#include <promeki/list.h>
#include <promeki/mutex.h>
#include <promeki/mediaiocommand.h>
#include <promeki/mediaiorequest.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class MediaIOSource;
 
class MediaIOReadCache {
        public:
                explicit MediaIOReadCache(MediaIOSource *source);
 
                ~MediaIOReadCache();
 
                MediaIOReadCache(const MediaIOReadCache &) = delete;
                MediaIOReadCache &operator=(const MediaIOReadCache &) = delete;
 
                void setDepth(int n);
 
                int depth() const;
 
                int count() const;
 
                bool isEmpty() const;
 
                bool isHeadReady() const;
 
                MediaIORequest readFrame();
 
                size_t cancelAll();
 
                void pushSyntheticResult(Error err);
 
                void onCommandCompleted();
 
        private:
                MediaIOCommand::Ptr submitOneLocked();
                bool                checkArmedLocked();
 
                MediaIOSource              *_source = nullptr;
                List<MediaIOCommand::Ptr>   _queue;
                int                         _depth = 1;
                bool                        _headReadyArmed = false;
                mutable Mutex               _mutex;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_PROAV