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
|
#include "memory.h"
#include "fiber.h"
#include "unit.h"
static int
noop_f(va_list ap)
{
return 0;
}
static int
cancel_f(va_list ap)
{
fiber_set_cancellable(true);
while (true) {
fiber_sleep(0.001);
fiber_testcancel();
}
return 0;
}
static int
exception_f(va_list ap)
{
tnt_raise(OutOfMemory, 42, "allocator", "exception");
return 0;
}
static int
no_exception_f(va_list ap)
{
try {
tnt_raise(OutOfMemory, 42, "allocator", "exception");
} catch (Exception *e) {
;
}
return 0;
}
static int
cancel_dead_f(va_list ap)
{
note("cancel dead has started");
fiber_set_cancellable(true);
tnt_raise(OutOfMemory, 42, "allocator", "exception");
return 0;
}
static void
fiber_join_test()
{
header();
struct fiber *fiber = fiber_new_xc("join", noop_f);
fiber_set_joinable(fiber, true);
fiber_wakeup(fiber);
fiber_join(fiber);
fiber = fiber_new_xc("cancel", cancel_f);
fiber_set_joinable(fiber, true);
fiber_wakeup(fiber);
fiber_sleep(0);
fiber_cancel(fiber);
fiber_join(fiber);
fiber = fiber_new_xc("exception", exception_f);
fiber_set_joinable(fiber, true);
fiber_wakeup(fiber);
try {
if (fiber_join(fiber) != 0)
diag_raise();
fail("exception not raised", "");
} catch (Exception *e) {
note("exception propagated");
}
fputs("#gh-1238: log uncaught errors\n", stderr);
fiber = fiber_new_xc("exception", exception_f);
fiber_wakeup(fiber);
/*
* A fiber which is using exception should not
* push them up the stack.
*/
fiber = fiber_new_xc("no_exception", no_exception_f);
fiber_set_joinable(fiber, true);
fiber_wakeup(fiber);
fiber_join(fiber);
/*
* Trying to cancel a dead joinable cancellable fiber lead to
* a crash, because cancel would try to schedule it.
*/
fiber = fiber_new_xc("cancel_dead", cancel_dead_f);
fiber_set_joinable(fiber, true);
fiber_wakeup(fiber);
/** Let the fiber schedule */
fiber_wakeup(fiber());
fiber_yield();
note("by this time the fiber should be dead already");
fiber_cancel(fiber);
fiber_join(fiber);
footer();
}
static int
main_f(va_list ap)
{
fiber_join_test();
ev_break(loop(), EVBREAK_ALL);
return 0;
}
int main()
{
memory_init();
fiber_init(fiber_cxx_invoke);
struct fiber *main = fiber_new_xc("main", main_f);
fiber_wakeup(main);
ev_run(loop(), 0);
fiber_free();
memory_free();
return 0;
}
|
