audiodecodermediaio.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/mediaconfig.h>
#include <promeki/audiodecoder.h>
#include <promeki/audiocodec.h>
#include <promeki/audioformat.h>
#include <promeki/string.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class AudioDecoderMediaIO : public SharedThreadMediaIO {
                PROMEKI_OBJECT(AudioDecoderMediaIO, SharedThreadMediaIO)
        public:
                static inline const MediaIOStats::ID StatsPacketsDecoded{"PacketsDecoded"};
 
                static inline const MediaIOStats::ID StatsFramesOut{"FramesOut"};
 
                AudioDecoderMediaIO(ObjectBase *parent = nullptr);
                ~AudioDecoderMediaIO() override;
 
                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;
                int   pendingInternalWrites() 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;
                void  configChanged(const MediaConfig &delta) override;
 
        private:
                // Drains every currently-available output Frame out of
                // the underlying decoder and pushes them onto
                // @c _outputQueue.  The decoder is responsible for
                // echoing the source Frame's video / metadata through
                // onto each emitted Frame via the base
                // @ref AudioDecoder::buildOutputFrame helper.
                void  drainDecoderInto();
                // Converts any decoded PCM audio payload on @p in to the
                // advertised @c _outputAudioDataType when the codec emitted a
                // different native format.  Returns @p in untouched when no
                // conversion is needed.
                Frame coerceOutputFormat(Frame in);
                Error createDecoder(const AudioCodec &codec);
 
                MediaConfig        _config;
                AudioCodec         _codec;
                AudioDecoder::UPtr _decoder;
                AudioFormat::ID    _outputAudioDataType = AudioFormat::Invalid;
                bool               _outputAudioDataTypeSet = false;
                int                _capacity = 8;
                Frame::List        _outputQueue;
                FrameCount         _frameCount{0};
                int64_t            _readCount = 0;
                int64_t            _packetsDecoded = 0;
                int64_t            _framesOut = 0;
                bool               _capacityWarned = false;
                bool               _closed = false;
};
 
class AudioDecoderFactory : public MediaIOFactory {
        public:
                AudioDecoderFactory() = default;
 
                String name() const override { return String("AudioDecoder"); }
                String displayName() const override { return String("Audio Decoder"); }
                String description() const override {
                        return String("Decodes compressed audio bitstreams into PCM frames");
                }
                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