skip to content
==> program.toml <==
1# pipesrc-n: the pipe demo's CPU source as a native worker program (pipesrc's twin;
2# layout: mesh_abi::v2::views::pipedemo, S_*).  Mode 0: `msg`s into pipehash's inbox;
3# mode 1: `digest`s hashed here straight into a sink.
4# `task pipesrc-n 2 <mode>`, `3 <batch>`, `4 <interval us>`, `5` resets.
5name       = "pipesrc-n"
6abi        = 6
7backends   = ["native"]
8view_bytes = 0x100
9nodes      = 1
10policy     = "continuous"
11feeds      = ["pipehash:msg", "pipesink:digest", "pipesink-w:digest"]
12counters   = ["sent", "full", "gone", ""]
13fields     = ["mode:u32:0x0", "batch:u32:0x4", "interval_us:u32:0x8", "next_seq:u32:0xc", "sent:u32:0x10", "full:u32:0x14", "gone:u32:0x18", "dst:u32:0x28"]
14autostart  = false
15colocate_with = "pipehash"  # a fleet: on the member(s) pipehash runs on (pipes are single-machine)