list_apps.cxx File Reference

#include "logging/Logging.hpp"
#include "conffwk/Configuration.hpp"
#include "confmodel/DaqApplication.hpp"
#include "confmodel/DaqModule.hpp"
#include "confmodel/ResourceSet.hpp"
#include "confmodel/Segment.hpp"
#include "confmodel/Session.hpp"
#include <iostream>
#include <string>

Include dependency graph for list_apps.cxx:

Go to the source code of this file.

Functions
void	process_segment (const Session *session, const Segment *segment, const std::set< std::string > &disabled_objects, std::string spacer)
int	main (int argc, char *argv[])

Function Documentation

main()

int main	(	int	argc,
		char *	argv[] )

Definition at line 81 of file list_apps.cxx.

                                 {
 
  if (argc < 2) {
    std::cout << "Usage: " << argv[0] << " [session] database-file\n";
    return 0;
  }
 
  int filearg = 1;
  if (argc == 3) {
    filearg = 2;
  }
  std::string confimpl = "oksconflibs:" + std::string(argv[filearg]);
  auto confdb = new conffwk::Configuration(confimpl);
 
  std::vector<std::string> sessionList;
  if (argc == 3) {
    sessionList.emplace_back(std::string(argv[1]));
  }
  else {
    std::vector<conffwk::ConfigObject> session_obj;
    confdb->get("Session", session_obj);
    if (session_obj.size() == 0) {
      std::cerr << "Can't find any Sessions in database\n";
      return -1;
    }
    for (auto obj : session_obj) {
      sessionList.push_back(obj.UID());
    }
  }
  dunedaq::logging::Logging::setup(sessionList[0], "list-apps"
  );
 
  std::string separator{};
  for (const auto& sessionName : sessionList) {
    const Session* session;
    session = confdb->get<Session>(sessionName);
    if (session==nullptr) {
      std::cerr << "Session " << sessionName << " not found in database\n";
      return -1;
    }
 
    std::cout << separator << "      Applications in Session: "
              << sessionName << "\n";
    std::set<std::string> disabled_objects;
    for (auto object : session->get_disabled()) {
      TLOG_DEBUG(11) << object->UID() << " is in disabled list of Session";
      disabled_objects.insert(object->UID());
    }
 
    process_segment (session, session->get_segment(),
                     disabled_objects,
                     "");
    separator =
      "\n   ----------------------------------------------\n\n";
  }
  delete confdb;
}

process_segment()

void process_segment	(	const Session *	session,
		const Segment *	segment,
		const std::set< std::string > &	disabled_objects,
		std::string	spacer )

Definition at line 19 of file list_apps.cxx.

                                       {
  std::cout << spacer << "Segment " << segment->UID();
  bool segment_disabled = segment->is_disabled(*session);
  std::string reason = "";
  if (segment_disabled) {
    std::cout << " disabled";
    reason = "segment";
  }
  std::cout << "\n";
  for (auto subseg : segment->get_segments()) {
    process_segment (session, subseg, disabled_objects, spacer+"  ");
  }
 
  for (auto app : segment->get_applications()) {
    bool disabled = segment_disabled;
    std::cout << spacer << "  Application: " << app->UID();
    if (!disabled) {
      auto rset = app->cast<ResourceSet>();
      if (rset) {
        if (rset->is_disabled(*session)) {
          disabled = true;
          if (disabled_objects.find(app->UID()) != disabled_objects.end()) {
            reason = "directly";
          }
          else {
            reason = "due to state of related objects";
          }
        }
        std::cout << " contains: {";
        std::string seperator = "";
        for (auto mod : rset->contained_resources()) {
          std::cout << seperator << mod->UID();
          if (mod->is_disabled(*session)) {
            std::cout << "<disabled ";
            if (disabled_objects.find(mod->UID()) == disabled_objects.end()) {
              std::cout << "in";
            }
            std::cout << "directly>";
          }
          seperator = ", ";
        }
        std::cout << "}";
      }
    }
    if (disabled) {
      std::cout << " <disabled "<< reason << ">";
    }
    auto daqApp = app->cast<DaqApplication>();
    if (daqApp) {
      std::cout << " Modules:";
      for (auto mod : daqApp->get_modules()) {
        std::cout << " " << mod->UID();
      }
    }
 
    std::cout << std::endl;
  }
}