diff --git a/test/test_chat_text.py b/test/test_chat_text.py index 582df1c9..feecb5e7 100644 --- a/test/test_chat_text.py +++ b/test/test_chat_text.py @@ -103,7 +103,7 @@ def analyze_results(station1: list, station2: list, call_list: list): @pytest.mark.parametrize("freedv_mode", ["datac1", "datac3"]) @pytest.mark.parametrize("n_frames_per_burst", [1]) # Higher fpb is broken. @pytest.mark.parametrize("message_no", range(len(messages))) -# @pytest.mark.flaky(reruns=2) +@pytest.mark.flaky(reruns=2) def test_chat_text( freedv_mode: str, n_frames_per_burst: int, message_no: int, tmp_path ): diff --git a/test/util_chat_text_1.py b/test/util_chat_text_1.py index 34ab4885..1095c17d 100644 --- a/test/util_chat_text_1.py +++ b/test/util_chat_text_1.py @@ -60,7 +60,7 @@ def t_setup( tnc.time_list_high_bw = [3, 1, 1] tnc.time_list = [3, 1, 1] # Limit number of retries - tnc.rx_n_max_retries_per_burst = 4 + tnc.rx_n_max_retries_per_burst = 5 # Create the modem t_modem = modem.RF() @@ -141,8 +141,6 @@ def t_highsnr_arq_short_station1( ], } - sock.process_tnc_commands(json.dumps(data, indent=None)) - time.sleep(0.5) sock.process_tnc_commands(json.dumps(data, indent=None)) # Assure the test completes. @@ -174,7 +172,7 @@ def t_highsnr_arq_short_station1( # log.info("S1 DQT: ", DQ_Tx=pformat(tnc.data_queue_transmit.queue)) # log.info("S1 DQR: ", DQ_Rx=pformat(tnc.data_queue_received.queue)) - # log.info("S1 Socket: ", socket_queue=pformat(sock.SOCKET_QUEUE.queue)) + log.info("S1 Socket: ", socket_queue=pformat(sock.SOCKET_QUEUE.queue)) assert '"arq":"transmission","status":"transmitting"' in str( sock.SOCKET_QUEUE.queue diff --git a/test/util_chat_text_2.py b/test/util_chat_text_2.py index a1883fb4..d77ebb15 100644 --- a/test/util_chat_text_2.py +++ b/test/util_chat_text_2.py @@ -57,7 +57,7 @@ def t_setup( tnc.time_list_high_bw = [1, 1, 1] tnc.time_list = [1, 1, 1] # Limit number of retries - tnc.rx_n_max_retries_per_burst = 4 + tnc.rx_n_max_retries_per_burst = 5 # Create the modem t_modem = modem.RF() @@ -148,7 +148,7 @@ def t_highsnr_arq_short_station2( # log.info("S2 DQT: ", DQ_Tx=pformat(tnc.data_queue_transmit.queue)) # log.info("S2 DQR: ", DQ_Rx=pformat(tnc.data_queue_received.queue)) - # log.info("S2 Socket: ", socket_queue=pformat(sock.SOCKET_QUEUE.queue)) + log.info("S2 Socket: ", socket_queue=pformat(sock.SOCKET_QUEUE.queue)) assert '"arq":"transmission","status":"received"' in str(sock.SOCKET_QUEUE.queue)