1 #include "otsdaq/Macros/TablePluginMacros.h"
2 #include "otsdaq/TablePlugins/ARTDAQDispatcherTable.h"
8 #define SLOWCONTROL_PV_FILE_PATH \
10 getenv("OTSDAQ_EPICS_DATA")? \
11 (std::string(getenv("OTSDAQ_EPICS_DATA")) + "/" + __ENV__("MU2E_OWNER") + "_otsdaq_artdaqDispatcher-ai.dbg"): \
12 (EPICS_CONFIG_PATH + "/_otsdaq_artdaqDispatcher-ai.dbg") )
17 ARTDAQDispatcherTable::ARTDAQDispatcherTable(
void)
26 __COUT__ <<
"ARTDAQDispatcherTable Constructed." << __E__;
30 ARTDAQDispatcherTable::~ARTDAQDispatcherTable(
void) {}
35 lastConfigManager_ = configManager;
48 __COUT_INFO__ <<
"ARTDAQ Supervisor is disabled, so skipping fcl handling."
54 mkdir((ARTDAQTableBase::ARTDAQ_FCL_PATH).c_str(), 0755);
61 auto dispatchers = lastConfigManager_->__SELF_NODE__.
getChildren(
62 std::map<std::string ,
67 for(
auto& dispatcher : dispatchers)
70 dispatcher.second, ARTDAQTableBase::ARTDAQAppType::Dispatcher);
71 ARTDAQTableBase::flattenFHICL(ARTDAQAppType::Dispatcher,
72 dispatcher.second.getValue());
78 unsigned int ARTDAQDispatcherTable::slowControlsHandlerConfig(
79 std::stringstream& out,
81 std::vector<std::pair<std::string , std::vector<std::string>>>*
88 std::string tabStr =
"";
89 std::string commentStr =
"";
92 std::vector<std::pair<std::string, ConfigurationTree>> artdaqRecords =
95 unsigned int numberOfDispatcherMetricParameters = 0;
97 for(
auto& artdaqPair : artdaqRecords)
99 if(artdaqPair.second.getNode(colARTDAQSupervisor_.colLinkToDispatchers_)
103 std::vector<std::pair<std::string, ConfigurationTree>> dispatcherRecords =
104 artdaqPair.second.getNode(colARTDAQSupervisor_.colLinkToDispatchers_)
107 for(
auto& dispatcherPair :
110 if(!dispatcherPair.second.status())
115 if(dispatcherPair.second.getNode(
"daqLink").isDisconnected())
118 auto daqLink = dispatcherPair.second.getNode(
"daqLink");
120 if(daqLink.getNode(
"daqMetricsLink").isDisconnected())
123 auto daqMetricsLinks = daqLink.getNode(
"daqMetricsLink").getChildren();
124 for(
auto& daqMetricsLink :
127 if(!daqMetricsLink.second.status())
130 if(daqMetricsLink.second.getNode(
"metricParametersLink")
136 dispatcherPair.second.
getNode(
"MetricAlarmThresholdsLink");
138 auto metricParametersLinks =
139 daqMetricsLink.second.
getNode(
"metricParametersLink")
141 for(
auto& metricParametersLink :
142 metricParametersLinks)
144 if(!metricParametersLink.second.status())
147 std::string subsystem =
148 metricParametersLink.second.getNode(
"metricParameterValue")
149 .getValueWithDefault<std::string>(std::string(
"TDAQ_") +
150 __ENV__(
"MU2E_OWNER"));
151 if(subsystem.find(
"Mu2e:") != std::string::npos)
152 subsystem = subsystem.replace(subsystem.find(
"Mu2e:"), 5,
"");
153 while(subsystem.find(
"\"") != std::string::npos)
154 subsystem = subsystem.replace(subsystem.find(
"\""), 1,
"");
156 numberOfDispatcherMetricParameters =
157 slowControlsHandler(out,
161 dispatcherPair.first,
165 __COUT__ <<
"Dispatcher '" << dispatcherPair.first
166 <<
"' number of metrics for slow controls: "
167 << numberOfDispatcherMetricParameters << __E__;
171 catch(
const std::runtime_error& e)
173 __COUT_ERR__ <<
"Ignoring Dispatcher error: " << e.what() << __E__;
178 return numberOfDispatcherMetricParameters;
185 return SLOWCONTROL_PV_FILE_PATH;
virtual std::string setFilePath() const override
return out file path
void init(ConfigurationManager *configManager) override
Methods.
<virtual so future plugins can inherit from multiple table base classes
static bool isARTDAQEnabled(const ConfigurationManager *cfgMgr)
isARTDAQEnabled
static void outputDataReceiverFHICL(const ConfigurationTree &receiverNode, ARTDAQAppType appType, size_t maxFragmentSizeBytes=DEFAULT_MAX_FRAGMENT_SIZE, size_t routingTimeoutMs=DEFAULT_ROUTING_TIMEOUT_MS, size_t routingRetryCount=DEFAULT_ROUTING_RETRY_COUNT)
ConfigurationTree getNode(const std::string &nodeString, bool doNotThrowOnBrokenUIDLinks=false) const
"root/parent/parent/"
std::vector< std::pair< std::string, ConfigurationTree > > getChildren(std::map< std::string, TableVersion > *memberMap=0, std::string *accumulatedTreeErrors=0) const
ConfigurationTree getNode(const std::string &nodeName, bool doNotThrowOnBrokenUIDLinks=false) const
navigating between nodes
std::vector< std::pair< std::string, ConfigurationTree > > getChildren(std::map< std::string, std::string > filterMap=std::map< std::string, std::string >(), bool byPriority=false, bool onlyStatusTrue=false) const
<virtual so future plugins can inherit from multiple table base classes
bool isFirstAppInContext_
for managing if PV list has changed