libcamera/jmondi/libcamera.git - Jacopo Mondi's clone of libcamera

diff options

Diffstat (limited to 'src/ipa')

0 files changed, 0 insertions, 0 deletions

/* SPDX-License-Identifier: LGPL-2.1-or-later */ /* * Copyright (C) 2018, Google Inc. * * pipeline_handler.h - Pipeline handler infrastructure */ #pragma once #include <memory> #include <queue> #include <set> #include <string> #include <sys/types.h> #include <vector> #include <libcamera/base/mutex.h> #include <libcamera/base/object.h> #include <libcamera/controls.h> #include <libcamera/stream.h> #include "libcamera/internal/ipa_proxy.h" namespace libcamera { class Camera; class CameraConfiguration; class CameraManager; class DeviceEnumerator; class DeviceMatch; class FrameBuffer; class MediaDevice; class PipelineHandler; class Request; class PipelineHandler : public std::enable_shared_from_this<PipelineHandler>, public Object { public: PipelineHandler(CameraManager *manager); virtual ~PipelineHandler(); virtual bool match(DeviceEnumerator *enumerator) = 0; MediaDevice *acquireMediaDevice(DeviceEnumerator *enumerator, const DeviceMatch &dm); bool acquire(); void release(Camera *camera); virtual std::unique_ptr<CameraConfiguration> generateConfiguration(Camera *camera, Span<const StreamRole> roles) = 0; virtual int configure(Camera *camera, CameraConfiguration *config) = 0; virtual int exportFrameBuffers(Camera *camera, Stream *stream, std::vector<std::unique_ptr<FrameBuffer>> *buffers) = 0; virtual int start(Camera *camera, const ControlList *controls) = 0; void stop(Camera *camera); bool hasPendingRequests(const Camera *camera) const; void registerRequest(Request *request); void queueRequest(Request *request); bool completeBuffer(Request *request, FrameBuffer *buffer); void completeRequest(Request *request); std::string configurationFile(const std::string &subdir, const std::string &name) const; const char *name() const { return name_; } protected: void registerCamera(std::shared_ptr<Camera> camera); void hotplugMediaDevice(MediaDevice *media); virtual int queueRequestDevice(Camera *camera, Request *request) = 0; virtual void stopDevice(Camera *camera) = 0; virtual void releaseDevice(Camera *camera); CameraManager *manager_; private: void unlockMediaDevices(); void mediaDeviceDisconnected(MediaDevice *media); virtual void disconnect(); void doQueueRequest(Request *request); void doQueueRequests(); std::vector<std::shared_ptr<MediaDevice>> mediaDevices_; std::vector<std::weak_ptr<Camera>> cameras_; std::queue<Request *> waitingRequests_; const char *name_; Mutex lock_; unsigned int useCount_ LIBCAMERA_TSA_GUARDED_BY(lock_); friend class PipelineHandlerFactoryBase; }; class PipelineHandlerFactoryBase { public: PipelineHandlerFactoryBase(const char *name); virtual ~PipelineHandlerFactoryBase() = default; std::shared_ptr<PipelineHandler> create(CameraManager *manager) const; const std::string &name() const { return name_; } static std::vector<PipelineHandlerFactoryBase *> &factories(); private: static void registerType(PipelineHandlerFactoryBase *factory); virtual std::unique_ptr<PipelineHandler> createInstance(CameraManager *manager) const = 0; std::string name_; }; template<typename _PipelineHandler> class PipelineHandlerFactory final : public PipelineHandlerFactoryBase { public: PipelineHandlerFactory(const char *name) : PipelineHandlerFactoryBase(name) { } std::unique_ptr<PipelineHandler> createInstance(CameraManager *manager) const override { return std::make_unique<_PipelineHandler>(manager); } }; #define REGISTER_PIPELINE_HANDLER(handler) \ static PipelineHandlerFactory<handler> global_##handler##Factory(#handler); } /* namespace libcamera */


context:
space:
mode: