framesyncmediaio.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_PROAV
#include <promeki/namespace.h>
#include <promeki/sharedthreadmediaio.h>
#include <promeki/mediaiofactory.h>
#include <promeki/framesync.h>
#include <promeki/clock.h>
#include <promeki/syntheticclock.h>
#include <promeki/list.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class Clock;
 
class FrameSyncMediaIO : public SharedThreadMediaIO {
                PROMEKI_OBJECT(FrameSyncMediaIO, SharedThreadMediaIO)
        public:
                static inline const MediaIOStats::ID StatsFramesPushed{"FramesPushed"};
 
                static inline const MediaIOStats::ID StatsFramesPulled{"FramesPulled"};
 
                FrameSyncMediaIO(ObjectBase *parent = nullptr);
                ~FrameSyncMediaIO() override;
 
                void setClock(const Clock::Ptr &clock);
 
                FrameSync &frameSync() { return _sync; }
 
                Error describe(MediaIODescription *out) const override;
                Error proposeInput(const MediaDesc &offered, MediaDesc *preferred) const override;
                Error proposeOutput(const MediaDesc &requested, MediaDesc *achievable,
                                    MediaConfig *configDelta = nullptr) const override;
 
        protected:
                Error executeCmd(MediaIOCommandOpen &cmd) override;
                Error executeCmd(MediaIOCommandClose &cmd) override;
                Error executeCmd(MediaIOCommandRead &cmd) override;
                Error executeCmd(MediaIOCommandWrite &cmd) override;
                Error executeCmd(MediaIOCommandStats &cmd) override;
 
        private:
                FrameSync  _sync;
                Clock::Ptr _ownedClock;
                Clock::Ptr _externalClock;
                FrameCount _framesPushed{0};
                FrameCount _framesPulled{0};
};
 
class FrameSyncFactory : public MediaIOFactory {
        public:
                FrameSyncFactory() = default;
 
                String name() const override { return String("FrameSync"); }
                String displayName() const override { return String("Frame Sync (clock-paced)"); }
                String description() const override {
                        return String("Resyncs media to a target clock cadence (frame-rate / sample-rate / channel "
                                      "conversion)");
                }
                bool canBeTransform() const override { return true; }
 
                Config::SpecMap configSpecs() const override;
                bool            bridge(const MediaDesc &from, const MediaDesc &to, Config *outConfig,
                                       int *outCost) const override;
                MediaIO        *create(const Config &config, ObjectBase *parent = nullptr) const override;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_PROAV