mediaioportgroup.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_PROAV
#include <promeki/namespace.h>
#include <promeki/objectbase.h>
#include <promeki/atomic.h>
#include <promeki/error.h>
#include <promeki/framenumber.h>
#include <promeki/framecount.h>
#include <promeki/framerate.h>
#include <promeki/ratetracker.h>
#include <promeki/timestamp.h>
#include <promeki/list.h>
#include <promeki/string.h>
#include <promeki/clock.h>
#include <promeki/mediaio.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class MediaIO;
class MediaIOPort;
class MediaIORequest;
 
class MediaIOPortGroup : public ObjectBase {
                PROMEKI_OBJECT(MediaIOPortGroup, ObjectBase)
                friend class MediaIO;
                friend class MediaIOSink;
                friend class MediaIOSource;
                friend class MediaIOReadCache;
                friend class CommandMediaIO;
        public:
                using PortList = ::promeki::List<MediaIOPort *>;
 
                MediaIOPortGroup(MediaIO *mediaIO, const String &name, const Clock::Ptr &clock);
 
                ~MediaIOPortGroup() override;
 
                MediaIO *mediaIO() const { return _mediaIO; }
 
                const String &name() const { return _name; }
 
                const PortList &ports() const { return _ports; }
 
                void addPort(MediaIOPort *port);
 
                const Clock::Ptr &clock() const { return _clock; }
 
                MediaIORequest setClock(const Clock::Ptr &clock);
 
                int pendingWrites() const { return _pendingWriteCount.value(); }
 
                int pendingReads() const { return _pendingReadCount.value(); }
 
                FrameNumber currentFrame() const { return _currentFrame; }
 
                double rate() const { return _rate; }
 
                void setRate(double r);
 
                int nextStep();
 
                MediaIORequest seekToFrame(const FrameNumber &frameNumber,
                                           MediaIOSeekMode  mode = MediaIO_SeekDefault);
 
                FrameCount frameCount() const { return _frameCount; }
 
                bool canSeek() const { return _canSeek; }
 
                void setCanSeek(bool val) { _canSeek = val; }
 
                void setFrameCount(const FrameCount &val) { _frameCount = val; }
 
                bool atEnd() const { return _atEnd; }
 
                const FrameRate &frameRate() const { return _frameRate; }
 
                void setFrameRate(const FrameRate &val) { _frameRate = val; }
 
                const TimeStamp &originTime() const { return _originTime; }
 
                void setOriginTime(const TimeStamp &val) { _originTime = val; }
 
                // ---- Per-group accounting ----
                //
                // A single backend tick (one CmdRead or CmdWrite)
                // advances the whole group, regardless of how many
                // ports it has — so the rate tracker, dropped /
                // repeated / late counters, and pending-command
                // counts all live here.  Reporting one dropped frame
                // on a paired audio + video group correctly counts
                // one missed tick rather than inflating the metric
                // to two.
 
                int64_t bytesPerSecond() const { return _rateTracker.bytesPerSecond(); }
 
                double framesPerSecond() const { return _rateTracker.framesPerSecond(); }
 
                int64_t framesDroppedTotal() const { return _framesDroppedTotal.value(); }
 
                int64_t framesRepeatedTotal() const { return _framesRepeatedTotal.value(); }
 
                int64_t framesLateTotal() const { return _framesLateTotal.value(); }
 
        private:
                MediaIO          *_mediaIO = nullptr;
                String            _name;
                PortList          _ports;
                Clock::Ptr        _clock;
                Atomic<int>       _pendingWriteCount;
                Atomic<int>       _pendingReadCount;
                FrameNumber       _currentFrame;
                FrameCount        _frameCount;
                FrameRate         _frameRate;
                TimeStamp         _originTime;
                RateTracker       _rateTracker;
                Atomic<int64_t>   _framesDroppedTotal{0};
                Atomic<int64_t>   _framesRepeatedTotal{0};
                Atomic<int64_t>   _framesLateTotal{0};
                double            _rate = 1.0;
                double            _rateAccumulator = 0.0;
                bool              _canSeek = false;
                bool              _atEnd = false;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_PROAV