cocotb_benches.dau_hero_datapath_tb
===================================

.. py:module:: cocotb_benches.dau_hero_datapath_tb


Attributes
----------

.. autoapisummary::

   cocotb_benches.dau_hero_datapath_tb.BUCKET_SHIFT
   cocotb_benches.dau_hero_datapath_tb.BUCKET_BITS
   cocotb_benches.dau_hero_datapath_tb.WINDOW
   cocotb_benches.dau_hero_datapath_tb._STREAM


Functions
---------

.. autoapisummary::

   cocotb_benches.dau_hero_datapath_tb._merge
   cocotb_benches.dau_hero_datapath_tb._golden
   cocotb_benches.dau_hero_datapath_tb.datapath_matches_golden
   cocotb_benches.dau_hero_datapath_tb.datapath_backpressure
   cocotb_benches.dau_hero_datapath_tb.datapath_with_tolerance
   cocotb_benches.dau_hero_datapath_tb.datapath_large_symbol_decodes_correctly
   cocotb_benches.dau_hero_datapath_tb._start
   cocotb_benches.dau_hero_datapath_tb._run
   cocotb_benches.dau_hero_datapath_tb._decode
   cocotb_benches.dau_hero_datapath_tb._send_records
   cocotb_benches.dau_hero_datapath_tb._collect_output
   cocotb_benches.dau_hero_datapath_tb._accept_success_status
   cocotb_benches.dau_hero_datapath_tb._s32
   cocotb_benches.dau_hero_datapath_tb._s64


Module Contents
---------------

.. py:data:: BUCKET_SHIFT
   :value: 3


.. py:data:: BUCKET_BITS
   :value: 16


.. py:data:: WINDOW
   :value: 3


.. py:data:: _STREAM

.. py:function:: _merge(quotes, trades)

.. py:function:: _golden(quotes, trades, *, tolerance=None)

   The full workflow through the same generic stages the datapath composes:
   align → derive(signed_volume) → bucket+generic-aggregator → OHLCV select →
   roll over bar closes per symbol. Returns (symbol, count, total, total_sq).


.. py:function:: datapath_matches_golden(dut)
   :async:


.. py:function:: datapath_backpressure(dut)
   :async:


.. py:function:: datapath_with_tolerance(dut)
   :async:


.. py:function:: datapath_large_symbol_decodes_correctly(dut)
   :async:


.. py:function:: _start(dut) -> None
   :async:


.. py:function:: _run(dut, records, *, ready_pattern=(1, ), tolerance=None)
   :async:


.. py:function:: _decode(w)

.. py:function:: _send_records(dut, records) -> None
   :async:


.. py:function:: _collect_output(dut, ready_pattern)
   :async:


.. py:function:: _accept_success_status(dut) -> int
   :async:


.. py:function:: _s32(value: int) -> int

.. py:function:: _s64(value: int) -> int