b602bbe811
The standard C library close() and lseek() functions require inclusion of the unistd.h header. Include it explicitly where needed instead of relying on indirect inclusion. Signed-off-by: Laurent Pinchart <laurent.pinchart@ideasonboard.com> Reviewed-by: Hirokazu Honda <hiroh@chromium.org> Tested-by: Paul Elder <paul.elder@ideasonboard.com>
130 lines
2.7 KiB
C++
130 lines
2.7 KiB
C++
/* SPDX-License-Identifier: LGPL-2.1-or-later */
|
|
/*
|
|
* Copyright (C) 2020, Google Inc.
|
|
*
|
|
* camera_worker.cpp - Process capture requests on behalf of the Camera HAL
|
|
*/
|
|
|
|
#include "camera_worker.h"
|
|
|
|
#include <errno.h>
|
|
#include <string.h>
|
|
#include <sys/poll.h>
|
|
#include <unistd.h>
|
|
|
|
#include "camera_device.h"
|
|
|
|
using namespace libcamera;
|
|
|
|
LOG_DECLARE_CATEGORY(HAL)
|
|
|
|
/*
|
|
* \class CaptureRequest
|
|
* \brief Wrap a libcamera::Request associated with buffers and fences
|
|
*
|
|
* A CaptureRequest is constructed by the CameraDevice, filled with
|
|
* buffers and fences provided by the camera3 framework and then processed
|
|
* by the CameraWorker which queues it to the libcamera::Camera after handling
|
|
* fences.
|
|
*/
|
|
CaptureRequest::CaptureRequest(libcamera::Camera *camera)
|
|
: camera_(camera)
|
|
{
|
|
request_ = camera_->createRequest(reinterpret_cast<uint64_t>(this));
|
|
}
|
|
|
|
void CaptureRequest::addBuffer(Stream *stream, FrameBuffer *buffer, int fence)
|
|
{
|
|
request_->addBuffer(stream, buffer);
|
|
acquireFences_.push_back(fence);
|
|
}
|
|
|
|
void CaptureRequest::queue()
|
|
{
|
|
camera_->queueRequest(request_.get());
|
|
}
|
|
|
|
/*
|
|
* \class CameraWorker
|
|
* \brief Process a CaptureRequest on an internal thread
|
|
*
|
|
* The CameraWorker class wraps a Worker that runs on an internal thread
|
|
* and schedules processing of CaptureRequest through it.
|
|
*/
|
|
CameraWorker::CameraWorker()
|
|
{
|
|
worker_.moveToThread(this);
|
|
}
|
|
|
|
void CameraWorker::start()
|
|
{
|
|
Thread::start();
|
|
}
|
|
|
|
void CameraWorker::stop()
|
|
{
|
|
exit();
|
|
wait();
|
|
}
|
|
|
|
void CameraWorker::run()
|
|
{
|
|
exec();
|
|
dispatchMessages(Message::Type::InvokeMessage);
|
|
}
|
|
|
|
void CameraWorker::queueRequest(CaptureRequest *request)
|
|
{
|
|
/* Async process the request on the worker which runs its own thread. */
|
|
worker_.invokeMethod(&Worker::processRequest, ConnectionTypeQueued,
|
|
request);
|
|
}
|
|
|
|
/*
|
|
* \class CameraWorker::Worker
|
|
* \brief Process a CaptureRequest handling acquisition fences
|
|
*/
|
|
int CameraWorker::Worker::waitFence(int fence)
|
|
{
|
|
/*
|
|
* \todo Better characterize the timeout. Currently equal to the one
|
|
* used by the Rockchip Camera HAL on ChromeOS.
|
|
*/
|
|
constexpr unsigned int timeoutMs = 300;
|
|
struct pollfd fds = { fence, POLLIN, 0 };
|
|
|
|
do {
|
|
int ret = poll(&fds, 1, timeoutMs);
|
|
if (ret == 0)
|
|
return -ETIME;
|
|
|
|
if (ret > 0) {
|
|
if (fds.revents & (POLLERR | POLLNVAL))
|
|
return -EINVAL;
|
|
|
|
return 0;
|
|
}
|
|
} while (errno == EINTR || errno == EAGAIN);
|
|
|
|
return -errno;
|
|
}
|
|
|
|
void CameraWorker::Worker::processRequest(CaptureRequest *request)
|
|
{
|
|
/* Wait on all fences before queuing the Request. */
|
|
for (int fence : request->fences()) {
|
|
if (fence == -1)
|
|
continue;
|
|
|
|
int ret = waitFence(fence);
|
|
close(fence);
|
|
if (ret < 0) {
|
|
LOG(HAL, Error) << "Failed waiting for fence: "
|
|
<< fence << ": " << strerror(-ret);
|
|
return;
|
|
}
|
|
}
|
|
|
|
request->queue();
|
|
}
|