forked from microsoft/devicescript
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathimpl_fiber.c
More file actions
58 lines (49 loc) · 1.82 KB
/
Copy pathimpl_fiber.c
File metadata and controls
58 lines (49 loc) · 1.82 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
58
#include "devs_internal.h"
static devs_fiber_t *fiber_self(devs_ctx_t *ctx, value_t self) {
if (devs_handle_type(self) != DEVS_HANDLE_TYPE_FIBER) {
devs_throw_expecting_error(ctx, DEVS_BUILTIN_STRING_FIBER, self);
return NULL;
} else {
devs_fiber_t *f = devs_fiber_by_tag(ctx, devs_handle_value(self));
if (f == NULL)
devs_throw_range_error(ctx, "fiber already disposed");
return f;
}
}
value_t prop_DsFiber_id(devs_ctx_t *ctx, value_t self) {
devs_fiber_t *f = fiber_self(ctx, self);
return f ? devs_value_from_int(f->handle_tag) : devs_undefined;
}
value_t prop_DsFiber_suspended(devs_ctx_t *ctx, value_t self) {
devs_fiber_t *fib = fiber_self(ctx, self);
return fib ? devs_value_from_bool(fib->pkt_kind == DEVS_PKT_KIND_SUSPENDED) : devs_undefined;
}
static devs_fiber_t *devs_arg_self_fiber(devs_ctx_t *ctx) {
return fiber_self(ctx, devs_arg_self(ctx));
}
void meth1_DsFiber_resume(devs_ctx_t *ctx) {
devs_fiber_t *fib = devs_arg_self_fiber(ctx);
if (!fib)
return;
if (fib->pkt_kind != DEVS_PKT_KIND_SUSPENDED) {
devs_throw_range_error(ctx, "fiber not suspended");
return;
}
fib->ret_val = devs_arg(ctx, 0);
devs_fiber_set_wake_time(fib, 1); // 1 is in the past
}
void meth0_DsFiber_terminate(devs_ctx_t *ctx) {
devs_fiber_t *fib = devs_arg_self_fiber(ctx);
if (!fib)
return;
devs_fiber_termiante(fib);
}
void fun1_DeviceScript_suspend(devs_ctx_t *ctx) {
devs_fiber_t *fib = ctx->curr_fiber;
unsigned sleep = devs_compute_timeout(ctx, devs_arg(ctx, 0));
devs_fiber_sleep(ctx->curr_fiber, sleep);
fib->pkt_kind = DEVS_PKT_KIND_SUSPENDED;
}
void fun0_DsFiber_self(devs_ctx_t *ctx) {
devs_ret(ctx, devs_value_from_handle(DEVS_HANDLE_TYPE_FIBER, ctx->curr_fiber->handle_tag));
}