blob: 52b0de295b3dcc9325a582b7ee63ffaed3d23f69 (
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
|
#include <mbgl/actor/actor.hpp>
#include <mbgl/util/default_thread_pool.hpp>
#include <mbgl/test/util.hpp>
#include <future>
using namespace mbgl;
TEST(ActorRef, CanOutliveActor) {
// An ActorRef can outlive its actor. Doing does not extend the actor's lifetime.
// Sending a message to an ActorRef whose actor has died is a no-op.
struct Test {
bool& died;
Test(ActorRef<Test>, bool& died_)
: died(died_) {
}
~Test() {
died = true;
}
void receive() {
FAIL();
}
};
ThreadPool pool { 1 };
bool died = false;
ActorRef<Test> test = [&] () {
return Actor<Test>(pool, std::ref(died)).self();
}();
EXPECT_TRUE(died);
test.invoke(&Test::receive);
}
TEST(ActorRef, Ask) {
// Ask returns a Future eventually returning the result
struct Test {
Test(ActorRef<Test>) {}
int gimme() {
return 20;
}
int echo(int i) {
return i;
}
};
ThreadPool pool { 1 };
Actor<Test> actor(pool);
ActorRef<Test> ref = actor.self();
EXPECT_EQ(20, ref.ask(&Test::gimme).get());
EXPECT_EQ(30, ref.ask(&Test::echo, 30).get());
}
TEST(ActorRef, AskOnDestroyedActor) {
// Tests behavior when calling ask() after the
// Actor has gone away. Should set a exception_ptr.
struct Test {
bool& died;
Test(ActorRef<Test>, bool& died_) : died(died_) {}
~Test() {
died = true;
}
int receive() {
return 1;
}
};
bool died = false;
ThreadPool pool { 1 };
auto actor = std::make_unique<Actor<Test>>(pool, died);
ActorRef<Test> ref = actor->self();
actor.reset();
EXPECT_TRUE(died);
auto result = ref.ask(&Test::receive);
EXPECT_ANY_THROW(result.get());
}
|
