diff --git a/cocotbext/axi/axi_master.py b/cocotbext/axi/axi_master.py index ef95f1b..56bb482 100644 --- a/cocotbext/axi/axi_master.py +++ b/cocotbext/axi/axi_master.py @@ -124,7 +124,7 @@ class TagContext: def _start(self): if self._cr is None: - self._cr = cocotb.fork(self._process_queue()) + self._cr = cocotb.start_soon(self._process_queue()) def _flush(self): flushed_cmds = [] @@ -392,9 +392,9 @@ class AxiMasterWrite(Region, Reset): else: self.log.info("Reset de-asserted") if self._process_write_cr is None: - self._process_write_cr = cocotb.fork(self._process_write()) + self._process_write_cr = cocotb.start_soon(self._process_write()) if self._process_write_resp_cr is None: - self._process_write_resp_cr = cocotb.fork(self._process_write_resp()) + self._process_write_resp_cr = cocotb.start_soon(self._process_write_resp()) async def _process_write(self): while True: @@ -737,9 +737,9 @@ class AxiMasterRead(Region, Reset): else: self.log.info("Reset de-asserted") if self._process_read_cr is None: - self._process_read_cr = cocotb.fork(self._process_read()) + self._process_read_cr = cocotb.start_soon(self._process_read()) if self._process_read_resp_cr is None: - self._process_read_resp_cr = cocotb.fork(self._process_read_resp()) + self._process_read_resp_cr = cocotb.start_soon(self._process_read_resp()) async def _process_read(self): while True: diff --git a/cocotbext/axi/axi_slave.py b/cocotbext/axi/axi_slave.py index ce4b330..06f931c 100644 --- a/cocotbext/axi/axi_slave.py +++ b/cocotbext/axi/axi_slave.py @@ -102,7 +102,7 @@ class AxiSlaveWrite(Reset): else: self.log.info("Reset de-asserted") if self._process_write_cr is None: - self._process_write_cr = cocotb.fork(self._process_write()) + self._process_write_cr = cocotb.start_soon(self._process_write()) async def _process_write(self): while True: @@ -259,7 +259,7 @@ class AxiSlaveRead(Reset): else: self.log.info("Reset de-asserted") if self._process_read_cr is None: - self._process_read_cr = cocotb.fork(self._process_read()) + self._process_read_cr = cocotb.start_soon(self._process_read()) async def _process_read(self): while True: diff --git a/cocotbext/axi/axil_master.py b/cocotbext/axi/axil_master.py index 3c5e7de..d3b07ee 100644 --- a/cocotbext/axi/axil_master.py +++ b/cocotbext/axi/axil_master.py @@ -220,9 +220,9 @@ class AxiLiteMasterWrite(Region, Reset): else: self.log.info("Reset de-asserted") if self._process_write_cr is None: - self._process_write_cr = cocotb.fork(self._process_write()) + self._process_write_cr = cocotb.start_soon(self._process_write()) if self._process_write_resp_cr is None: - self._process_write_resp_cr = cocotb.fork(self._process_write_resp()) + self._process_write_resp_cr = cocotb.start_soon(self._process_write_resp()) async def _process_write(self): while True: @@ -437,9 +437,9 @@ class AxiLiteMasterRead(Region, Reset): else: self.log.info("Reset de-asserted") if self._process_read_cr is None: - self._process_read_cr = cocotb.fork(self._process_read()) + self._process_read_cr = cocotb.start_soon(self._process_read()) if self._process_read_resp_cr is None: - self._process_read_resp_cr = cocotb.fork(self._process_read_resp()) + self._process_read_resp_cr = cocotb.start_soon(self._process_read_resp()) async def _process_read(self): while True: diff --git a/cocotbext/axi/axil_slave.py b/cocotbext/axi/axil_slave.py index 5fb875b..063aa12 100644 --- a/cocotbext/axi/axil_slave.py +++ b/cocotbext/axi/axil_slave.py @@ -97,7 +97,7 @@ class AxiLiteSlaveWrite(Reset): else: self.log.info("Reset de-asserted") if self._process_write_cr is None: - self._process_write_cr = cocotb.fork(self._process_write()) + self._process_write_cr = cocotb.start_soon(self._process_write()) async def _process_write(self): while True: @@ -210,7 +210,7 @@ class AxiLiteSlaveRead(Reset): else: self.log.info("Reset de-asserted") if self._process_read_cr is None: - self._process_read_cr = cocotb.fork(self._process_read()) + self._process_read_cr = cocotb.start_soon(self._process_read()) async def _process_read(self): while True: diff --git a/cocotbext/axi/axis.py b/cocotbext/axi/axis.py index d43d274..ea3e607 100644 --- a/cocotbext/axi/axis.py +++ b/cocotbext/axi/axis.py @@ -366,7 +366,7 @@ class AxiStreamBase(Reset): else: self.log.info("Reset de-asserted") if self._run_cr is None: - self._run_cr = cocotb.fork(self._run()) + self._run_cr = cocotb.start_soon(self._run()) async def _run(self): raise NotImplementedError() @@ -388,7 +388,7 @@ class AxiStreamPause: self._pause_generator = generator if self._pause_generator is not None: - self._pause_cr = cocotb.fork(self._run_pause()) + self._pause_cr = cocotb.start_soon(self._run_pause()) def clear_pause_generator(self): self.set_pause_generator(None) diff --git a/cocotbext/axi/reset.py b/cocotbext/axi/reset.py index dca90aa..dd5f59f 100644 --- a/cocotbext/axi/reset.py +++ b/cocotbext/axi/reset.py @@ -33,7 +33,7 @@ class Reset: self._reset_state = True if reset_signal is not None: - cocotb.fork(self._run_reset(reset_signal, bool(active_level))) + cocotb.start_soon(self._run_reset(reset_signal, bool(active_level))) self._update_reset() diff --git a/cocotbext/axi/stream.py b/cocotbext/axi/stream.py index 9f57337..de2a3b6 100644 --- a/cocotbext/axi/stream.py +++ b/cocotbext/axi/stream.py @@ -153,7 +153,7 @@ class StreamBase(Reset): else: self.log.info("Reset de-asserted") if self._run_cr is None: - self._run_cr = cocotb.fork(self._run()) + self._run_cr = cocotb.start_soon(self._run()) async def _run(self): raise NotImplementedError() @@ -175,7 +175,7 @@ class StreamPause: self._pause_generator = generator if self._pause_generator is not None: - self._pause_cr = cocotb.fork(self._run_pause()) + self._pause_cr = cocotb.start_soon(self._run_pause()) def clear_pause_generator(self): self.set_pause_generator(None)