@@ -1222,13 +1222,15 @@ def execute_dual_test_rgb24(
1222
1222
):
1223
1223
# Initialize logging for this test
1224
1224
init_test_logging ()
1225
-
1225
+
1226
1226
# Use separate NIC port lists for TX and RX hosts
1227
1227
tx_nic_port_list = tx_host .vfs
1228
1228
rx_nic_port_list = rx_host .vfs
1229
1229
video_size , fps = decode_video_format_16_9 (video_format )
1230
-
1231
- logger .info (f"Creating RX config for RGB24 dual test with video_format: { video_format } " )
1230
+
1231
+ logger .info (
1232
+ f"Creating RX config for RGB24 dual test with video_format: { video_format } "
1233
+ )
1232
1234
log_to_file (
1233
1235
f"Creating RX config for RGB24 dual test with video_format: { video_format } " ,
1234
1236
rx_host ,
@@ -1246,7 +1248,7 @@ def execute_dual_test_rgb24(
1246
1248
log_fail (f"Failed to create RX config file: { e } " )
1247
1249
log_to_file (f"Failed to create RX config file: { e } " , rx_host , build )
1248
1250
return False
1249
-
1251
+
1250
1252
rx_cmd = f"{ RXTXAPP_PATH } --config_file { rx_config_file } --test_time { test_time } "
1251
1253
tx_cmd = (
1252
1254
f"ffmpeg -stream_loop -1 -video_size { video_size } -f rawvideo -pix_fmt rgb24 "
@@ -1282,7 +1284,7 @@ def execute_dual_test_rgb24(
1282
1284
enable_sudo = True ,
1283
1285
)
1284
1286
time .sleep (5 )
1285
-
1287
+
1286
1288
# Start TX pipeline on TX host
1287
1289
logger .info ("Starting TX pipeline on TX host..." )
1288
1290
tx_proc = run (
@@ -1294,7 +1296,7 @@ def execute_dual_test_rgb24(
1294
1296
background = True ,
1295
1297
enable_sudo = True ,
1296
1298
)
1297
-
1299
+
1298
1300
# Start tcpdump after pipelines are running
1299
1301
if tcpdump :
1300
1302
logger .info ("Starting tcpdump capture..." )
@@ -1320,7 +1322,7 @@ def execute_dual_test_rgb24(
1320
1322
logger .info ("TX process killed" )
1321
1323
except Exception :
1322
1324
logger .info ("Could not terminate TX process" )
1323
-
1325
+
1324
1326
rx_output = ""
1325
1327
try :
1326
1328
rx_output = rx_proc .stdout_text
@@ -1335,7 +1337,7 @@ def execute_dual_test_rgb24(
1335
1337
logger .info ("TX output captured successfully" )
1336
1338
except Exception as e :
1337
1339
log_to_file (f"Error retrieving TX output: { e } " , tx_host , build )
1338
-
1340
+
1339
1341
except Exception as e :
1340
1342
log_fail (f"Error during test execution: { e } " )
1341
1343
# Terminate processes immediately on error
@@ -1374,7 +1376,7 @@ def execute_dual_test_rgb24(
1374
1376
pass
1375
1377
if tcpdump :
1376
1378
tcpdump .stop ()
1377
-
1379
+
1378
1380
if not check_output_rgb24 (rx_output , 1 ):
1379
1381
log_fail ("rx video sessions failed" )
1380
1382
return False
@@ -1395,13 +1397,13 @@ def execute_dual_test_rgb24_multiple(
1395
1397
):
1396
1398
# Initialize logging for this test
1397
1399
init_test_logging ()
1398
-
1399
- # Use separate NIC port lists for TX and RX hosts
1400
+
1401
+ # Use separate NIC port lists for TX and RX hosts
1400
1402
tx_nic_port_list = tx_host .vfs
1401
1403
rx_nic_port_list = rx_host .vfs
1402
1404
video_size_1 , fps_1 = decode_video_format_16_9 (video_format_list [0 ])
1403
1405
video_size_2 , fps_2 = decode_video_format_16_9 (video_format_list [1 ])
1404
-
1406
+
1405
1407
logger .info (
1406
1408
f"Creating RX config for RGB24 multiple dual test with video_formats: { video_format_list } "
1407
1409
)
@@ -1422,7 +1424,7 @@ def execute_dual_test_rgb24_multiple(
1422
1424
log_fail (f"Failed to create RX config file: { e } " )
1423
1425
log_to_file (f"Failed to create RX config file: { e } " , rx_host , build )
1424
1426
return False
1425
-
1427
+
1426
1428
rx_cmd = f"{ RXTXAPP_PATH } --config_file { rx_config_file } --test_time { test_time } "
1427
1429
tx_1_cmd = (
1428
1430
f"ffmpeg -stream_loop -1 -video_size { video_size_1 } -f rawvideo -pix_fmt rgb24 "
@@ -1469,7 +1471,7 @@ def execute_dual_test_rgb24_multiple(
1469
1471
enable_sudo = True ,
1470
1472
)
1471
1473
time .sleep (5 )
1472
-
1474
+
1473
1475
# Start TX pipelines on TX host
1474
1476
logger .info ("Starting TX pipelines on TX host..." )
1475
1477
tx_1_proc = run (
@@ -1490,7 +1492,7 @@ def execute_dual_test_rgb24_multiple(
1490
1492
background = True ,
1491
1493
enable_sudo = True ,
1492
1494
)
1493
-
1495
+
1494
1496
# Start tcpdump after pipelines are running
1495
1497
if tcpdump :
1496
1498
logger .info ("Starting tcpdump capture..." )
@@ -1515,7 +1517,7 @@ def execute_dual_test_rgb24_multiple(
1515
1517
logger .info ("TX process killed" )
1516
1518
except Exception :
1517
1519
logger .info ("Could not terminate TX process" )
1518
-
1520
+
1519
1521
rx_output = ""
1520
1522
try :
1521
1523
rx_output = rx_proc .stdout_text
@@ -1524,13 +1526,13 @@ def execute_dual_test_rgb24_multiple(
1524
1526
except Exception as e :
1525
1527
logger .info (f"Error retrieving RX output: { e } " )
1526
1528
log_to_file (f"Error retrieving RX output: { e } " , rx_host , build )
1527
-
1529
+
1528
1530
try :
1529
1531
log_to_file (f"TX1 Output:\n { tx_1_proc .stdout_text } " , tx_host , build )
1530
1532
logger .info ("TX1 output captured successfully" )
1531
1533
except Exception as e :
1532
1534
logger .info (f"Error retrieving TX1 output: { e } " )
1533
-
1535
+
1534
1536
try :
1535
1537
log_to_file (f"TX2 Output:\n { tx_2_proc .stdout_text } " , tx_host , build )
1536
1538
logger .info ("TX2 output captured successfully" )
@@ -1561,9 +1563,9 @@ def execute_dual_test_rgb24_multiple(
1561
1563
pass
1562
1564
if tcpdump :
1563
1565
tcpdump .stop ()
1564
-
1566
+
1565
1567
if not check_output_rgb24 (rx_output , 2 ):
1566
1568
log_fail ("rx video session failed" )
1567
1569
return False
1568
1570
time .sleep (5 )
1569
- return True
1571
+ return True
0 commit comments