summaryrefslogtreecommitdiff
path: root/test/pipeline/rkisp1/rkisp1_pipeline_test.cpp
blob: acaf3c33b529d31d281c8a990d39d1106581bfca (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
/* SPDX-License-Identifier: GPL-2.0-or-later */
/*
 * Copyright (C) 2020, Linaro
 *
 * Based on test/pipeline/ipu3/ipu3_pipeline_test.cpp
 *
 * rkisp1_pipeline_test.cpp - Rockchip RK3399 rkisp1 pipeline test
 */

#include <iostream>

#include <sys/stat.h>
#include <sys/types.h>
#include <unistd.h>

#include <libcamera/camera.h>
#include <libcamera/camera_manager.h>

#include "libcamera/internal/device_enumerator.h"
#include "libcamera/internal/media_device.h"
#include "libcamera/internal/media_object.h"

#include "test.h"

using namespace std;
using namespace libcamera;

/*
 * Verify that the RK3399 pipeline handler gets matched and cameras
 * are enumerated correctly.
 *
 * The test is supposed to be run on rockchip platform.
 *
 * The test lists all cameras registered in the system, if any camera is
 * available at all.
 */
class RKISP1PipelineTest : public Test
{
protected:
	int init();
	int run();
	void cleanup();

private:
	CameraManager *cameraManager_;
	unsigned int sensors_;
};

int RKISP1PipelineTest::init()
{
	unique_ptr<DeviceEnumerator> enumerator = DeviceEnumerator::create();
	if (!enumerator) {
		cerr << "Failed to create device enumerator" << endl;
		return TestFail;
	}

	if (enumerator->enumerate()) {
		cerr << "Failed to enumerate media devices" << endl;
		return TestFail;
	}

	DeviceMatch dm("rkisp1");

	std::shared_ptr<MediaDevice> rkisp1 = enumerator->search(dm);
	if (!rkisp1) {
		cerr << "Failed to find rkisp1: test skip" << endl;
		return TestSkip;
	}

	int ret = rkisp1->populate();
	if (ret) {
		cerr << "Failed to populate media device "
		     << rkisp1->deviceNode() << endl;
		return TestFail;
	}

	sensors_ = 0;
	const vector<MediaEntity *> &entities = rkisp1->entities();
	for (MediaEntity *entity : entities) {
		if (entity->function() == MEDIA_ENT_F_CAM_SENSOR)
			sensors_++;
	}

	cameraManager_ = new CameraManager();
	ret = cameraManager_->start();
	if (ret) {
		cerr << "Failed to start the CameraManager" << endl;
		return TestFail;
	}

	return 0;
}

int RKISP1PipelineTest::run()
{
	auto cameras = cameraManager_->cameras();
	for (const std::shared_ptr<Camera> &cam : cameras)
		cout << "Found camera '" << cam->id() << "'" << endl;

	if (cameras.size() != sensors_) {
		cerr << cameras.size() << " cameras registered, but " << sensors_
		     << " were expected" << endl;
		return TestFail;
	}

	return TestPass;
}

void RKISP1PipelineTest::cleanup()
{
	cameraManager_->stop();
	delete cameraManager_;
}

TEST_REGISTER(RKISP1PipelineTest)
pan class="hl num">100; i++) { int nBuffer = dist(generator_); int index = cache->get(*buffers[nBuffer].get()); if (index < 0) { std::cout << "Failed lookup from cache" << std::endl; return TestFail; } cache->put(index); } return TestPass; } /* * Test that using a buffer more frequently keeps it hot in the cache at * all times. */ int testHot(V4L2BufferCache *cache, const std::vector<std::unique_ptr<FrameBuffer>> &buffers, unsigned int hotFrequency) { /* Run the random test on the cache to make it messy. */ if (testRandom(cache, buffers) != TestPass) return TestFail; std::uniform_int_distribution<> dist(0, buffers.size() - 1); /* Pick a hot buffer at random and store its index. */ int hotBuffer = dist(generator_); int hotIndex = cache->get(*buffers[hotBuffer].get()); cache->put(hotIndex); /* * Queue hot buffer at the requested frequency and make sure * it stays hot. */ for (unsigned int i = 0; i < buffers.size() * 100; i++) { int nBuffer, index; bool hotQueue = i % hotFrequency == 0; if (hotQueue) nBuffer = hotBuffer; else nBuffer = dist(generator_); index = cache->get(*buffers[nBuffer].get()); if (index < 0) { std::cout << "Failed lookup from cache" << std::endl; return TestFail; } if (hotQueue && index != hotIndex) { std::cout << "Hot buffer got cold" << std::endl; return TestFail; } cache->put(index); } return TestPass; } int testIsEmpty(const std::vector<std::unique_ptr<FrameBuffer>> &buffers) { V4L2BufferCache cache(buffers.size()); if (!cache.isEmpty()) return TestFail; for (auto const &buffer : buffers) { FrameBuffer &b = *buffer.get(); cache.get(b); } if (cache.isEmpty()) return TestFail; unsigned int i; for (i = 0; i < buffers.size() - 1; i++) cache.put(i); if (cache.isEmpty()) return TestFail; cache.put(i); if (!cache.isEmpty()) return TestFail; return TestPass; } int init() override { std::random_device rd; unsigned int seed = rd(); std::cout << "Random seed is " << seed << std::endl; generator_.seed(seed); return TestPass; } int run() override { const unsigned int numBuffers = 8; StreamConfiguration cfg; cfg.pixelFormat = formats::YUYV; cfg.size = Size(600, 800); cfg.bufferCount = numBuffers; BufferSource source; int ret = source.allocate(cfg); if (ret != TestPass) return ret; const std::vector<std::unique_ptr<FrameBuffer>> &buffers = source.buffers(); if (buffers.size() != numBuffers) { std::cout << "Got " << buffers.size() << " buffers, expected " << numBuffers << std::endl; return TestFail; } /* * Test cache of same size as there are buffers, the cache is * created from a list of buffers and will be pre-populated. */ V4L2BufferCache cacheFromBuffers(buffers); if (testSequential(&cacheFromBuffers, buffers) != TestPass) return TestFail; if (testRandom(&cacheFromBuffers, buffers) != TestPass) return TestFail; if (testHot(&cacheFromBuffers, buffers, numBuffers) != TestPass) return TestFail; /* * Test cache of same size as there are buffers, the cache is * not pre-populated. */ V4L2BufferCache cacheFromNumbers(numBuffers); if (testSequential(&cacheFromNumbers, buffers) != TestPass) return TestFail; if (testRandom(&cacheFromNumbers, buffers) != TestPass) return TestFail; if (testHot(&cacheFromNumbers, buffers, numBuffers) != TestPass) return TestFail; /* * Test cache half the size of number of buffers used, the cache * is not pre-populated. */ V4L2BufferCache cacheHalf(numBuffers / 2); if (testRandom(&cacheHalf, buffers) != TestPass) return TestFail; if (testHot(&cacheHalf, buffers, numBuffers / 2) != TestPass) return TestFail; /* * Test that the isEmpty function reports the correct result at * various levels of cache fullness. */ if (testIsEmpty(buffers) != TestPass) return TestFail; return TestPass; } private: std::mt19937 generator_; }; } /* namespace */ TEST_REGISTER(BufferCacheTest)