Line data Source code
1 : /**
2 : * @file TriggerApplication.cpp
3 : *
4 : * Implementation of TriggerApplication's generate_modules dal method
5 : *
6 : * This is part of the DUNE DAQ Software Suite, copyright 2023.
7 : * Licensing/copyright details are in the COPYING file that you should have
8 : * received with this code.
9 : */
10 :
11 :
12 : #include "appmodel/ConfigurationHelper.hpp"
13 : #include "conffwk/Configuration.hpp"
14 :
15 : #include "confmodel/Connection.hpp"
16 : #include "confmodel/NetworkConnection.hpp"
17 : #include "confmodel/ResourceSet.hpp"
18 : #include "confmodel/Service.hpp"
19 :
20 : #include "ConfigObjectFactory.hpp"
21 : #include "appmodel/DataSubscriberModule.hpp"
22 : #include "appmodel/DataReaderConf.hpp"
23 : #include "appmodel/DataRecorderConf.hpp"
24 :
25 : #include "appmodel/DataHandlerModule.hpp"
26 : #include "appmodel/DataHandlerConf.hpp"
27 :
28 : #include "appmodel/NetworkConnectionRule.hpp"
29 : #include "appmodel/QueueConnectionRule.hpp"
30 :
31 : #include "appmodel/QueueDescriptor.hpp"
32 : #include "appmodel/NetworkConnectionDescriptor.hpp"
33 :
34 : #include "appmodel/SourceIDConf.hpp"
35 :
36 : #include "appmodel/TriggerApplication.hpp"
37 : #include "appmodel/appmodelIssues.hpp"
38 :
39 : #include "logging/Logging.hpp"
40 :
41 : #include <string>
42 : #include <vector>
43 :
44 : namespace dunedaq {
45 : namespace appmodel {
46 :
47 : /**
48 : * \brief Helper function that gets a network connection config
49 : *
50 : * \param idname Unique ID name of the config object
51 : * \param ntDesc Network connection descriptor object
52 : * \param confdb Global database configuration
53 : * \param dbfile Database file location
54 : *
55 : * \ret OKS configuration object for the network connection
56 : */
57 : conffwk::ConfigObject
58 0 : create_network_connection(std::string uid,
59 : const NetworkConnectionDescriptor* ntDesc,
60 : conffwk::Configuration* confdb,
61 : const std::string& dbfile)
62 : {
63 0 : auto ntServiceObj = ntDesc->get_associated_service()->config_object();
64 0 : conffwk::ConfigObject ntObj;
65 0 : confdb->create(dbfile, "NetworkConnection", uid, ntObj);
66 0 : ntObj.set_by_val<std::string>("data_type", ntDesc->get_data_type());
67 0 : ntObj.set_by_val<std::string>("connection_type", ntDesc->get_connection_type());
68 0 : ntObj.set_obj("associated_service", &ntServiceObj);
69 :
70 0 : return ntObj;
71 0 : }
72 :
73 :
74 : void
75 0 : TriggerApplication::generate_modules(std::shared_ptr<appmodel::ConfigurationHelper> helper) const
76 : {
77 :
78 0 : std::vector<const confmodel::DaqModule*> modules;
79 :
80 0 : ConfigObjectFactory obj_fac(this);
81 :
82 0 : auto ti_conf = get_trigger_inputs_handler();
83 0 : auto ti_class = ti_conf->get_template_for();
84 0 : std::string handler_name("");
85 : // Process the queue rules looking for inputs to our trigger handler modules
86 0 : const QueueDescriptor* ti_inputq_desc = nullptr;
87 :
88 0 : for (auto rule : get_queue_rules()) {
89 0 : auto destination_class = rule->get_destination_class();
90 0 : auto data_type = rule->get_descriptor()->get_data_type();
91 0 : if (destination_class == "DataHandlerModule" || destination_class == ti_class) {
92 0 : ti_inputq_desc = rule->get_descriptor();
93 : }
94 0 : }
95 : // Process the network rules looking for the TP handler data reuest inputs
96 0 : const NetworkConnectionDescriptor* req_net_desc = nullptr;
97 0 : const NetworkConnectionDescriptor* tin_net_desc = nullptr;
98 0 : const NetworkConnectionDescriptor* tout_net_desc = nullptr;
99 0 : const NetworkConnectionDescriptor* tset_out_net_desc = nullptr;
100 0 : for (auto rule : get_network_rules()) {
101 0 : auto endpoint_class = rule->get_endpoint_class();
102 0 : auto data_type = rule->get_descriptor()->get_data_type();
103 :
104 0 : if (data_type == "DataRequest") {
105 0 : req_net_desc = rule->get_descriptor();
106 : }
107 0 : else if (data_type == "TASet" || data_type == "TCSet"){
108 0 : tset_out_net_desc = rule->get_descriptor();
109 : }
110 0 : else if (endpoint_class == "DataSubscriberModule") {
111 0 : if (!tin_net_desc) {
112 0 : tin_net_desc = rule->get_descriptor();
113 : }
114 0 : else if (rule->get_descriptor()->get_data_type() == tin_net_desc->get_data_type()) {
115 : // For now endpoint_class of DataSubscriberModule for both input and output
116 : // with the same data type is not possible.
117 0 : throw (BadConf(ERS_HERE, "Have two network connections of the same data_type and the same endpoint_class"));
118 : }
119 0 : else if (tin_net_desc->get_data_type() == "TriggerActivity" &&
120 0 : rule->get_descriptor()->get_data_type() == "TriggerCandidate") {
121 : // For TA->TC
122 0 : tout_net_desc = rule->get_descriptor();
123 0 : handler_name = "tahandler";
124 : }
125 0 : else if (tin_net_desc->get_data_type() == "TriggerCandidate" &&
126 0 : rule->get_descriptor()->get_data_type() == "TriggerActivity") {
127 : // For TA->TC if we saved TC network connection as input first...
128 0 : tout_net_desc = tin_net_desc;
129 0 : tin_net_desc = rule->get_descriptor();
130 0 : handler_name = "tahandler";
131 : }
132 : else {
133 0 : throw (BadConf(ERS_HERE, "Unexpected input & output network connection descriptors provided"));
134 : }
135 : }
136 0 : else if (data_type == "TriggerActivity" || data_type == "TriggerCandidate"){
137 0 : tout_net_desc = rule->get_descriptor();
138 0 : if (data_type == "TriggerActivity")
139 0 : handler_name = "tphandler";
140 : else
141 0 : handler_name = "tahandler";
142 : }
143 0 : }
144 :
145 : // Process special Network rules!
146 0 : std::vector<conffwk::ConfigObject> fragOutObjs;
147 0 : for (auto [uid, descriptor]:
148 0 : helper->get_netdescriptors("Fragment", "DFApplication")) {
149 0 : fragOutObjs.push_back(obj_fac.create_net_obj(descriptor, uid));
150 0 : }
151 0 : if ( req_net_desc== nullptr) {
152 0 : throw (BadConf(ERS_HERE, "No network descriptor given to receive request and send data was set"));
153 : }
154 0 : if ( tin_net_desc== nullptr) {
155 0 : throw (BadConf(ERS_HERE, "No network descriptor given to receive trigger objects"));
156 : }
157 0 : if ( tout_net_desc== nullptr) {
158 0 : throw (BadConf(ERS_HERE, "No network descriptor given to publish trigger objects"));
159 : }
160 0 : if (ti_inputq_desc == nullptr) {
161 0 : throw (BadConf(ERS_HERE, "No data input queue descriptor given"));
162 : }
163 :
164 0 : auto input_queue_obj = obj_fac.create_queue_obj(ti_inputq_desc);
165 :
166 0 : auto req_net_obj = obj_fac.create_net_obj(req_net_desc, UID());
167 :
168 0 : auto tin_net_obj = obj_fac.create_net_obj(tin_net_desc, ".*");
169 :
170 0 : auto tout_net_obj = obj_fac.create_net_obj(tout_net_desc, UID());
171 0 : conffwk::ConfigObject tset_out_net_obj;
172 0 : if (tset_out_net_desc) {
173 0 : tset_out_net_obj = obj_fac.create_net_obj(tset_out_net_desc, UID());
174 : }
175 :
176 :
177 : // build up the full list of outputs
178 0 : std::vector<const conffwk::ConfigObject*> ti_output_objs;
179 0 : for (auto& fNet : fragOutObjs) {
180 0 : ti_output_objs.push_back(&fNet);
181 : }
182 0 : ti_output_objs.push_back(&tout_net_obj);
183 0 : if (tset_out_net_desc!= nullptr) {
184 0 : ti_output_objs.push_back(&tset_out_net_obj);
185 : }
186 :
187 0 : if (get_source_id() == nullptr) {
188 0 : throw(BadConf(ERS_HERE, "No source_id associated with this TriggerApplication!"));
189 : }
190 0 : uint32_t source_id = get_source_id()->get_sid();
191 0 : std::string ti_uid(handler_name + "-" + std::to_string(source_id));
192 0 : auto ti_obj = obj_fac.create(ti_class, ti_uid);
193 :
194 0 : ti_obj.set_by_val<uint32_t>("source_id", source_id);
195 0 : ti_obj.set_by_val<uint32_t>("detector_id", 1); // 1 == kDAQ
196 0 : ti_obj.set_by_val<bool>("post_processing_enabled", !get_tx_generation_disabled());
197 :
198 0 : auto ti_conf_obj = ti_conf->config_object();
199 0 : ti_obj.set_obj("module_configuration", &ti_conf_obj);
200 0 : ti_obj.set_objs("inputs", {&input_queue_obj, &req_net_obj});
201 0 : ti_obj.set_objs("outputs", ti_output_objs);
202 : // Add to our list of modules to return
203 0 : modules.push_back(obj_fac.get_dal<DataHandlerModule>(ti_uid));
204 :
205 :
206 : // Now create the DataSubscriberModule object
207 0 : auto rdr_conf = get_data_subscriber();
208 0 : if (rdr_conf == nullptr) {
209 : throw (BadConf(ERS_HERE, "No DataReaderModule configuration given"));
210 : }
211 :
212 : // Create a DataReaderModule
213 :
214 0 : std::string reader_uid("data-reader-"+UID());
215 0 : std::string reader_class = rdr_conf->get_template_for();
216 0 : TLOG_DEBUG(7) << "creating OKS configuration object for Data subscriber class " << reader_class;
217 0 : auto reader_obj = obj_fac.create(reader_class, reader_uid);
218 0 : reader_obj.set_objs("inputs", {&tin_net_obj} );
219 0 : reader_obj.set_objs("outputs", {&input_queue_obj} );
220 0 : reader_obj.set_obj("configuration", &rdr_conf->config_object());
221 :
222 0 : modules.push_back(obj_fac.get_dal<DataSubscriberModule>(reader_uid));
223 :
224 :
225 0 : obj_fac.update_modules(modules);
226 0 : }
227 :
228 : } // namespace appmodel
229 : } // namespace dunedaq
|
