cocotb_benches.dau_bucket_agg_chain_tb

Attributes

BUCKET_SHIFT
BUCKET_BITS
_MARKET

Functions

_bucket_rows(market)
bar_stage_matches_generic_aggregate(dut)
bar_stage_selects_to_time_bars(dut)
bar_stage_backpressure(dut)
_start(dut) → None
_run(dut, rows, *[, ready_pattern])
_field(lastfirst, minmax, total) → dau_core.operators.FieldStats
_decode(w) → dau_core.operators.GroupedFieldAggregate
_send_rows(dut, rows) → None
_collect_output(dut, ready_pattern)
_accept_success_status(dut) → int
_s32(value) → int
_s64(value) → int

Module Contents

cocotb_benches.dau_bucket_agg_chain_tb.BUCKET_SHIFT = 3

cocotb_benches.dau_bucket_agg_chain_tb.BUCKET_BITS = 16

cocotb_benches.dau_bucket_agg_chain_tb._MARKET = [(5, 100, 12, 3, 10, 12), (5, 103, 15, 2, 11, 13), (5, 112, 8, 4, 9, 11), (7, 100, 50, 7, 48,...

cocotb_benches.dau_bucket_agg_chain_tb._bucket_rows(market)

async cocotb_benches.dau_bucket_agg_chain_tb.bar_stage_matches_generic_aggregate(dut)

async cocotb_benches.dau_bucket_agg_chain_tb.bar_stage_selects_to_time_bars(dut)

async cocotb_benches.dau_bucket_agg_chain_tb.bar_stage_backpressure(dut)

async cocotb_benches.dau_bucket_agg_chain_tb._start(dut) → None

async cocotb_benches.dau_bucket_agg_chain_tb._run(dut, rows, *, ready_pattern=(1,))

cocotb_benches.dau_bucket_agg_chain_tb._field(lastfirst, minmax, total) → dau_core.operators.FieldStats

cocotb_benches.dau_bucket_agg_chain_tb._decode(w) → dau_core.operators.GroupedFieldAggregate

async cocotb_benches.dau_bucket_agg_chain_tb._send_rows(dut, rows) → None

async cocotb_benches.dau_bucket_agg_chain_tb._collect_output(dut, ready_pattern)

async cocotb_benches.dau_bucket_agg_chain_tb._accept_success_status(dut) → int

cocotb_benches.dau_bucket_agg_chain_tb._s32(value: int) → int

cocotb_benches.dau_bucket_agg_chain_tb._s64(value: int) → int