fd0087b5d8
For all tests that don't otherwise require access to the camera manager, get the event dispatcher from the current thread instead of the camera manager. This prepares for the removal of CameraManager::instance(). Signed-off-by: Laurent Pinchart <laurent.pinchart@ideasonboard.com> Reviewed-by: Jacopo Mondi <jacopo@jmondi.org>
88 lines
1.7 KiB
C++
88 lines
1.7 KiB
C++
/* SPDX-License-Identifier: GPL-2.0-or-later */
|
|
/*
|
|
* Copyright (C) 2019, Google Inc.
|
|
*
|
|
* libcamera V4L2 API tests
|
|
*/
|
|
|
|
#include <libcamera/buffer.h>
|
|
#include <libcamera/event_dispatcher.h>
|
|
#include <libcamera/timer.h>
|
|
|
|
#include <iostream>
|
|
|
|
#include "thread.h"
|
|
#include "v4l2_videodevice_test.h"
|
|
|
|
class CaptureAsyncTest : public V4L2VideoDeviceTest
|
|
{
|
|
public:
|
|
CaptureAsyncTest()
|
|
: V4L2VideoDeviceTest("vimc", "Raw Capture 0"), frames(0) {}
|
|
|
|
void receiveBuffer(Buffer *buffer)
|
|
{
|
|
std::cout << "Received buffer " << buffer->index() << std::endl;
|
|
frames++;
|
|
|
|
/* Requeue the buffer for further use. */
|
|
capture_->queueBuffer(buffer);
|
|
}
|
|
|
|
protected:
|
|
int run()
|
|
{
|
|
const unsigned int bufferCount = 8;
|
|
|
|
EventDispatcher *dispatcher = Thread::current()->eventDispatcher();
|
|
Timer timeout;
|
|
int ret;
|
|
|
|
pool_.createBuffers(bufferCount);
|
|
|
|
ret = capture_->exportBuffers(&pool_);
|
|
if (ret)
|
|
return TestFail;
|
|
|
|
capture_->bufferReady.connect(this, &CaptureAsyncTest::receiveBuffer);
|
|
|
|
std::vector<std::unique_ptr<Buffer>> buffers;
|
|
buffers = capture_->queueAllBuffers();
|
|
if (buffers.empty())
|
|
return TestFail;
|
|
|
|
ret = capture_->streamOn();
|
|
if (ret)
|
|
return TestFail;
|
|
|
|
timeout.start(10000);
|
|
while (timeout.isRunning()) {
|
|
dispatcher->processEvents();
|
|
if (frames > 30)
|
|
break;
|
|
}
|
|
|
|
if (frames < 1) {
|
|
std::cout << "Failed to capture any frames within timeout." << std::endl;
|
|
return TestFail;
|
|
}
|
|
|
|
if (frames < 30) {
|
|
std::cout << "Failed to capture 30 frames within timeout." << std::endl;
|
|
return TestFail;
|
|
}
|
|
|
|
std::cout << "Processed " << frames << " frames" << std::endl;
|
|
|
|
ret = capture_->streamOff();
|
|
if (ret)
|
|
return TestFail;
|
|
|
|
return TestPass;
|
|
}
|
|
|
|
private:
|
|
unsigned int frames;
|
|
};
|
|
|
|
TEST_REGISTER(CaptureAsyncTest);
|