/* SPDX-License-Identifier: GPL-2.0-or-later */ /* * Copyright (C) 2019, Google Inc. * * threads.cpp - Threads test */ #include #include #include #include #include #include "test.h" using namespace std; using namespace libcamera; class DelayThread : public Thread { public: DelayThread(chrono::steady_clock::duration duration) : duration_(duration) { } protected: void run() { this_thread::sleep_for(duration_); } private: chrono::steady_clock::duration duration_; }; class ThreadTest : public Test { protected: int init() { return 0; } int run() { /* Test Thread() retrieval for the main thread. */ Thread *mainThread = Thread::current(); if (!mainThread) { cout << "Thread::current() failed to main thread" << endl; return TestFail; } if (!mainThread->isRunning()) { cout << "Main thread is not running" << endl; return TestFail; } /* Test starting the main thread, the test shall not crash. */ mainThread->start(); /* Test the running state of a custom thread. */ std::unique_ptr thread = std::make_unique(); thread->start(); if (!thread->isRunning()) { cout << "Thread is not running after being started" << endl; return TestFail; } thread->exit(0); thread->wait(); if (thread->isRunning()) { cout << "Thread is still running after finishing" << endl; return TestFail; } /* Test waiting for completion with a timeout. */ thread = std::make_unique(chrono::milliseconds(500)); thread->start(); thread->exit(0); bool timeout = !thread->wait(chrono::milliseconds(100)); if (!timeout) { cout << "Waiting for thread didn't time out" << endl; return TestFail; } timeout = !thread->wait(chrono::milliseconds(1000)); if (timeout) { cout << "Waiting for thread timed out" << endl; return TestFail; } /* Test waiting on a thread that isn't running. */ thread = std::make_unique(); timeout = !thread->wait(); if (timeout) { cout << "Waiting for non-started thread timed out" << endl; return TestFail; } thread->start(); thread->exit(0); thread->wait(); timeout = !thread->wait(); if (timeout) { cout << "Waiting for already stopped thread timed out" << endl; return TestFail; } return TestPass; } void cleanup() { } }; TEST_REGISTER(ThreadTest) camera_file.h?h=v0.3.1'>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

/* SPDX-License-Identifier: LGPL-2.1-or-later */
/*
 * Copyright (C) 2020, Google Inc.
 *
 * V4L2 compatibility camera file information
 */

#pragma once

#include <string>

#include <linux/videodev2.h>

class V4L2CameraProxy;

class V4L2CameraFile
{
public:
	V4L2CameraFile(int dirfd, const char *path, int efd, bool nonBlocking,
		       V4L2CameraProxy *proxy);
	~V4L2CameraFile();

	V4L2CameraProxy *proxy() const { return proxy_; }

	bool nonBlocking() const { return nonBlocking_; }
	int efd() const { return efd_; }

	enum v4l2_priority priority() const { return priority_; }
	void setPriority(enum v4l2_priority priority) { priority_ = priority; }

	const std::string &description() const;

private:
	V4L2CameraProxy *proxy_;

	std::string description_;
	bool nonBlocking_;
	int efd_;
	enum v4l2_priority priority_;
};
generated by cgit v1.2.1 (git 2.18.0) at 2024-12-24 21:36:02 +0000