nx_pipeline_test.nx
buildroot/runtime/nx_pipeline_test.nx
about
nx_pipeline_test.nx -- 3-stage pipeline stress + backpressure check.
Pipeline: input -> [stage 0: x*2] -> [stage 1: x+1] -> [stage 2: x*10]
Each stage runs n_workers parallel workers. Output of input i is
((i*2)+1)*10 = 20i + 10.
Push 100 inputs, drain 100 outputs, verify EVERY output's value is
in the expected set {20i + 10 | i in 0..99}. Don't require FIFO
across stages because parallel workers within a stage may reorder.
dependencies 6 imports · 0 importers
imports: nx_kernel_v2.nxnx_log.nxnx_atom.nxnx_thread_pool.nxnx_pipeline.nxnx_hw.nx
imported by: nobody (leaf or entry point)
call flow from main pre-order; caps 40 nodes / depth 6 declared; ↻ = already shown
structs
| none |
consts
| 18 | const N_INPUTS: i64 = 64 |
functions
| 20 | func stage0_double(x: i64) -> i64 { return x * 2 } |
| 21 | func stage1_add1(x: i64) -> i64 { return x + 1 } |
| 22 | func stage2_x10(x: i64) -> i64 { return x * 10 } |
| 24 | func main() -> nx_exit |