cxx-async 0.1.3

Simple interoperability between C++ coroutines and asynchronous Rust
Documentation 
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

/*
 * Copyright (c) Meta Platforms, Inc. and affiliates.
 *
 * This source code is licensed under both the MIT license found in the
 * LICENSE-MIT file in the root directory of this source tree and the Apache
 * License, Version 2.0 found in the LICENSE-APACHE file in the root directory
 * of this source tree.
 */

// cxx-async/src/cxx_async.cpp
//
// Glue functions for C++/Rust async interoperability.

#include "rust/cxx_async.h"
#include <cstdint>
#include <cstdlib>

namespace rust {
namespace async {

void cxxasync_assert(
    bool cond,
    const char* message,
    const char* file,
    int line) {
  if (!cond) {
    fprintf(stderr, "assertion failed: %s at %s:%d\n", message, file, line);
    abort();
  }
}

} // namespace async
} // namespace rust

extern "C" uint8_t* cxxasync_suspended_coroutine_clone(uint8_t* ptr) {
  return reinterpret_cast<uint8_t*>(
      reinterpret_cast<rust::async::SuspendedCoroutine*>(ptr)->add_ref());
}

extern "C" void cxxasync_suspended_coroutine_drop(uint8_t* address) {
  reinterpret_cast<rust::async::SuspendedCoroutine*>(address)->release();
}

extern "C" void cxxasync_suspended_coroutine_wake_by_ref(uint8_t* ptr) {
  rust::async::SuspendedCoroutine* coroutine =
      reinterpret_cast<rust::async::SuspendedCoroutine*>(ptr);
  if (wake_status_is_done(coroutine->wake())) {
    coroutine->resume();
  }
}

extern "C" void cxxasync_suspended_coroutine_wake(uint8_t* ptr) {
  cxxasync_suspended_coroutine_wake_by_ref(ptr);
  cxxasync_suspended_coroutine_drop(ptr);
}