blob: c4789c83a178e25790fbc47731f10419c696c704 (
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
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
|
/* SPDX-License-Identifier: GPL-2.0-or-later */
/*
* Copyright (C) 2019, Google Inc.
*
* Cross-thread signal delivery test
*/
#include <chrono>
#include <iostream>
#include <thread>
#include <libcamera/base/message.h>
#include <libcamera/base/object.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 init()
{
receiver_ = new SignalReceiver();
signal_.connect(receiver_, &SignalReceiver::slot);
return TestPass;
}
int run()
{
/* 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()
{
receiver_->deleteLater();
thread_.exit(0);
thread_.wait();
}
private:
SignalReceiver *receiver_;
Thread thread_;
Signal<int> signal_;
};
TEST_REGISTER(SignalThreadsTest)
|
