framebridgemediaio.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_NETWORK
#include <promeki/namespace.h>
#include <promeki/sharedthreadmediaio.h>
#include <promeki/mediaiofactory.h>
#include <promeki/framebridge.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class FrameBridgeMediaIO : public SharedThreadMediaIO {
                PROMEKI_OBJECT(FrameBridgeMediaIO, SharedThreadMediaIO)
        public:
                FrameBridgeMediaIO(ObjectBase *parent = nullptr);
 
                ~FrameBridgeMediaIO() override;
 
                void cancelBlockingWork() override;
 
        protected:
                Error executeCmd(MediaIOCommandOpen &cmd) override;
                Error executeCmd(MediaIOCommandClose &cmd) override;
                Error executeCmd(MediaIOCommandRead &cmd) override;
                Error executeCmd(MediaIOCommandWrite &cmd) override;
 
        private:
                FrameBridge::UPtr _bridge;
                bool              _isOutput = false;
};
 
class FrameBridgeFactory : public MediaIOFactory {
        public:
                FrameBridgeFactory() = default;
 
                String name() const override { return String("FrameBridge"); }
                String displayName() const override { return String("Frame Bridge (IPC)"); }
                String description() const override {
                        return String("Cross-process frame transport via shared memory + UNIX-domain handshake");
                }
                StringList schemes() const override { return {String("pmfb")}; }
                bool       canBeSource() const override { return true; }
                bool       canBeSink() const override { return true; }
 
                Config::SpecMap configSpecs() const override;
                Error           urlToConfig(const Url &url, Config *outConfig) const override;
                MediaIO        *create(const Config &config, ObjectBase *parent = nullptr) const override;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK