diff --git a/tb/eth_mac_10g_fifo/test_eth_mac_10g_fifo.py b/tb/eth_mac_10g_fifo/test_eth_mac_10g_fifo.py
index 5a3343087..0fe7ccaed 100644
--- a/tb/eth_mac_10g_fifo/test_eth_mac_10g_fifo.py
+++ b/tb/eth_mac_10g_fifo/test_eth_mac_10g_fifo.py
@@ -108,8 +108,8 @@ async def run_test_rx(dut, payload_lengths=None, payload_data=None, ifg=12):
     await tb.reset()
 
     tb.log.info("Wait for PTP CDC lock")
-    while not dut.tx_ptp.tx_ptp_cdc.locked.value.integer:
-        await RisingEdge(dut.tx_clk)
+    while not dut.rx_ptp.rx_ptp_cdc.locked.value.integer:
+        await RisingEdge(dut.rx_clk)
 
     test_frames = [payload_data(x) for x in payload_lengths()]
     tx_frames = []
diff --git a/tb/eth_mac_phy_10g_fifo/test_eth_mac_phy_10g_fifo.py b/tb/eth_mac_phy_10g_fifo/test_eth_mac_phy_10g_fifo.py
index d6883df76..a4cd1b617 100644
--- a/tb/eth_mac_phy_10g_fifo/test_eth_mac_phy_10g_fifo.py
+++ b/tb/eth_mac_phy_10g_fifo/test_eth_mac_phy_10g_fifo.py
@@ -125,8 +125,8 @@ async def run_test_rx(dut, payload_lengths=None, payload_data=None, ifg=12):
         await RisingEdge(dut.rx_clk)
 
     tb.log.info("Wait for PTP CDC lock")
-    while not dut.tx_ptp.tx_ptp_cdc.locked.value.integer:
-        await RisingEdge(dut.tx_clk)
+    while not dut.rx_ptp.rx_ptp_cdc.locked.value.integer:
+        await RisingEdge(dut.rx_clk)
 
     # clear out sink buffer
     tb.axis_sink.clear()