nx_circulation.nx
buildroot/runtime/nx_circulation.nx
about
nx_circulation.nx -- reliable byte stream with flow control (TCP class).
Biology: cardiovascular circulation regulates blood flow via heart
rate + vessel diameter + smooth-muscle tone. Substrate: reliable
ordered byte stream with backpressure (window-based flow control).
dependencies 2 imports · 1 importers
imports: nx_syscalls.nxnx_tier.nx
imported by: nx_circulation_test.nx
structs
| 16 | struct NxStream |
consts
| 10 | const NX_CR_V_OK: nx_int = 0 |
| 11 | const NX_CR_V_BLOCKED: nx_int = 1 // would exceed window |
| 12 | const NX_CR_V_CLOSED: nx_int = 2 |
| 13 | const NX_CR_V_NULL: nx_int = 3 |
| 14 | const NX_CR_V_N: nx_int = 4 |
| 26 | const NX_CR_BYTES: nx_int = 48 |
| 27 | const NX_CR_STATE_OPEN: nx_int = 0 |
| 28 | const NX_CR_STATE_HALF_CLOSED: nx_int = 1 |
| 29 | const NX_CR_STATE_CLOSED: nx_int = 2 |
functions
| 31 | func nx_cr_v_is_valid(v: nx_int) -> nx_int called by 1: main |
| 37 | func nx_cr_stream_new(stream_id: nx_int, window_size: nx_size) -> *NxStream |
| 51 | func nx_cr_send(s: *NxStream, bytes: nx_size) -> nx_int called by 1: main |
| 61 | func nx_cr_ack(s: *NxStream, bytes: nx_size) -> nx_int called by 1: main |
| 69 | func nx_cr_receive(s: *NxStream, bytes: nx_size) -> nx_int called by 1: main |
| 76 | func nx_cr_available_window(s: *NxStream) -> nx_size called by 1: main |
| 82 | func nx_cr_close(s: *NxStream) -> nx_int called by 1: main |