1 #include "otsdaq/Macros/TablePluginMacros.h"
2 #include "otsdaq/TablePlugins/ARTDAQDispatcherTable.h"
3 #include "otsdaq/TablePlugins/XDAQContextTable.h"
9 #define SLOWCONTROL_PV_FILE_PATH \
11 getenv("OTSDAQ_EPICS_DATA")? \
12 (std::string(getenv("OTSDAQ_EPICS_DATA")) + "/" + __ENV__("MU2E_OWNER") + "_otsdaq_artdaqDispatcher-ai.dbg"): \
13 (EPICS_CONFIG_PATH + "/_otsdaq_artdaqDispatcher-ai.dbg") )
18 ARTDAQDispatcherTable::ARTDAQDispatcherTable(
void)
27 __COUT__ <<
"ARTDAQDispatcherTable Constructed." << __E__;
31 ARTDAQDispatcherTable::~ARTDAQDispatcherTable(
void) {}
36 lastConfigManager_ = configManager;
40 isFirstAppInContext_ = configManager->isOwnerFirstAppInContext();
43 if(!isFirstAppInContext_)
47 mkdir((ARTDAQTableBase::ARTDAQ_FCL_PATH).c_str(), 0755);
54 auto dispatchers = lastConfigManager_->__SELF_NODE__.getChildren(
55 std::map<std::string /*relative-path*/, std::string /*value*/>(),
59 for(
auto& dispatcher : dispatchers)
61 ARTDAQTableBase::outputDataReceiverFHICL(dispatcher.second, ARTDAQTableBase::ARTDAQAppType::Dispatcher);
62 ARTDAQTableBase::flattenFHICL(ARTDAQAppType::Dispatcher, dispatcher.second.getValue());
68 unsigned int ARTDAQDispatcherTable::slowControlsHandlerConfig(std::stringstream& out,
70 std::vector<std::pair<std::string , std::vector<std::string>>>* channelList
76 std::string tabStr =
"";
77 std::string commentStr =
"";
80 std::vector<std::pair<std::string, ConfigurationTree>> artdaqRecords = configManager->getNode(
"ARTDAQSupervisorTable").getChildren();
82 unsigned int numberOfDispatchers = 0;
83 unsigned int numberOfDispatcherMetricParameters = 0;
85 for(
auto& artdaqPair : artdaqRecords)
87 if(artdaqPair.second.getNode(colARTDAQSupervisor_.colLinkToDispatchers_).isDisconnected())
90 std::vector<std::pair<std::string, ConfigurationTree>> dispatcherRecords =
91 artdaqPair.second.getNode(colARTDAQSupervisor_.colLinkToDispatchers_).getChildren();
93 for(
auto& dispatcherPair : dispatcherRecords)
95 if(!dispatcherPair.second.status())
98 numberOfDispatchers++;
102 if(dispatcherPair.second.getNode(
"daqLink").isDisconnected())
105 auto daqLink = dispatcherPair.second.getNode(
"daqLink");
107 if(daqLink.getNode(
"daqMetricsLink").isDisconnected())
110 auto daqMetricsLinks = daqLink.getNode(
"daqMetricsLink").getChildren();
111 for(
auto& daqMetricsLink : daqMetricsLinks)
113 if(!daqMetricsLink.second.status())
116 if(daqMetricsLink.second.getNode(
"metricParametersLink").isDisconnected())
120 ConfigurationTree slowControlsLink = dispatcherPair.second.getNode(
"MetricAlarmThresholdsLink");
122 auto metricParametersLinks = daqMetricsLink.second.getNode(
"metricParametersLink").getChildren();
123 for(
auto& metricParametersLink : metricParametersLinks)
125 if(!metricParametersLink.second.status())
128 std::string subsystem = metricParametersLink.second.getNode(
"metricParameterValue")
129 .getValueWithDefault<std::string>(std::string(
"TDAQ_") + __ENV__(
"MU2E_OWNER"));
130 if(subsystem.find(
"Mu2e:") != std::string::npos)
131 subsystem = subsystem.replace(subsystem.find(
"Mu2e:"), 5,
"");
132 while(subsystem.find(
"\"") != std::string::npos)
133 subsystem = subsystem.replace(subsystem.find(
"\""), 1,
"");
135 numberOfDispatcherMetricParameters =
136 slowControlsHandler(out, tabStr, commentStr, subsystem, dispatcherPair.first, slowControlsLink, channelList);
138 __COUT__ <<
"Dispatcher '" << dispatcherPair.first
139 <<
"' number of metrics for slow controls: " << numberOfDispatcherMetricParameters << __E__;
143 catch(
const std::runtime_error& e)
145 __COUT_ERR__ <<
"Ignoring Dispatcher error: " << e.what() << __E__;
150 return numberOfDispatcherMetricParameters;
155 std::string ARTDAQDispatcherTable::setFilePath()
const {
return SLOWCONTROL_PV_FILE_PATH; }