Merge pull request #280 from DUNE-DAQ/kbiery/integtest_token_count_fixes

fixed the assignment of the token count in several integration tests
DUNE-DAQ · Apr 3, 2023 · bd40439 · bd40439
2 parents 4cef7ed + bc1d2db
commit bd40439
Show file tree

Hide file tree

Showing 7 changed files with 8 additions and 5 deletions.
diff --git a/integtest/3ru_1df_multirun_test.py b/integtest/3ru_1df_multirun_test.py
@@ -93,7 +93,7 @@
 
 swtpg_conf = copy.deepcopy(conf_dict)
 swtpg_conf["readout"]["enable_software_tpg"] = True
-swtpg_conf["dataflow"]["apps"][0]["token_count"] = max(10, 3*number_of_data_producers*number_of_readout_apps)
+swtpg_conf["dataflow"]["token_count"] = max(10, 3*number_of_data_producers*number_of_readout_apps)
 
 dqm_conf = copy.deepcopy(conf_dict)
 dqm_conf["dqm"]["enable_dqm"] = True

diff --git a/integtest/3ru_3df_multirun_test.py b/integtest/3ru_3df_multirun_test.py
@@ -84,8 +84,7 @@
 
 swtpg_conf = copy.deepcopy(conf_dict)
 swtpg_conf["readout"]["enable_software_tpg"] = True
-for df_app in range(number_of_dataflow_apps):
-    swtpg_conf["dataflow"]["apps"][df_app]["token_count"] = int(math.ceil(max(10, 3*number_of_data_producers*number_of_readout_apps)/number_of_dataflow_apps))
+swtpg_conf["dataflow"]["token_count"] = int(math.ceil(max(10, 3*number_of_data_producers*number_of_readout_apps)/number_of_dataflow_apps))
 
 dqm_conf = copy.deepcopy(conf_dict)
 dqm_conf["dqm"]["enable_dqm"] = True

diff --git a/integtest/long_window_readout_test.py b/integtest/long_window_readout_test.py
@@ -85,6 +85,7 @@
 conf_dict["trigger"]["trigger_window_before_ticks"] = readout_window_time_before
 conf_dict["trigger"]["trigger_window_after_ticks"] = readout_window_time_after
 
+conf_dict["dataflow"]["token_count"] = token_count
 conf_dict["dataflow"]["apps"] = [] # Remove preconfigured dataflow0 app
 for df_app in range(number_of_dataflow_apps):
     dfapp_conf = {}

diff --git a/integtest/multi_output_file_test.py b/integtest/multi_output_file_test.py
@@ -75,7 +75,7 @@
 
 swtpg_conf = copy.deepcopy(conf_dict)
 swtpg_conf["readout"]["enable_software_tpg"] = True
-swtpg_conf["dataflow"]["apps"][0]["token_count"] = max(10, 3*number_of_data_producers*number_of_readout_apps)
+swtpg_conf["dataflow"]["token_count"] = max(10, 3*number_of_data_producers*number_of_readout_apps)
 
 confgen_arguments={"WIB1_System": conf_dict,
                    "Software_TPG_System": swtpg_conf,

diff --git a/integtest/tpstream_writing_test.py b/integtest/tpstream_writing_test.py
@@ -1,6 +1,7 @@
 import pytest
 import os
 import re
+import math
 import urllib.request
 
 import dfmodules.data_file_checks as data_file_checks
@@ -83,12 +84,12 @@
 conf_dict["trigger"]["tpset_output_path"] = output_dir
 conf_dict["readout"]["enable_software_tpg"] = True
 
+conf_dict["dataflow"]["token_count"] = int(math.ceil(max(10, 3*number_of_data_producers*number_of_readout_apps)/number_of_dataflow_apps))
 conf_dict["dataflow"]["apps"] = [] # Remove preconfigured dataflow0 app
 for df_app in range(number_of_dataflow_apps):
     dfapp_conf = {}
     dfapp_conf["app_name"] = f"dataflow{df_app}"
     dfapp_conf["output_path"] = output_dir
-    dfapp_conf["token_count"] = 3*number_of_readout_apps
     conf_dict["dataflow"]["apps"].append(dfapp_conf)
 
 confgen_arguments={"Software_TPG_System": conf_dict                  }

diff --git a/integtest/z.insufficient_disk_space_test.not_yet_working b/integtest/z.insufficient_disk_space_test.not_yet_working
@@ -80,6 +80,7 @@ conf_dict["trigger"]["trigger_rate_hz"] = trigger_rate
 conf_dict["trigger"]["trigger_window_before_ticks"] = readout_window_time_before
 conf_dict["trigger"]["trigger_window_after_ticks"] = readout_window_time_after
 
+conf_dict["dataflow"]["token_count"] = token_count
 conf_dict["dataflow"]["apps"] = [] # Remove preconfigured dataflow0 app
 for df_app in range(number_of_dataflow_apps):
     dfapp_conf = {}

diff --git a/integtest/z.large_trigger_record_test.not_yet_working b/integtest/z.large_trigger_record_test.not_yet_working
@@ -62,6 +62,7 @@ conf_dict["trigger"]["trigger_rate_hz"] = trigger_rate
 conf_dict["trigger"]["trigger_window_before_ticks"] = readout_window_time_before
 conf_dict["trigger"]["trigger_window_after_ticks"] = readout_window_time_after
 
+conf_dict["dataflow"]["token_count"] = token_count
 conf_dict["dataflow"]["apps"] = [] # Remove preconfigured dataflow0 app
 for df_app in range(number_of_dataflow_apps):
     dfapp_conf = {}