1# pipesink: the pipe demo's checking sink, a native worker program (layout:
2# mesh_abi::v2::views::pipedemo, K_*).  It drains its inbox of `digest` records,
3# checks each against its own SHA-256 (mesh-ref) of the msg it rebuilds from the
4# seq, and histograms the latency since the source stamped the msg (1 us bins).
5# `task pipesink 2` refreshes the percentiles, `task pipesink 3` resets.
6name       = "pipesink"
7abi        = 6
8backends   = ["native"]
9view_bytes = 0x3d000
10inbox      = "0x4100:4096:48"
11inbox_type = "digest"
12nodes      = 2
13fanout     = 2
14policy     = "continuous"
15in_flight  = "free"
16counters   = ["records", "bad", "gpu", "cpu"]
17fields     = ["records:u32:0x0", "bad:u32:0x4", "gpu:u32:0x8", "cpu:u32:0xc", "max_us:u32:0x10", "p50_us:u32:0x14", "p90_us:u32:0x18", "p99_us:u32:0x1c", "empty:u32:0x20", "in_head:u32:0x4100", "in_full:u32:0x4104", "in_tail:u32:0x4140"]
18autostart  = false
19colocate_with = "pipehash"  # a fleet: on the member(s) pipehash runs on (pipes are single-machine)