NekoCWD/libcamera
NekoCWD/libcamera
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 7 Wiki Activity Actions

libcamera: camera: Pass the stream set to allocate/freeBuffers()

Browse source 
Pipeline handlers might need to perform allocation of internal buffers,
setup operations, or simple sanity check before going into the
per-stream buffer allocation.

As of now, PipelineHandler::allocateBuffers() is called once for each
active stream, leaving no space for stream-independent configuration.

Change this by providing to the pipeline handlers the full set of active
streams, and ask them to loop over them to perform per-streams
memory allocations and freeing.

Reviewed-by: Niklas Söderlund <niklas.soderlund@ragnatech.se>
Reviewed-by: Laurent Pinchart <laurent.pinchart@ideasonboard.com>
Signed-off-by: Jacopo Mondi <jacopo@jmondi.org>
This commit is contained in:
Jacopo Mondi 2019-03-26 17:25:15 +01:00
parent 4e1dc9004f
commit 911bc4aa41
6 changed files with 43 additions and 28 deletions
Download patch file Download diff file Expand all files Collapse all files

7
src/libcamera/camera.cpp
View file

@ -647,14 +647,12 @@ int Camera::allocateBuffers()
return -EINVAL; return -EINVAL;
} }
for (Stream *stream : activeStreams_) { int ret = pipe_->allocateBuffers(this, activeStreams_);
int ret = pipe_->allocateBuffers(this, stream);
if (ret) { if (ret) {
LOG(Camera, Error) << "Failed to allocate buffers"; LOG(Camera, Error) << "Failed to allocate buffers";
freeBuffers(); freeBuffers();
return ret; return ret;
} }
}
state_ = CameraPrepared; state_ = CameraPrepared;
@ -683,12 +681,11 @@ int Camera::freeBuffers()
* by the V4L2 device that has allocated them. * by the V4L2 device that has allocated them.
*/ */
stream->bufferPool().destroyBuffers(); stream->bufferPool().destroyBuffers();
pipe_->freeBuffers(this, stream);
} }
state_ = CameraConfigured; state_ = CameraConfigured;
return 0; return pipe_->freeBuffers(this, activeStreams_);
} }
/** /**

6
src/libcamera/include/pipeline_handler.h
View file

@ -58,8 +58,10 @@ public:
streamConfiguration(Camera *camera, const std::vector<StreamUsage> &usages) = 0; streamConfiguration(Camera *camera, const std::vector<StreamUsage> &usages) = 0;
virtual int configureStreams(Camera *camera, const CameraConfiguration &config) = 0; virtual int configureStreams(Camera *camera, const CameraConfiguration &config) = 0;
virtual int allocateBuffers(Camera *camera, Stream *stream) = 0; virtual int allocateBuffers(Camera *camera,
virtual int freeBuffers(Camera *camera, Stream *stream) = 0; const std::set<Stream *> &streams) = 0;
virtual int freeBuffers(Camera *camera,
const std::set<Stream *> &streams) = 0;
virtual int start(Camera *camera) = 0; virtual int start(Camera *camera) = 0;
virtual void stop(Camera *camera); virtual void stop(Camera *camera);

13
src/libcamera/pipeline/ipu3/ipu3.cpp
View file

@ -145,8 +145,10 @@ public:
int configureStreams(Camera *camera, int configureStreams(Camera *camera,
const CameraConfiguration &config) override; const CameraConfiguration &config) override;
int allocateBuffers(Camera *camera, Stream *stream) override; int allocateBuffers(Camera *camera,
int freeBuffers(Camera *camera, Stream *stream) override; const std::set<Stream *> &streams) override;
int freeBuffers(Camera *camera,
const std::set<Stream *> &streams) override;
int start(Camera *camera) override; int start(Camera *camera) override;
void stop(Camera *camera) override; void stop(Camera *camera) override;
@ -305,9 +307,11 @@ int PipelineHandlerIPU3::configureStreams(Camera *camera,
return 0; return 0;
} }
int PipelineHandlerIPU3::allocateBuffers(Camera *camera, Stream *stream) int PipelineHandlerIPU3::allocateBuffers(Camera *camera,
const std::set<Stream *> &streams)
{ {
IPU3CameraData *data = cameraData(camera); IPU3CameraData *data = cameraData(camera);
Stream *stream = *streams.begin();
CIO2Device *cio2 = &data->cio2_; CIO2Device *cio2 = &data->cio2_;
ImgUDevice *imgu = data->imgu_; ImgUDevice *imgu = data->imgu_;
int ret; int ret;
@ -346,7 +350,8 @@ int PipelineHandlerIPU3::allocateBuffers(Camera *camera, Stream *stream)
return 0; return 0;
} }
int PipelineHandlerIPU3::freeBuffers(Camera *camera, Stream *stream) int PipelineHandlerIPU3::freeBuffers(Camera *camera,
const std::set<Stream *> &streams)
{ {
IPU3CameraData *data = cameraData(camera); IPU3CameraData *data = cameraData(camera);

13
src/libcamera/pipeline/uvcvideo.cpp
View file

@ -32,8 +32,10 @@ public:
int configureStreams(Camera *camera, int configureStreams(Camera *camera,
const CameraConfiguration &config) override; const CameraConfiguration &config) override;
int allocateBuffers(Camera *camera, Stream *stream) override; int allocateBuffers(Camera *camera,
int freeBuffers(Camera *camera, Stream *stream) override; const std::set<Stream *> &streams) override;
int freeBuffers(Camera *camera,
const std::set<Stream *> &streams) override;
int start(Camera *camera) override; int start(Camera *camera) override;
void stop(Camera *camera) override; void stop(Camera *camera) override;
@ -127,9 +129,11 @@ int PipelineHandlerUVC::configureStreams(Camera *camera,
return 0; return 0;
} }
int PipelineHandlerUVC::allocateBuffers(Camera *camera, Stream *stream) int PipelineHandlerUVC::allocateBuffers(Camera *camera,
const std::set<Stream *> &streams)
{ {
UVCCameraData *data = cameraData(camera); UVCCameraData *data = cameraData(camera);
Stream *stream = *streams.begin();
const StreamConfiguration &cfg = stream->configuration(); const StreamConfiguration &cfg = stream->configuration();
LOG(UVC, Debug) << "Requesting " << cfg.bufferCount << " buffers"; LOG(UVC, Debug) << "Requesting " << cfg.bufferCount << " buffers";
@ -137,7 +141,8 @@ int PipelineHandlerUVC::allocateBuffers(Camera *camera, Stream *stream)
return data->video_->exportBuffers(&stream->bufferPool()); return data->video_->exportBuffers(&stream->bufferPool());
} }
int PipelineHandlerUVC::freeBuffers(Camera *camera, Stream *stream) int PipelineHandlerUVC::freeBuffers(Camera *camera,
const std::set<Stream *> &streams)
{ {
UVCCameraData *data = cameraData(camera); UVCCameraData *data = cameraData(camera);
return data->video_->releaseBuffers(); return data->video_->releaseBuffers();

13
src/libcamera/pipeline/vimc.cpp
View file

@ -32,8 +32,10 @@ public:
int configureStreams(Camera *camera, int configureStreams(Camera *camera,
const CameraConfiguration &config) override; const CameraConfiguration &config) override;
int allocateBuffers(Camera *camera, Stream *stream) override; int allocateBuffers(Camera *camera,
int freeBuffers(Camera *camera, Stream *stream) override; const std::set<Stream *> &streams) override;
int freeBuffers(Camera *camera,
const std::set<Stream *> &streams) override;
int start(Camera *camera) override; int start(Camera *camera) override;
void stop(Camera *camera) override; void stop(Camera *camera) override;
@ -127,9 +129,11 @@ int PipelineHandlerVimc::configureStreams(Camera *camera,
return 0; return 0;
} }
int PipelineHandlerVimc::allocateBuffers(Camera *camera, Stream *stream) int PipelineHandlerVimc::allocateBuffers(Camera *camera,
const std::set<Stream *> &streams)
{ {
VimcCameraData *data = cameraData(camera); VimcCameraData *data = cameraData(camera);
Stream *stream = *streams.begin();
const StreamConfiguration &cfg = stream->configuration(); const StreamConfiguration &cfg = stream->configuration();
LOG(VIMC, Debug) << "Requesting " << cfg.bufferCount << " buffers"; LOG(VIMC, Debug) << "Requesting " << cfg.bufferCount << " buffers";
@ -137,7 +141,8 @@ int PipelineHandlerVimc::allocateBuffers(Camera *camera, Stream *stream)
return data->video_->exportBuffers(&stream->bufferPool()); return data->video_->exportBuffers(&stream->bufferPool());
} }
int PipelineHandlerVimc::freeBuffers(Camera *camera, Stream *stream) int PipelineHandlerVimc::freeBuffers(Camera *camera,
const std::set<Stream *> &streams)
{ {
VimcCameraData *data = cameraData(camera); VimcCameraData *data = cameraData(camera);
return data->video_->releaseBuffers(); return data->video_->releaseBuffers();

11
src/libcamera/pipeline_handler.cpp
View file

@ -193,10 +193,11 @@ PipelineHandler::~PipelineHandler()
* \fn PipelineHandler::allocateBuffers() * \fn PipelineHandler::allocateBuffers()
* \brief Allocate buffers for a stream * \brief Allocate buffers for a stream
* \param[in] camera The camera the \a stream belongs to * \param[in] camera The camera the \a stream belongs to
* \param[in] stream The stream to allocate buffers for * \param[in] streams The set of streams to allocate buffers for
* *
* This method allocates buffers internally in the pipeline handler and * This method allocates buffers internally in the pipeline handler for each
* associates them with the stream's buffer pool. * stream in the \a streams buffer set, and associates them with the stream's
* buffer pool.
* *
* The intended caller of this method is the Camera class. * The intended caller of this method is the Camera class.
* *
@ -207,9 +208,9 @@ PipelineHandler::~PipelineHandler()
* \fn PipelineHandler::freeBuffers() * \fn PipelineHandler::freeBuffers()
* \brief Free all buffers associated with a stream * \brief Free all buffers associated with a stream
* \param[in] camera The camera the \a stream belongs to * \param[in] camera The camera the \a stream belongs to
* \param[in] stream The stream to free buffers from * \param[in] streams The set of streams to free buffers from
* *
* After a capture session has been stopped all buffers associated with the * After a capture session has been stopped all buffers associated with each
* stream shall be freed. * stream shall be freed.
* *
* The intended caller of this method is the Camera class. * The intended caller of this method is the Camera class.