forked from edubart/minicoro
-
Notifications
You must be signed in to change notification settings - Fork 1
Expand file tree
/
Copy pathminicoro.c
More file actions
57 lines (48 loc) · 1.42 KB
/
minicoro.c
File metadata and controls
57 lines (48 loc) · 1.42 KB
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
#define MINICORO_IMPL
#include "minicoro.h"
#include <assert.h>
mco_coro* mco_coro_init(void (*effectful_fn)(mco_coro* co), void* user_data) {
mco_coro* co;
mco_desc desc = mco_desc_init(effectful_fn, 0);
desc.user_data = user_data;
mco_result res = mco_create(&co, &desc);
assert(res == MCO_SUCCESS);
return co;
}
void* mco_coro_get_user_data(mco_coro* k) {
return mco_get_user_data(k);
}
char mco_coro_free(mco_coro* k) {
mco_result res = mco_destroy(k);
assert(res == MCO_SUCCESS);
// Ante's Cranelift codegen currently doesn't filter out Unit values.
// So since this function (and other void-returning functions) are thought
// to return unit values we still need to return one here.
return 0;
}
char mco_coro_is_suspended(mco_coro* k) {
return mco_status(k) == MCO_SUSPENDED;
}
char mco_coro_push(mco_coro* k, const void* arg, size_t size) {
mco_result res = mco_push(k, arg, size);
assert(res == MCO_SUCCESS);
return 0;
}
char mco_coro_pop(mco_coro* k, void* arg, size_t size) {
mco_result res = mco_pop(k, arg, size);
assert(res == MCO_SUCCESS);
return 0;
}
char mco_coro_suspend(mco_coro* k) {
mco_result res = mco_yield(k);
assert(res == MCO_SUCCESS);
return 0;
}
char mco_coro_resume(mco_coro* k) {
mco_result res = mco_resume(k);
assert(res == MCO_SUCCESS);
return 0;
}
mco_coro* mco_coro_running(void) {
return mco_running();
}