GCC Code Coverage Report

Directory: src/gate/
File: src/gate/tests/gatecore_cpp_platform_test/test_coroutines.cpp
Date: 2025-12-12 23:40:09
Exec Total Coverage
Lines: 94 97 96.9%
Functions: 14 14 100.0%
Branches: 77 212 36.3%
Line Branch Exec Source
1 #include "gate/tests.hpp"
2 #include "gate/coroutines.hpp"
3
4 using namespace gate;
5
6 static gate_result_t co1(void* param);
7 static gate_result_t co2(void* param);
8 static gate_result_t co_main(void* param);
9
10 struct co_params
11 {
12 Coroutine::id_t id0;
13 Coroutine::id_t id1;
14 Coroutine::id_t id2;
15
16 int state;
17 };
18
19 1 static gate_result_t co1(void* param)
20 {
21 1 co_params* ptr = (co_params*)param;
22
1/2
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
 1 GATEXX_TEST_CHECK(ptr != NULL);
23
24
1/2
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
 1 GATEXX_TEST_CHECK_EQUAL(ptr->state, 0);
25 1 ptr->state = 1;
26
27 // interrupt -> switch to co2
28 1 Coroutine::switchTo(ptr->id2);
29
30 // continue from co_main
31
1/2
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
 1 GATEXX_TEST_CHECK_EQUAL(ptr->state, 3);
32 1 ptr->state = 4;
33
34 // interrupt -> switch to co_main
35 1 Coroutine::switchTo(ptr->id0);
36
37 // exit scenario:
38
1/2
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
 1 GATEXX_TEST_CHECK_EQUAL(ptr->state, 5);
39 1 return results::Ok;
40 }
41 1 static gate_result_t co2(void* param)
42 {
43 1 co_params* ptr = (co_params*)param;
44
1/2
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
 1 GATEXX_TEST_CHECK(ptr != NULL);
45
46 // come from co1
47
1/2
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
 1 GATEXX_TEST_CHECK_EQUAL(ptr->state, 1);
48 1 ptr->state = 2;
49
50 // interrupt -> switch co_main
51 1 Coroutine::switchTo(ptr->id0);
52
53 // exit scenario:
54
1/2
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
 1 GATEXX_TEST_CHECK_EQUAL(ptr->state, 5);
55 1 return results::Ok;
56 }
57 1 static gate_result_t co_main(void* param)
58 {
59 1 co_params* ptr = (co_params*)param;
60
1/2
✓ Branch 3 taken 1 times.
✗ Branch 4 not taken.
 1 GATEXX_TEST_CHECK(Coroutine::enabled());
61
1/2
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
 1 GATEXX_TEST_CHECK_EQUAL(ptr->state, 0);
62
63
2/8
✓ Branch 3 taken 1 times.
✗ Branch 4 not taken.
✓ Branch 6 taken 1 times.
✗ Branch 7 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
 1 GATEXX_TEST_CHECK_NOTHROW(ptr->id0 = Coroutine::getCurrent());
64
2/8
✓ Branch 3 taken 1 times.
✗ Branch 4 not taken.
✓ Branch 6 taken 1 times.
✗ Branch 7 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
 1 GATEXX_TEST_CHECK_NOTHROW(ptr->id1 = Coroutine::create(&co1, param));
65
2/8
✓ Branch 3 taken 1 times.
✗ Branch 4 not taken.
✓ Branch 6 taken 1 times.
✗ Branch 7 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
 1 GATEXX_TEST_CHECK_NOTHROW(ptr->id2 = Coroutine::create(&co2, param));
66
67
1/2
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
 1 GATEXX_TEST_CHECK_NOT_EQUAL(ptr->id0, ptr->id1);
68
1/2
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
 1 GATEXX_TEST_CHECK_NOT_EQUAL(ptr->id0, ptr->id2);
69
1/2
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
 1 GATEXX_TEST_CHECK_NOT_EQUAL(ptr->id1, ptr->id2);
70
71
1/2
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
 1 GATEXX_TEST_CHECK_EQUAL(ptr->state, 0);
72
73 // start co1
74 1 Coroutine::switchTo(ptr->id1);
75
76 // return from co2
77
1/2
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
 1 GATEXX_TEST_CHECK_EQUAL(ptr->state, 2);
78
79 1 ptr->state = 3;
80
81 // continue co1
82 1 Coroutine::switchTo(ptr->id1);
83
84 // return from co1
85
1/2
✓ Branch 2 taken 1 times.
✗ Branch 3 not taken.
 1 GATEXX_TEST_CHECK_EQUAL(ptr->state, 4);
86
87 // exit scenario:
88 1 ptr->state = 5;
89 1 return results::Ok;
90 }
91
92
93
2/7
✓ Branch 2 taken 1 times.
✓ Branch 3 taken 1 times.
✗ Branch 4 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
 6 GATEXX_TEST_UNIT(Coroutine)
94 {
95
2/4
✓ Branch 1 taken 1 times.
✗ Branch 2 not taken.
✗ Branch 3 not taken.
✓ Branch 4 taken 1 times.
 2 if (!Coroutine::supported())
96 {
97 ✗ return;
98 }
99
100
5/14
✓ Branch 1 taken 1 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 1 times.
✗ Branch 8 not taken.
✓ Branch 9 taken 1 times.
✗ Branch 10 not taken.
✓ Branch 12 taken 1 times.
✗ Branch 13 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
✗ Branch 18 not taken.
✗ Branch 19 not taken.
 2 GATEXX_TEST_CHECK(!Coroutine::enabled());
101
102 co_params params;
103 2 params.state = 0;
104
105
4/14
✓ Branch 1 taken 1 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 1 times.
✗ Branch 8 not taken.
✓ Branch 10 taken 1 times.
✗ Branch 11 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 17 not taken.
✗ Branch 18 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
 2 GATEXX_TEST_CHECK_NOTHROW(Coroutine::run(&co_main, &params));
106
107
4/12
✓ Branch 1 taken 1 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1 times.
✗ Branch 5 not taken.
✓ Branch 6 taken 1 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 1 times.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
 2 GATEXX_TEST_CHECK_EQUAL(params.state, 5);
108 }
109
110
111
112 class GATE_API_LOCAL Yielder : public IRunnable
113 {
114
115 public:
116 int yield_counter;
117
118 4 explicit Yielder(int counter) : yield_counter(counter)
119 {
120 4 }
121
122 14 virtual void run() override
123 {
124
2/2
✓ Branch 0 taken 10 times.
✓ Branch 1 taken 4 times.
 14 while (this->yield_counter-- > 0)
125 {
126
2/8
✓ Branch 3 taken 10 times.
✗ Branch 4 not taken.
✓ Branch 6 taken 10 times.
✗ Branch 7 not taken.
✗ Branch 10 not taken.
✗ Branch 11 not taken.
✗ Branch 13 not taken.
✗ Branch 14 not taken.
 10 GATEXX_TEST_CHECK_NOTHROW(Coroutine::yield());
127 }
128 4 }
129 };
130
131 class GATE_API_LOCAL Waiter : public IRunnable
132 {
133 public:
134 2 virtual void run() override
135 {
136 {
137 4 Yielder yielder(3);
138 2 Coroutine::id_t yield_job = 0;
139
4/12
✓ Branch 1 taken 2 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 2 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 2 times.
✗ Branch 8 not taken.
✓ Branch 10 taken 2 times.
✗ Branch 11 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 17 not taken.
✗ Branch 18 not taken.
 2 GATEXX_TEST_REQUIRE_NOTHROW(yield_job = Coroutine::create(yielder));
140
1/2
✓ Branch 1 taken 2 times.
✗ Branch 2 not taken.
 2 result_t result = Coroutine::await(yield_job);
141
4/12
✓ Branch 1 taken 2 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 2 times.
✗ Branch 5 not taken.
✓ Branch 6 taken 2 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 2 times.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
 2 GATEXX_TEST_CHECK_OK(result);
142
143 }
144
145 {
146
1/2
✓ Branch 1 taken 2 times.
✗ Branch 2 not taken.
 4 Ptr<IRunnable> code = new Yielder(2);
147 2 Coroutine::id_t yield_job = 0;
148
4/12
✓ Branch 1 taken 2 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 2 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 2 times.
✗ Branch 8 not taken.
✓ Branch 10 taken 2 times.
✗ Branch 11 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 17 not taken.
✗ Branch 18 not taken.
 2 GATEXX_TEST_REQUIRE_NOTHROW(yield_job = Coroutine::create(code));
149
1/2
✓ Branch 1 taken 2 times.
✗ Branch 2 not taken.
 2 result_t result = Coroutine::await(yield_job);
150
4/12
✓ Branch 1 taken 2 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 2 times.
✗ Branch 5 not taken.
✓ Branch 6 taken 2 times.
✗ Branch 7 not taken.
✓ Branch 9 taken 2 times.
✗ Branch 10 not taken.
✗ Branch 12 not taken.
✗ Branch 13 not taken.
✗ Branch 15 not taken.
✗ Branch 16 not taken.
 2 GATEXX_TEST_CHECK_OK(result);
151
152 }
153 2 }
154 };
155
156
2/7
✓ Branch 2 taken 1 times.
✓ Branch 3 taken 1 times.
✗ Branch 4 not taken.
✗ Branch 11 not taken.
✗ Branch 12 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
 6 GATEXX_TEST_UNIT(CoroutineWaitYield)
157 {
158
1/2
✗ Branch 1 not taken.
✓ Branch 2 taken 1 times.
 2 if (!Coroutine::supported())
159 {
160 ✗ return;
161 }
162
163 {
164
1/2
✓ Branch 1 taken 1 times.
✗ Branch 2 not taken.
 4 Ptr<IRunnable> waiter = new Waiter();
165
4/14
✓ Branch 1 taken 1 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 1 times.
✗ Branch 8 not taken.
✓ Branch 10 taken 1 times.
✗ Branch 11 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 17 not taken.
✗ Branch 18 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
 2 GATEXX_TEST_CHECK_NOTHROW(Coroutine::run(waiter));
166 }
167
168 {
169 2 Waiter waiter;
170
4/14
✓ Branch 1 taken 1 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 1 times.
✗ Branch 8 not taken.
✓ Branch 10 taken 1 times.
✗ Branch 11 not taken.
✗ Branch 14 not taken.
✗ Branch 15 not taken.
✗ Branch 17 not taken.
✗ Branch 18 not taken.
✗ Branch 20 not taken.
✗ Branch 21 not taken.
 2 GATEXX_TEST_CHECK_NOTHROW(Coroutine::run(waiter));
171 }
172 }
173
174 struct SleepParam
175 {
176 gate::bool_t cancel;
177 gate::int32_t previous;
178 gate::int32_t current;
179 result_t coresult;
180 };
181
182 1 static gate_result_t generate_worker(void* param)
183 {
184 1 SleepParam volatile* const ptr = static_cast<SleepParam volatile*>(param);
185
2/2
✓ Branch 0 taken 418629 times.
✓ Branch 1 taken 1 times.
 418630 while (!ptr->cancel)
186 {
187 418629 int64_t const next = ptr->previous + ptr->current;
188
2/2
✓ Branch 0 taken 38 times.
✓ Branch 1 taken 418591 times.
 418629 if (next < 100000000) // ensure our numbers will not overflow
189 {
190 38 ptr->previous = ptr->current;
191 38 ptr->current = next;
192 }
193 418629 Coroutine::yield();
194 }
195 1 return results::Ok;
196 }
197
198 1 static gate_result_t sleep_main(void* param)
199 {
200 1 SleepParam volatile* const ptr = static_cast<SleepParam*>(param);
201
202 1 Coroutine::id_t worker_id = Coroutine::create(&generate_worker, param);
203 1 Coroutine::sleep(500);
204
205 1 ptr->cancel = true;
206 1 ptr->coresult = Coroutine::await(worker_id);
207 1 return results::Ok;
208 }
209
210
211 3 GATEXX_TEST_UNIT(CoroutineSleep)
212 {
213 1 if (!Coroutine::supported())
214 {
215 ✗ return;
216 }
217
218 SleepParam volatile param;
219 1 param.cancel = false;
220 1 param.previous = 0;
221 1 param.current = 1;
222 1 param.coresult = results::Failed;
223
224 1 GATEXX_TEST_CHECK_NOTHROW(Coroutine::run(&sleep_main, const_cast<SleepParam*>(&param)));
225 1 GATEXX_TEST_CHECK_EQUAL(param.cancel, true);
226 1 GATEXX_TEST_CHECK(param.previous > 0);
227 1 GATEXX_TEST_CHECK(param.current > 1);
228 1 GATEXX_TEST_CHECK_EQUAL(param.coresult, results::Ok);
229 }
230