A pipe inbox's two lock-free MPMC rings: laps, record sums, reserve and commit
$ sexc add @ajax/mesh-abi-pipe-ring- total 3
- drwxr-xr-x-../
- drwxr-xr-x-Oct 27 01:45v/# 1 version
- drwxr-xr-x-Oct 27 01:45files/# the files of 0.1.0
- latest
- 0.1.0, published Oct 27 01:45 by ajax
- owners
- ajax
- license
- MIT
- dependencies
- @ajax/mesh-abi-words ^0.1.0, @ajax/mesh-abi-pipe-hash ^0.1.0, @ajax/mesh-check ^0.1.0
- dependents
- @ajax/mesh-abi, @ajax/mesh-abi-pipe, @ajax/mesh-manifest, @ajax/mesh-rt-ctx, @ajax/mesh-worker-ctx
- keywords
- mesh alphaos abi gpu pipe ring
- homepage
- https://github.com/thomasdavis/alpha-c-mesh/tree/main/packages/mesh-abi-pipe-ring
- repository
- https://github.com/thomasdavis/alpha-c-mesh
1# @ajax/mesh-abi-pipe-ring 2 3A pipe inbox's two lock-free MPMC rings: laps, record sums, reserve and commit. 4 5Part of the mesh contract: the memory, control, snapshot and peer protocols shared by meshd, its GPU 6programs (CUDA kernels, wasm lanes, native workers) and the tools. Every side compiles the same 7definitions, so an offset can never disagree. 8 9```c 10#include "mesh/abi/pipe_ring.h" 11``` 12 13## Ported from 14 15[alpha-rust-mesh](https://github.com/rsafier/alpha-rust-mesh) (Richard Safier, MIT): crates/mesh-abi/src/v2/pipe.rs (the ring: PI_*, Ring, Inbox, owner tags, shapes). 16 17Names: Rust's `NAME` is `MESH_NAME`; a constant of a Rust module `m` is `MESH_M_NAME` (unless it already starts with `M_`); a function `f` is `mesh_f` (`mesh_m_f`). Offsets that are `usize` in the Rust are plain integer constants or `size_t` results, `u32` constants carry a `u` suffix, `u64` use `UINT64_C`. 18 19## Device code 20 21The header is freestanding (`<stdint.h>`, `<stddef.h>`, `<stdbool.h>` only): it compiles for the host, `nvptx64-nvidia-cuda` and `wasm32`. Functions the Rust marks `const fn` are `static inline` here. 22 23## Tests 24 25- `tests/constants.c`: every constant against the value the Rust prints (11 checks) 26- `tests/golden.c`: its functions against 267 vectors computed by the Rust on the same inputs 27- `tests/ring.c`: the Rust's ring tests, one for one (shape_and_laps, fifo_full_and_wrap, mpmc_threads_lose_and_duplicate_nothing with C11 threads, position_is_in_the_sum, reserve_push_is_bounded, skip_dead_waits_for_the_front), over C11 atomics (`tests/mem.h`) 28 29## Differences 30 31`Option<u32>` results are a bool plus an out parameter; `skip_dead`'s `Option<bool>` is 1 / 0 / -1. `abandoned` takes a callback and a context instead of a closure. Methods are functions taking the ring or inbox first. 32 33## Licence 34 35MIT. See the repository's LICENSE.