otsdaq  3.04.02
SupervisorInfo.h
1 #ifndef _ots_SupervisorInfo_h_
2 #define _ots_SupervisorInfo_h_
3 
4 #include <algorithm>
5 #include <string>
6 #include "otsdaq/Macros/CoutMacros.h" /* also for XDAQ_CONST_CALL */
7 #include "otsdaq/TablePlugins/XDAQContextTable/XDAQContextTable.h"
8 
9 #pragma GCC diagnostic push
10 #pragma GCC diagnostic ignored "-Wunused-parameter"
11 #pragma GCC diagnostic ignored "-Wdeprecated-declarations"
12 #if __GNUC__ >= 8
13 #pragma GCC diagnostic ignored "-Wcatch-value"
14 #endif
15 #if __GNUC__ >= 9
16 #pragma GCC diagnostic ignored "-Wdeprecated-copy"
17 #endif
18 #include <xdaq/Application.h>
19 #pragma GCC diagnostic pop
20 #include "otsdaq/Macros/XDAQApplicationMacros.h"
21 
22 // clang-format off
23 namespace ots
24 {
25 class SupervisorInfo
26 {
27  public:
30  SupervisorInfo(XDAQ_CONST_CALL xdaq::ApplicationDescriptor* descriptor, const std::string& name, const std::string& contextName)
31  : descriptor_(descriptor)
32  , contextDescriptor_(descriptor ? descriptor->getContextDescriptor() : 0)
33  , name_(name)
34  , mfSubject_(name_)
35  , contextName_(contextName)
36  , id_(descriptor ? descriptor->getLocalId() : 0)
37  , class_(descriptor ? descriptor->getClassName() : "")
38  , contextURL_(contextDescriptor_ ? contextDescriptor_->getURL() : "")
39  , hostname_(SupervisorInfo::extractHostname(contextURL_))
40  , URN_(descriptor ? descriptor->getURN() : "")
41  , URL_(contextURL_ + "/" + URN_)
42  , port_(0)
43  , status_(SupervisorInfo::APP_STATUS_UNKNOWN)
44  {
45  // when no configuration, e.g. Wizard Mode, then
46  // name and contextName are derived from the class name and LID
47  if(name_ == "")
48  name_ = "LID-" + std::to_string(id_);
49  if(contextName_ == "")
50  contextName_ = class_;
51  } //end constructor
52 
53  ~SupervisorInfo(void) { ; }
54 
55 
56  struct SubappInfo {
57  std::string name;
58  std::string status;
59  unsigned int progress, id;
60  std::string detail;
61  int64_t availableLogSpaceKB = 0, availableDataSpaceKB = 0;
62  float logUsageRateKBps = 0, dataUsageRateKBps = 0;
63  time_t lastStatusTime;
64  std::string url, parent_url;
65  std::string class_name;
66  std::deque<std::pair<time_t, int64_t>> availableLogSpaceKB_, availableDataSpaceKB_; //keep time series of last, 3.75 minutes, 7.5, 15, 30, 60 minutes to monitor rate trends
67  }; // end SubappInfo struct
68 
69  static const std::string APP_STATUS_UNKNOWN;
70  static const std::string APP_STATUS_NOT_MONITORED;
71 
73  bool isGatewaySupervisor (void) const { return class_ == XDAQContextTable::GATEWAY_SUPERVISOR_CLASS; }
74  bool isWizardSupervisor (void) const { return class_ == XDAQContextTable::WIZARD_SUPERVISOR_CLASS; }
75  bool isTypeFESupervisor (void) const { return XDAQContextTable::FETypeClassNames_.find(class_) != XDAQContextTable::FETypeClassNames_.end(); }
76  bool isTypeDMSupervisor (void) const { return XDAQContextTable::DMTypeClassNames_.find(class_) != XDAQContextTable::DMTypeClassNames_.end(); }
77  bool isTypeLogbookSupervisor (void) const { return XDAQContextTable::LogbookTypeClassNames_.find(class_) != XDAQContextTable::LogbookTypeClassNames_.end(); }
78  bool isTypeMacroMakerSupervisor (void) const { return XDAQContextTable::MacroMakerTypeClassNames_.find(class_) != XDAQContextTable::MacroMakerTypeClassNames_.end(); }
79  bool isTypeConfigurationGUISupervisor (void) const { return XDAQContextTable::ConfigurationGUITypeClassNames_.find(class_) != XDAQContextTable::ConfigurationGUITypeClassNames_.end(); }
80  bool isTypeChatSupervisor (void) const { return XDAQContextTable::ChatTypeClassNames_.find(class_) != XDAQContextTable::ChatTypeClassNames_.end(); }
81  bool isTypeConsoleSupervisor (void) const { return XDAQContextTable::ConsoleTypeClassNames_.find(class_) != XDAQContextTable::ConsoleTypeClassNames_.end(); }
82  bool isTypeCodeEditorSupervisor (void) const { return XDAQContextTable::CodeEditorTypeClassNames_.find(class_) != XDAQContextTable::CodeEditorTypeClassNames_.end(); }
83  bool isTypeARTDAQSupervisor (void) const { return class_ == XDAQContextTable::ARTDAQ_SUPERVISOR_CLASS; }
84 
86  XDAQ_CONST_CALL xdaq::ApplicationDescriptor* getDescriptor (void) const { return descriptor_; }
87  const xdaq::ContextDescriptor* getContextDescriptor (void) const { return contextDescriptor_; }
88  const std::string& getName (void) const { return name_; }
89  const std::string& getHostname (void) const { return hostname_; }
90  const std::string& getContextName (void) const { return contextName_; }
91  const unsigned int& getId (void) const { return id_; }
92  const std::string& getClass (void) const { return class_; }
93 
95  const std::string& getStatus (void) const { return status_; }
96  time_t getLastStatusTime (void) const { return lastStatusTime_; }
97  const unsigned int& getProgress (void) const { return progress_; }
98  const std::string& getDetail (void) const { return detail_; }
99 
100  const std::string& getURL (void) const { return contextURL_; }
101  const std::string& getURN (void) const { return URN_; }
102  const std::string& getFullURL (void) const { return URL_; }
103  const uint16_t& getPort (void) const { return port_; }
104  const std::map<std::string, SubappInfo>& getSubappInfo (void) const { return subapps_; }
105 
106 
107  int64_t getAvailableLogSpaceKB (void) const { return availableLogSpaceKB_.size() > 0 ? availableLogSpaceKB_.front().second : 0; }
108  int64_t getAvailableDataSpaceKB (void) const { return availableDataSpaceKB_.size() > 0 ? availableDataSpaceKB_.front().second : 0; }
109 
110  float getLogUsageRateLastHourKBps (void) const { return availableLogSpaceKB_.size() > 9 ? (availableLogSpaceKB_[9].second - availableLogSpaceKB_.front().second)*1.0f/
111  std::max(static_cast<time_t>(1), availableLogSpaceKB_.front().first - availableLogSpaceKB_[9].first) : 0; }
112  float getLogUsageRateLastHalfHourKBps (void) const { return availableLogSpaceKB_.size() > 7 ? (availableLogSpaceKB_[7].second - availableLogSpaceKB_.front().second)*1.0f/
113  std::max(static_cast<time_t>(1), availableLogSpaceKB_.front().first - availableLogSpaceKB_[7].first): 0; }
114  float getLogUsageRateLastQuarterHourKBps (void) const { return availableLogSpaceKB_.size() > 5 ? (availableLogSpaceKB_[5].second - availableLogSpaceKB_.front().second)*1.0f/
115  std::max(static_cast<time_t>(1), availableLogSpaceKB_.front().first - availableLogSpaceKB_[5].first): 0; }
116  float getLogUsageRateNowKBps (void) const { return availableLogSpaceKB_.size() > 1 ? (availableLogSpaceKB_[1].second - availableLogSpaceKB_.front().second)*1.0f/
117  std::max(static_cast<time_t>(1), availableLogSpaceKB_.front().first - availableLogSpaceKB_[1].first) : 0; }
118  float getDataUsageRateLastHourKBps (void) const { return availableDataSpaceKB_.size() > 9 ? (availableDataSpaceKB_[9].second - availableDataSpaceKB_.front().second)*1.0f/
119  std::max(static_cast<time_t>(1), availableDataSpaceKB_.front().first - availableDataSpaceKB_[9].first) : 0; }
120  float getDataUsageRateLastHalfHourKBps (void) const { return availableDataSpaceKB_.size() > 7 ? (availableDataSpaceKB_[7].second - availableDataSpaceKB_.front().second)*1.0f/
121  std::max(static_cast<time_t>(1), availableDataSpaceKB_.front().first - availableDataSpaceKB_[7].first): 0; }
122  float getDataUsageRateLastQuarterHourKBps(void) const { return availableDataSpaceKB_.size() > 5 ? (availableDataSpaceKB_[5].second - availableDataSpaceKB_.front().second)*1.0f/
123  std::max(static_cast<time_t>(1), availableDataSpaceKB_.front().first - availableDataSpaceKB_[5].first): 0; }
124  float getDataUsageRateNowKBps (void) const { return availableDataSpaceKB_.size() > 1 ? (availableDataSpaceKB_[1].second - availableDataSpaceKB_.front().second)*1.0f/
125  std::max(static_cast<time_t>(1), availableDataSpaceKB_.front().first - availableDataSpaceKB_[1].first) : 0; }
127  void setStatus(const std::string& status, const unsigned int progress, const std::string& detail = "", const int64_t availableLogSpaceKB = 0, const int64_t availableDataSpaceKB = 0);
128  void setSubappStatus(const std::string& name, const std::string& status, const unsigned int progress, const std::string& detail = "", const int64_t availableLogSpaceKB = 0, const int64_t availableDataSpaceKB = 0);
129  void copySubappStatus(const SubappInfo& info);
130  void clearSubapps() { subapps_.clear(); };
131 
132  static std::string serializeSubappInfos(std::vector<SubappInfo> infos);
133  static std::vector<SubappInfo> deserializeSubappInfos(std::string info_string);
134 
135  private:
137  static std::string extractHostname (const std::string& URL);
138  void emplaceAvailableSpace (const int64_t availableSpaceKB, std::deque<std::pair<time_t, int64_t>>& availableSpaceDeque);
139 
140 
141  XDAQ_CONST_CALL xdaq::ApplicationDescriptor* descriptor_;
142  XDAQ_CONST_CALL xdaq::ContextDescriptor* contextDescriptor_;
143  std::string name_, mfSubject_;
144  std::string contextName_;
145  unsigned int id_;
146  std::string class_;
147  std::string contextURL_;
148  std::string hostname_;
149  std::string URN_;
150  std::string URL_;
151  uint16_t port_;
152  std::string status_;
153  unsigned int progress_;
154  std::string detail_;
155  time_t lastStatusTime_;
156  std::map<std::string, SubappInfo> subapps_;
157  std::deque<std::pair<time_t, int64_t>> availableLogSpaceKB_, availableDataSpaceKB_; //keep time series of last, 3.75 minutes, 7.5, 15, 30, 60 minutes to monitor rate trends
158 };
159 // clang-format on
160 } // namespace ots
161 
162 #endif
ots::SupervisorInfo::isGatewaySupervisor
bool isGatewaySupervisor(void) const
BOOLs ----------------—.
Definition: SupervisorInfo.h:73
ots::SupervisorInfo::getDescriptor
XDAQ_CONST_CALL xdaq::ApplicationDescriptor * getDescriptor(void) const
Getters ----------------—.
Definition: SupervisorInfo.h:86
ots::SupervisorInfo::getStatus
const std::string & getStatus(void) const
Note: be careful accessing status_ in multithreaded code (need higher level lock, a la getSupervisorI...
Definition: SupervisorInfo.h:95
ots::SupervisorInfo::SupervisorInfo
SupervisorInfo(XDAQ_CONST_CALL xdaq::ApplicationDescriptor *descriptor, const std::string &name, const std::string &contextName)
Definition: SupervisorInfo.h:30
ots::SupervisorInfo::setStatus
void setStatus(const std::string &status, const unsigned int progress, const std::string &detail="", const int64_t availableLogSpaceKB=0, const int64_t availableDataSpaceKB=0)
Setters ----------------—.
Definition: SupervisorInfo.cc:9
ots
defines used also by OtsConfigurationWizardSupervisor
Definition: ArtdaqOtsBuildInfo_module.cc:10
ots::SupervisorInfo::SubappInfo::name
std::string name
Also key in map.
Definition: SupervisorInfo.h:57