bslathi19/cocotbext-axi
1
0
Fork 0
Code Issues Actions Packages Projects Releases 5 Wiki Activity

Use start_soon instead of fork

Browse Source
This commit is contained in:
Alex Forencich
2021-03-21 11:40:25 -07:00
parent a71678c7e3
commit 6c66776518
7 changed files with 17 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
cocotbext/axi/axi_master.py
View File

@@ -209,9 +209,9 @@ class AxiMasterWrite(Reset):
else: else:
self.log.info("Reset de-asserted") self.log.info("Reset de-asserted")
if self._process_write_cr is None: if self._process_write_cr is None:
self._process_write_cr = cocotb.fork(self._process_write()) self._process_write_cr = cocotb.scheduler.start_soon(self._process_write())
if self._process_write_resp_cr is None: 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.scheduler.start_soon(self._process_write_resp())
self.aw_channel.clear() self.aw_channel.clear()
self.w_channel.clear() self.w_channel.clear()
@@ -541,9 +541,9 @@ class AxiMasterRead(Reset):
else: else:
self.log.info("Reset de-asserted") self.log.info("Reset de-asserted")
if self._process_read_cr is None: if self._process_read_cr is None:
self._process_read_cr = cocotb.fork(self._process_read()) self._process_read_cr = cocotb.scheduler.start_soon(self._process_read())
if self._process_read_resp_cr is None: 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.scheduler.start_soon(self._process_read_resp())
self.ar_channel.clear() self.ar_channel.clear()
self.r_channel.clear() self.r_channel.clear()

4
cocotbext/axi/axi_ram.py
View File

@@ -78,7 +78,7 @@ class AxiRamWrite(Memory, Reset):
else: else:
self.log.info("Reset de-asserted") self.log.info("Reset de-asserted")
if self._process_write_cr is None: if self._process_write_cr is None:
self._process_write_cr = cocotb.fork(self._process_write()) self._process_write_cr = cocotb.scheduler.start_soon(self._process_write())
self.aw_channel.clear() self.aw_channel.clear()
self.w_channel.clear() self.w_channel.clear()
@@ -198,7 +198,7 @@ class AxiRamRead(Memory, Reset):
else: else:
self.log.info("Reset de-asserted") self.log.info("Reset de-asserted")
if self._process_read_cr is None: if self._process_read_cr is None:
self._process_read_cr = cocotb.fork(self._process_read()) self._process_read_cr = cocotb.scheduler.start_soon(self._process_read())
self.ar_channel.clear() self.ar_channel.clear()
self.r_channel.clear() self.r_channel.clear()

8
cocotbext/axi/axil_master.py
View File

@@ -152,9 +152,9 @@ class AxiLiteMasterWrite(Reset):
else: else:
self.log.info("Reset de-asserted") self.log.info("Reset de-asserted")
if self._process_write_cr is None: if self._process_write_cr is None:
self._process_write_cr = cocotb.fork(self._process_write()) self._process_write_cr = cocotb.scheduler.start_soon(self._process_write())
if self._process_write_resp_cr is None: 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.scheduler.start_soon(self._process_write_resp())
self.aw_channel.clear() self.aw_channel.clear()
self.w_channel.clear() self.w_channel.clear()
@@ -360,9 +360,9 @@ class AxiLiteMasterRead(Reset):
else: else:
self.log.info("Reset de-asserted") self.log.info("Reset de-asserted")
if self._process_read_cr is None: if self._process_read_cr is None:
self._process_read_cr = cocotb.fork(self._process_read()) self._process_read_cr = cocotb.scheduler.start_soon(self._process_read())
if self._process_read_resp_cr is None: 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.scheduler.start_soon(self._process_read_resp())
self.ar_channel.clear() self.ar_channel.clear()
self.r_channel.clear() self.r_channel.clear()

4
cocotbext/axi/axil_ram.py
View File

@@ -75,7 +75,7 @@ class AxiLiteRamWrite(Memory, Reset):
else: else:
self.log.info("Reset de-asserted") self.log.info("Reset de-asserted")
if self._process_write_cr is None: if self._process_write_cr is None:
self._process_write_cr = cocotb.fork(self._process_write()) self._process_write_cr = cocotb.scheduler.start_soon(self._process_write())
self.aw_channel.clear() self.aw_channel.clear()
self.w_channel.clear() self.w_channel.clear()
@@ -153,7 +153,7 @@ class AxiLiteRamRead(Memory, Reset):
else: else:
self.log.info("Reset de-asserted") self.log.info("Reset de-asserted")
if self._process_read_cr is None: if self._process_read_cr is None:
self._process_read_cr = cocotb.fork(self._process_read()) self._process_read_cr = cocotb.scheduler.start_soon(self._process_read())
self.ar_channel.clear() self.ar_channel.clear()
self.r_channel.clear() self.r_channel.clear()

4
cocotbext/axi/axis.py
View File

@@ -368,7 +368,7 @@ class AxiStreamBase(Reset):
else: else:
self.log.info("Reset de-asserted") self.log.info("Reset de-asserted")
if self._run_cr is None: if self._run_cr is None:
self._run_cr = cocotb.fork(self._run()) self._run_cr = cocotb.scheduler.start_soon(self._run())
self.active = False self.active = False
@@ -392,7 +392,7 @@ class AxiStreamPause:
self._pause_generator = generator self._pause_generator = generator
if self._pause_generator is not None: if self._pause_generator is not None:
self._pause_cr = cocotb.fork(self._run_pause()) self._pause_cr = cocotb.scheduler.start_soon(self._run_pause())
def clear_pause_generator(self): def clear_pause_generator(self):
self.set_pause_generator(None) self.set_pause_generator(None)

2
cocotbext/axi/reset.py
View File

@@ -33,7 +33,7 @@ class Reset:
self._reset_state = True self._reset_state = True
if reset_signal is not None: if reset_signal is not None:
cocotb.fork(self._run_reset(reset_signal, bool(active_level))) cocotb.scheduler.start_soon(self._run_reset(reset_signal, bool(active_level)))
self._update_reset() self._update_reset()

4
cocotbext/axi/stream.py
View File

@@ -146,7 +146,7 @@ class StreamBase(Reset):
else: else:
self.log.info("Reset de-asserted") self.log.info("Reset de-asserted")
if self._run_cr is None: if self._run_cr is None:
self._run_cr = cocotb.fork(self._run()) self._run_cr = cocotb.scheduler.start_soon(self._run())
self.active = False self.active = False
@@ -170,7 +170,7 @@ class StreamPause:
self._pause_generator = generator self._pause_generator = generator
if self._pause_generator is not None: if self._pause_generator is not None:
self._pause_cr = cocotb.fork(self._run_pause()) self._pause_cr = cocotb.scheduler.start_soon(self._run_pause())
def clear_pause_generator(self): def clear_pause_generator(self):
self.set_pause_generator(None) self.set_pause_generator(None)