27aff949fb
Move the functionality for the following components to the new base support library: - BoundMethod - EventDispatcher - EventDispatcherPoll - Log - Message - Object - Signal - Semaphore - Thread - Timer While it would be preferable to see these split to move one component per commit, these components are all interdependent upon each other, which leaves us with one big change performing the move for all of them. Reviewed-by: Hirokazu Honda <hiroh@chromium.org> Reviewed-by: Paul Elder <paul.elder@ideasonboard.com> Signed-off-by: Kieran Bingham <kieran.bingham@ideasonboard.com>
126 lines
2.2 KiB
C++
126 lines
2.2 KiB
C++
/* SPDX-License-Identifier: GPL-2.0-or-later */
|
|
/*
|
|
* Copyright (C) 2019, Google Inc.
|
|
*
|
|
* signal-threads.cpp - Cross-thread signal delivery test
|
|
*/
|
|
|
|
#include <chrono>
|
|
#include <iostream>
|
|
#include <thread>
|
|
|
|
#include <libcamera/base/message.h>
|
|
#include <libcamera/base/thread.h>
|
|
#include <libcamera/base/utils.h>
|
|
|
|
#include "test.h"
|
|
|
|
using namespace std;
|
|
using namespace libcamera;
|
|
|
|
class SignalReceiver : public Object
|
|
{
|
|
public:
|
|
enum Status {
|
|
NoSignal,
|
|
InvalidThread,
|
|
SignalReceived,
|
|
};
|
|
|
|
SignalReceiver()
|
|
: status_(NoSignal)
|
|
{
|
|
}
|
|
|
|
Status status() const { return status_; }
|
|
int value() const { return value_; }
|
|
void reset()
|
|
{
|
|
status_ = NoSignal;
|
|
value_ = 0;
|
|
}
|
|
|
|
void slot(int value)
|
|
{
|
|
if (Thread::current() != thread())
|
|
status_ = InvalidThread;
|
|
else
|
|
status_ = SignalReceived;
|
|
|
|
value_ = value;
|
|
}
|
|
|
|
private:
|
|
Status status_;
|
|
int value_;
|
|
};
|
|
|
|
class SignalThreadsTest : public Test
|
|
{
|
|
protected:
|
|
int run()
|
|
{
|
|
SignalReceiver receiver;
|
|
signal_.connect(&receiver, &SignalReceiver::slot);
|
|
|
|
/* Test that a signal is received in the main thread. */
|
|
signal_.emit(0);
|
|
|
|
switch (receiver.status()) {
|
|
case SignalReceiver::NoSignal:
|
|
cout << "No signal received for direct connection" << endl;
|
|
return TestFail;
|
|
case SignalReceiver::InvalidThread:
|
|
cout << "Signal received in incorrect thread "
|
|
"for direct connection" << endl;
|
|
return TestFail;
|
|
default:
|
|
break;
|
|
}
|
|
|
|
/*
|
|
* Move the object to a thread and verify that the signal is
|
|
* correctly delivered, with the correct data.
|
|
*/
|
|
receiver.reset();
|
|
receiver.moveToThread(&thread_);
|
|
|
|
thread_.start();
|
|
|
|
signal_.emit(42);
|
|
|
|
this_thread::sleep_for(chrono::milliseconds(100));
|
|
|
|
switch (receiver.status()) {
|
|
case SignalReceiver::NoSignal:
|
|
cout << "No signal received for message connection" << endl;
|
|
return TestFail;
|
|
case SignalReceiver::InvalidThread:
|
|
cout << "Signal received in incorrect thread "
|
|
"for message connection" << endl;
|
|
return TestFail;
|
|
default:
|
|
break;
|
|
}
|
|
|
|
if (receiver.value() != 42) {
|
|
cout << "Signal received with incorrect value" << endl;
|
|
return TestFail;
|
|
}
|
|
|
|
return TestPass;
|
|
}
|
|
|
|
void cleanup()
|
|
{
|
|
thread_.exit(0);
|
|
thread_.wait();
|
|
}
|
|
|
|
private:
|
|
Thread thread_;
|
|
|
|
Signal<int> signal_;
|
|
};
|
|
|
|
TEST_REGISTER(SignalThreadsTest)
|