cocotb_benches.dau_record_batch_aggregation_tb

Attributes

_ALIGN
_WIDTHS
_CODES

Functions

record_batch_aggregates_selected_middle_column(dut)
record_batch_first_column_min_with_trailing_columns_skipped(dut)
record_batch_count_outputs_uint64(dut)
record_batch_repeated_batches_reuse_module(dut)
record_batch_many_back_to_back_batches_reuse_module(dut)
record_batch_survives_input_and_output_stalls(dut)
record_batch_out_of_range_column_reports_descriptor_error(dut)
record_batch_non_int32_selected_column_reports_descriptor_error(dut)
record_batch_truncated_payload_reports_descriptor_error(dut)
_encode_batch(columns, opcode, *, input_column_id) → bytes
_align_up(value) → int
_words_from_bytes(data) → list[int]
_reset(dut) → None
_send_words(dut, words, *[, rng]) → None
_collect_output_words(dut, *[, rng]) → list[int]
_accept_success_status(dut, *[, rng]) → None
_expect_error_status(dut, code) → None
_result_logical_type(words) → int
_result_payload(words, *[, signed]) → int

Module Contents

cocotb_benches.dau_record_batch_aggregation_tb._ALIGN = 64

cocotb_benches.dau_record_batch_aggregation_tb._WIDTHS

cocotb_benches.dau_record_batch_aggregation_tb._CODES

async cocotb_benches.dau_record_batch_aggregation_tb.record_batch_aggregates_selected_middle_column(dut)

async cocotb_benches.dau_record_batch_aggregation_tb.record_batch_first_column_min_with_trailing_columns_skipped(dut)

async cocotb_benches.dau_record_batch_aggregation_tb.record_batch_count_outputs_uint64(dut)

async cocotb_benches.dau_record_batch_aggregation_tb.record_batch_repeated_batches_reuse_module(dut)

async cocotb_benches.dau_record_batch_aggregation_tb.record_batch_many_back_to_back_batches_reuse_module(dut)

async cocotb_benches.dau_record_batch_aggregation_tb.record_batch_survives_input_and_output_stalls(dut)

async cocotb_benches.dau_record_batch_aggregation_tb.record_batch_out_of_range_column_reports_descriptor_error(dut)

async cocotb_benches.dau_record_batch_aggregation_tb.record_batch_non_int32_selected_column_reports_descriptor_error(dut)

async cocotb_benches.dau_record_batch_aggregation_tb.record_batch_truncated_payload_reports_descriptor_error(dut)

cocotb_benches.dau_record_batch_aggregation_tb._encode_batch(columns: list[tuple[dau_core.stream.LogicalType, list[int]]], opcode: dau_core.stream.OperationCode, *, input_column_id: int) → bytes

cocotb_benches.dau_record_batch_aggregation_tb._align_up(value: int) → int

cocotb_benches.dau_record_batch_aggregation_tb._words_from_bytes(data: bytes) → list[int]

async cocotb_benches.dau_record_batch_aggregation_tb._reset(dut) → None

async cocotb_benches.dau_record_batch_aggregation_tb._send_words(dut, words: list[int], *, rng: random.Random | None = None) → None

async cocotb_benches.dau_record_batch_aggregation_tb._collect_output_words(dut, *, rng: random.Random | None = None) → list[int]

async cocotb_benches.dau_record_batch_aggregation_tb._accept_success_status(dut, *, rng: random.Random | None = None) → None

async cocotb_benches.dau_record_batch_aggregation_tb._expect_error_status(dut, code: dau_core.stream.StreamAggregationErrorCode) → None

cocotb_benches.dau_record_batch_aggregation_tb._result_logical_type(words: list[int]) → int

cocotb_benches.dau_record_batch_aggregation_tb._result_payload(words: list[int], *, signed: bool = False) → int