libcamera/jmondi/libcamera.git - Jacopo Mondi's clone of libcamera

diff options

author	Laurent Pinchart <laurent.pinchart@ideasonboard.com>	2023-11-26 05:11:50 +0200
committer	Laurent Pinchart <laurent.pinchart@ideasonboard.com>	2023-11-28 14:08:13 +0200
commit	64be677b11b70177f730cee6c787809e9e27c737 (patch)
tree	824ec4cf41a99f010f8f6b06e4dcfdec72f91e1a /test/log/meson.build
parent	74c5db6fd412a414ea3c38bbb5436849d4bd8d34 (diff)

Documentation: Fix list indentation

reStructuredText requires list items to be indented. Fix the few offenders in the documentation. Signed-off-by: Laurent Pinchart <laurent.pinchart@ideasonboard.com> Reviewed-by: Kieran Bingham <kieran.bingham@ideasonboard.com>

Diffstat (limited to 'test/log/meson.build')

0 files changed, 0 insertions, 0 deletions

/* SPDX-License-Identifier: GPL-2.0-or-later */ /* * Copyright (C) 2019, Google Inc. * * threads.cpp - Threads test */ #include <chrono> #include <iostream> #include <memory> #include <pthread.h> #include <thread> #include <time.h> #include <libcamera/base/thread.h> #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 CancelThread : public Thread { public: CancelThread(bool &cancelled) : cancelled_(cancelled) { } protected: void run() { cancelled_ = true; /* * Cancel the thread and call a guaranteed cancellation point * (nanosleep). */ pthread_cancel(pthread_self()); struct timespec req{ 0, 100*000*000 }; nanosleep(&req, nullptr); cancelled_ = false; } private: bool &cancelled_; }; 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> thread = std::make_unique<Thread>(); 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<DelayThread>(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<Thread>(); 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; } /* Test thread cleanup upon abnormal termination. */ bool cancelled = false; bool finished = false; thread = std::make_unique<CancelThread>(cancelled); thread->finished.connect(this, [&finished]() { finished = true; }); thread->start(); thread->exit(0); thread->wait(chrono::milliseconds(1000)); if (!cancelled || !finished) { cout << "Cleanup failed upon abnormal termination" << endl; return TestFail; } return TestPass; } void cleanup() { } }; TEST_REGISTER(ThreadTest)


context:
space:
mode: