==> 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)