wit-bindgen-cli 0.57.1

CLI tool to generate bindings for WIT documents and the component model. 
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

//@ args = '--rename my:test/i=test --async=-run'
//@ wasmtime-flags = '-Wcomponent-model-async'

#include <assert.h>
#include <runner.h>

void exports_runner_run() {
  // Call an import and cancel it.
  {
    test_future_void_writer_t writer;
    test_future_void_t reader = test_future_void_new(&writer);
    runner_subtask_status_t status = test_pending_import(reader);
    assert(RUNNER_SUBTASK_STATE(status) == RUNNER_SUBTASK_STARTED);
    runner_subtask_t subtask = RUNNER_SUBTASK_HANDLE(status);
    assert(subtask != 0);
    status = runner_subtask_cancel(subtask);
    assert(RUNNER_SUBTASK_STATE(status) == RUNNER_SUBTASK_RETURNED_CANCELLED);
    assert(RUNNER_SUBTASK_HANDLE(status) == 0);
    runner_subtask_drop(subtask);

    runner_waitable_status_t status2 = test_future_void_write(writer);
    assert(RUNNER_WAITABLE_STATE(status2) == RUNNER_WAITABLE_DROPPED);
    assert(RUNNER_WAITABLE_COUNT(status2) == 0);
    test_future_void_drop_writable(writer);
  }

  // One import in "started", one in "starting", then cancel both.
  {
    test_future_void_writer_t writer1;
    test_future_void_t reader1 = test_future_void_new(&writer1);
    test_future_void_writer_t writer2;
    test_future_void_t reader2 = test_future_void_new(&writer2);

    // start up one task, it'll be in "STARTED"
    runner_subtask_status_t status = test_pending_import(reader1);
    assert(RUNNER_SUBTASK_STATE(status) == RUNNER_SUBTASK_STARTED);
    runner_subtask_t subtask1 = RUNNER_SUBTASK_HANDLE(status);
    assert(subtask1 != 0);

    // Start up a second task after setting the backpressure flag, forcing it
    // to be in the "STARTING" state.
    test_backpressure_set(true);
    status = test_pending_import(reader2);
    assert(RUNNER_SUBTASK_STATE(status) == RUNNER_SUBTASK_STARTING);
    runner_subtask_t subtask2 = RUNNER_SUBTASK_HANDLE(status);
    assert(subtask2 != 0);

    // Now cancel both tasks, witnessing slightly different cancellation codes.
    status = runner_subtask_cancel(subtask1);
    assert(RUNNER_SUBTASK_STATE(status) == RUNNER_SUBTASK_RETURNED_CANCELLED);
    assert(RUNNER_SUBTASK_HANDLE(status) == 0);
    runner_subtask_drop(subtask1);

    status = runner_subtask_cancel(subtask2);
    assert(RUNNER_SUBTASK_STATE(status) == RUNNER_SUBTASK_STARTED_CANCELLED);
    assert(RUNNER_SUBTASK_HANDLE(status) == 0);
    runner_subtask_drop(subtask2);

    // We still own the readable end of `reader2` and `writer2` since the
    // subtask didn't actually start, so drop it here.
    test_future_void_drop_readable(reader2);

    // Assert both read ends are dropped from the POV of the write ends
    runner_waitable_status_t status2 = test_future_void_write(writer1);
    assert(RUNNER_WAITABLE_STATE(status2) == RUNNER_WAITABLE_DROPPED);
    assert(RUNNER_WAITABLE_COUNT(status2) == 0);
    test_future_void_drop_writable(writer1);

    status2 = test_future_void_write(writer2);
    assert(RUNNER_WAITABLE_STATE(status2) == RUNNER_WAITABLE_DROPPED);
    assert(RUNNER_WAITABLE_COUNT(status2) == 0);
    test_future_void_drop_writable(writer2);

    // reset the backpressure flag
    test_backpressure_set(false);
  }
}