review: Use XLSChannel semantics

Signed-off-by: Robert Winkler <[email protected]>

Author: rw1nkler

xls/examples/cocotb/cocotb_running_counter.py

@@ -15,7 +15,7 @@
 import cocotb
 
 from cocotb.clock import Clock
-from cocotb.triggers import Event, ClockCycles
+from cocotb.triggers import Event, ClockCycles, RisingEdge
 from cocotb.binary import BinaryValue
 
 from cocotb_bus.scoreboard import Scoreboard
@@ -45,11 +45,17 @@ def terminate_cb(transaction):
             terminate.set()
 
     monitor.add_callback(terminate_cb)
-    monitor.bus.rdy.setimmediatevalue(1)
-
     return (clock, driver, terminate)
 
 
+@cocotb.coroutine
+async def recv(dut):
+    dut.running_counter__cnt_s_rdy.setimmediatevalue(0)
+    while True:
+        await RisingEdge(dut.clk)
+        dut.running_counter__cnt_s_rdy.value = dut.running_counter__cnt_s_vld.value
+
+
 @cocotb.coroutine
 async def reset(clk, rst, cycles=1):
     rst.setimmediatevalue(1)
@@ -65,6 +71,8 @@ async def counter_test(dut):
     (clock, driver, terminate) = init_sim(dut, data_to_send, data_to_recv)
 
     cocotb.start_soon(clock.start())
+    cocotb.start_soon(recv(dut))
+
     await reset(dut.clk, dut.rst, 10)
     await driver.write(data_to_send)
     await terminate.wait()

xls/simulation/cocotb/cocotb_xls.py

@@ -63,6 +63,6 @@ def __init__(
     async def _monitor_recv(self) -> None:
         while True:
             await RisingEdge(self.clock)
-            if self.bus.vld.value and self.bus.rdy.value:
+            if self.bus.rdy.value:
                 vec = self.bus.data.value
                 self._recv(vec)