From 904c88677af83e9148222324d04eec0868d72591 Mon Sep 17 00:00:00 2001 From: Adam Wegrzynek Date: Tue, 8 Jan 2019 11:03:50 +0100 Subject: [PATCH] Drop TObject2Json in favour of nodejs extenstion (#106) * Make TObject2Json a library * Drop TObject2Json * Add retrieveJson method to database interface * Update docs --- Framework/CMakeLists.txt | 16 +- .../include/QualityControl/CcdbDatabase.h | 1 + .../QualityControl/DatabaseInterface.h | 5 + .../include/QualityControl/MySqlDatabase.h | 1 + Framework/src/CcdbDatabase.cxx | 13 + Framework/src/MySqlDatabase.cxx | 13 + Framework/src/tobject2json/TObject2Json.cxx | 56 - .../src/tobject2json/TObject2JsonBackend.h | 47 - .../TObject2JsonBackendFactory.cxx | 72 -- .../tobject2json/TObject2JsonBackendFactory.h | 50 - .../src/tobject2json/TObject2JsonCcdb.cxx | 61 - Framework/src/tobject2json/TObject2JsonCcdb.h | 56 - .../src/tobject2json/TObject2JsonMySql.cxx | 62 - .../src/tobject2json/TObject2JsonMySql.h | 56 - .../src/tobject2json/TObject2JsonServer.cxx | 87 -- .../src/tobject2json/TObject2JsonServer.h | 61 - .../src/tobject2json/TObject2JsonWorker.cxx | 170 --- .../src/tobject2json/TObject2JsonWorker.h | 79 -- Framework/src/tobject2json/UriParser.h | 106 -- Framework/src/tobject2json/zmq.h | 1079 ----------------- README.md | 49 - 21 files changed, 34 insertions(+), 2106 deletions(-) delete mode 100644 Framework/src/tobject2json/TObject2Json.cxx delete mode 100644 Framework/src/tobject2json/TObject2JsonBackend.h delete mode 100644 Framework/src/tobject2json/TObject2JsonBackendFactory.cxx delete mode 100644 Framework/src/tobject2json/TObject2JsonBackendFactory.h delete mode 100644 Framework/src/tobject2json/TObject2JsonCcdb.cxx delete mode 100644 Framework/src/tobject2json/TObject2JsonCcdb.h delete mode 100644 Framework/src/tobject2json/TObject2JsonMySql.cxx delete mode 100644 Framework/src/tobject2json/TObject2JsonMySql.h delete mode 100644 Framework/src/tobject2json/TObject2JsonServer.cxx delete mode 100644 Framework/src/tobject2json/TObject2JsonServer.h delete mode 100644 Framework/src/tobject2json/TObject2JsonWorker.cxx delete mode 100644 Framework/src/tobject2json/TObject2JsonWorker.h delete mode 100644 Framework/src/tobject2json/UriParser.h delete mode 100644 Framework/src/tobject2json/zmq.h diff --git a/Framework/CMakeLists.txt b/Framework/CMakeLists.txt index a9e6a67027..8817e9b377 100644 --- a/Framework/CMakeLists.txt +++ b/Framework/CMakeLists.txt @@ -35,18 +35,8 @@ set( include/QualityControl/InfrastructureGenerator.h ) -set( - SRCS_TOBJECT2JSON - src/tobject2json/TObject2Json.cxx - src/tobject2json/TObject2JsonServer.cxx - src/tobject2json/TObject2JsonWorker.cxx - src/tobject2json/TObject2JsonBackendFactory.cxx - src/tobject2json/TObject2JsonCcdb.cxx -) - if(ENABLE_MYSQL) list(APPEND SRCS src/MySqlDatabase.cxx) - list(APPEND SRCS_TOBJECT2JSON src/tobject2json/TObject2JsonMySql.cxx) endif() # Produce the final Version.h using template Version.h.in and substituting variables. We don't want to polute our source @@ -168,10 +158,6 @@ foreach(i RANGE ${count}) target_link_libraries(${name} PRIVATE QualityControl) endforeach() -# tobject2json -add_executable(tobject2json ${SRCS_TOBJECT2JSON}) -target_link_libraries(tobject2json PRIVATE QualityControl ZeroMQ::ZeroMQ $<$:MySQL::MySQL>) - # ---- Gui ---- set(DATADUMP "") @@ -243,7 +229,7 @@ unset(isSystemDir) # Install library and binaries install( - TARGETS QualityControl ${EXE_NAMES} tobject2json ${DATADUMP} + TARGETS QualityControl ${EXE_NAMES} ${DATADUMP} EXPORT QualityControlTargets LIBRARY DESTINATION ${CMAKE_INSTALL_LIBDIR} ARCHIVE DESTINATION ${CMAKE_INSTALL_LIBDIR} diff --git a/Framework/include/QualityControl/CcdbDatabase.h b/Framework/include/QualityControl/CcdbDatabase.h index ea8e600f8e..86c44d77c8 100644 --- a/Framework/include/QualityControl/CcdbDatabase.h +++ b/Framework/include/QualityControl/CcdbDatabase.h @@ -61,6 +61,7 @@ class CcdbDatabase : public DatabaseInterface void connect(const std::unordered_map& config) override; void store(std::shared_ptr mo) override; core::MonitorObject* retrieve(std::string taskName, std::string objectName) override; + std::string retrieveJson(std::string taskName, std::string objectName) override; void disconnect() override; void prepareTaskDataContainer(std::string taskName) override; std::vector getListOfTasksWithPublications() override; diff --git a/Framework/include/QualityControl/DatabaseInterface.h b/Framework/include/QualityControl/DatabaseInterface.h index f61d89c72a..b2b63cfad4 100644 --- a/Framework/include/QualityControl/DatabaseInterface.h +++ b/Framework/include/QualityControl/DatabaseInterface.h @@ -60,6 +60,11 @@ class DatabaseInterface * TODO evaluate whether we should have a method to retrieve a list of objects (optimization) */ virtual o2::quality_control::core::MonitorObject* retrieve(std::string taskName, std::string objectName) = 0; + + /** + * Returns JSON encoded object + */ + virtual std::string retrieveJson(std::string taskName, std::string objectName) = 0; virtual void disconnect() = 0; /** * \brief Prepare the container, such as a table in a relational database, that will contain the MonitorObject's for diff --git a/Framework/include/QualityControl/MySqlDatabase.h b/Framework/include/QualityControl/MySqlDatabase.h index ec56b75eb1..c60aef2b58 100644 --- a/Framework/include/QualityControl/MySqlDatabase.h +++ b/Framework/include/QualityControl/MySqlDatabase.h @@ -34,6 +34,7 @@ class MySqlDatabase : public DatabaseInterface void connect(const std::unordered_map& config) override; void store(std::shared_ptr mo) override; o2::quality_control::core::MonitorObject* retrieve(std::string taskName, std::string objectName) override; + std::string retrieveJson(std::string taskName, std::string objectName) override; void disconnect() override; std::vector getPublishedObjectNames(std::string taskName) override; std::vector getListOfTasksWithPublications() override; diff --git a/Framework/src/CcdbDatabase.cxx b/Framework/src/CcdbDatabase.cxx index e57d3f0590..7dabd7b352 100644 --- a/Framework/src/CcdbDatabase.cxx +++ b/Framework/src/CcdbDatabase.cxx @@ -18,6 +18,7 @@ #include #include #include +#include "TBufferJSON.h" using namespace std::chrono; using namespace AliceO2::Common; @@ -82,6 +83,18 @@ core::MonitorObject* CcdbDatabase::retrieve(std::string taskName, std::string ob return dynamic_cast(object); } +std::string CcdbDatabase::retrieveJson(std::string taskName, std::string objectName) +{ + std::unique_ptr monitor(retrieve(taskName, objectName)); + if (monitor == nullptr) { + return std::string(); + } + std::unique_ptr obj(monitor->getObject()); + monitor->setIsOwner(false); + TString json = TBufferJSON::ConvertToJSON(obj.get()); + return json.Data(); +} + void CcdbDatabase::disconnect() { /* we're done with libcurl, so clean it up */ diff --git a/Framework/src/MySqlDatabase.cxx b/Framework/src/MySqlDatabase.cxx index f6e287cfe2..7170b71c6a 100644 --- a/Framework/src/MySqlDatabase.cxx +++ b/Framework/src/MySqlDatabase.cxx @@ -10,6 +10,7 @@ #include "TMySQLResult.h" #include "TMySQLRow.h" #include "TMySQLStatement.h" +#include "TBufferJSON.h" // O2 #include "Common/Exceptions.h" // QC @@ -207,6 +208,18 @@ o2::quality_control::core::MonitorObject* MySqlDatabase::retrieve(std::string ta return mo; } +std::string MySqlDatabase::retrieveJson(std::string taskName, std::string objectName) +{ + std::unique_ptr monitor(retrieve(taskName, objectName)); + if (monitor == nullptr) { + return std::string(); + } + std::unique_ptr obj(monitor->getObject()); + monitor->setIsOwner(false); + TString json = TBufferJSON::ConvertToJSON(obj.get()); + return json.Data(); +} + void MySqlDatabase::disconnect() { storeQueue(); diff --git a/Framework/src/tobject2json/TObject2Json.cxx b/Framework/src/tobject2json/TObject2Json.cxx deleted file mode 100644 index 478c28ab34..0000000000 --- a/Framework/src/tobject2json/TObject2Json.cxx +++ /dev/null @@ -1,56 +0,0 @@ -// Copyright CERN and copyright holders of ALICE O2. This software is -// distributed under the terms of the GNU General Public License v3 (GPL -// Version 3), copied verbatim in the file "COPYING". -// -// See http://alice-o2.web.cern.ch/license for full licensing information. -// -// In applying this license CERN does not waive the privileges and immunities -// granted to it by virtue of its status as an Intergovernmental Organization -// or submit itself to any jurisdiction. - -/// -/// \file TObject2Json.cxx -/// \author Adam Wegrzynek -/// \author Vladimir Kosmala -/// - -// TObject2Json -#include "TObject2JsonServer.h" -#include -#include - -using o2::quality_control::tobject_to_json::TObject2JsonServer; - -int main(int argc, char* argv[]) -{ - boost::program_options::variables_map vm; - boost::program_options::options_description desc("Allowed options"); - desc.add_options()("backend", boost::program_options::value()->required(), - "Backend URL, eg.: mysql://:@:/")( - "zeromq-server", boost::program_options::value()->required(), - "ZeroMQ server endpoint, eg.: tcp://:")("workers", boost::program_options::value(), - "Number of worker threads, eg.: 8"); - try { - boost::program_options::store(boost::program_options::parse_command_line(argc, argv, desc), vm); - boost::program_options::notify(vm); - } catch (...) { - std::cout << desc << std::endl; - return 1; - } - std::string backend = vm["backend"].as(); - std::string zeromq = vm["zeromq-server"].as(); - int workers = 8; - if (vm.count("workers")) { - workers = vm["workers"].as(); - } - - TObject2JsonServer server; - try { - server.start(backend, zeromq, workers); - } catch (const std::exception& error) { - std::cout << error.what() << std::endl; - return 2; - } - - return 0; -} diff --git a/Framework/src/tobject2json/TObject2JsonBackend.h b/Framework/src/tobject2json/TObject2JsonBackend.h deleted file mode 100644 index 983233e8bf..0000000000 --- a/Framework/src/tobject2json/TObject2JsonBackend.h +++ /dev/null @@ -1,47 +0,0 @@ -// Copyright CERN and copyright holders of ALICE O2. This software is -// distributed under the terms of the GNU General Public License v3 (GPL -// Version 3), copied verbatim in the file "COPYING". -// -// See http://alice-o2.web.cern.ch/license for full licensing information. -// -// In applying this license CERN does not waive the privileges and immunities -// granted to it by virtue of its status as an Intergovernmental Organization -// or submit itself to any jurisdiction. - -/// -/// \file Backend.h -/// \author Vladimir Kosmala -/// \author Adam Wegrzynek -/// - -#ifndef QC_TOBJECT2JSON_BACKEND_H -#define QC_TOBJECT2JSON_BACKEND_H - -#include - -namespace o2 -{ -namespace quality_control -{ -namespace tobject_to_json -{ - -/// \brief Converts ROOT objects into JSON format which is readable by JSROOT -class Backend -{ - public: - /// Default constructor - Backend() = default; - - /// Default destructor - virtual ~Backend() = default; - - /// Gets TObject from database and returns the JSON equivalent - virtual std::string getJsonObject(std::string agentName, std::string objectName) = 0; -}; - -} // namespace tobject_to_json -} // namespace quality_control -} // namespace o2 - -#endif // QC_TOBJECT2JSON_BACKEND_H diff --git a/Framework/src/tobject2json/TObject2JsonBackendFactory.cxx b/Framework/src/tobject2json/TObject2JsonBackendFactory.cxx deleted file mode 100644 index fe63fd39f8..0000000000 --- a/Framework/src/tobject2json/TObject2JsonBackendFactory.cxx +++ /dev/null @@ -1,72 +0,0 @@ -// Copyright CERN and copyright holders of ALICE O2. This software is -// distributed under the terms of the GNU General Public License v3 (GPL -// Version 3), copied verbatim in the file "COPYING". -// -// See http://alice-o2.web.cern.ch/license for full licensing information. -// -// In applying this license CERN does not waive the privileges and immunities -// granted to it by virtue of its status as an Intergovernmental Organization -// or submit itself to any jurisdiction. - -/// -/// \file TObject2JsonBackendFactory.cxx -/// \author Adam Wegrzynek -/// - -#include "TObject2JsonBackendFactory.h" -#include "TObject2JsonServer.h" -#ifdef _WITH_MYSQL -#include "TObject2JsonMySql.h" -#endif -#include "TObject2JsonCcdb.h" -#include "UriParser.h" - -#include - -namespace o2 -{ -namespace quality_control -{ -namespace tobject_to_json -{ - -#ifdef _WITH_MYSQL -auto getMySql(const http::url& uri) -{ - int port = (uri.port == 0) ? 3306 : uri.port; - std::string database = uri.path; - database.erase(database.begin(), database.begin() + 1); - return std::make_unique(uri.host, port, database, uri.user, uri.password); -} -#endif - -auto getCcdb(const http::url& uri) -{ - int port = (uri.port == 0) ? 3306 : uri.port; - return std::make_unique(uri.host, port, "", uri.user, uri.password); -} - -std::unique_ptr TObject2JsonBackendFactory::Get(std::string url) -{ - static const std::map(const http::url&)>> map = { -#ifdef _WITH_MYSQL - { "mysql", getMySql }, -#endif - { "ccdb", getCcdb } - }; - - http::url parsedUrl = http::ParseHttpUrl(url); - if (parsedUrl.protocol.empty()) { - throw std::runtime_error("Ill-formed URI"); - } - auto iterator = map.find(parsedUrl.protocol); - if (iterator != map.end()) { - return iterator->second(parsedUrl); - } else { - throw std::runtime_error("Unrecognized backend " + parsedUrl.protocol); - } -} - -} // namespace tobject_to_json -} // namespace quality_control -} // namespace o2 diff --git a/Framework/src/tobject2json/TObject2JsonBackendFactory.h b/Framework/src/tobject2json/TObject2JsonBackendFactory.h deleted file mode 100644 index b1eb2099ec..0000000000 --- a/Framework/src/tobject2json/TObject2JsonBackendFactory.h +++ /dev/null @@ -1,50 +0,0 @@ -// Copyright CERN and copyright holders of ALICE O2. This software is -// distributed under the terms of the GNU General Public License v3 (GPL -// Version 3), copied verbatim in the file "COPYING". -// -// See http://alice-o2.web.cern.ch/license for full licensing information. -// -// In applying this license CERN does not waive the privileges and immunities -// granted to it by virtue of its status as an Intergovernmental Organization -// or submit itself to any jurisdiction. - -/// -/// \file TObject2JsonBackendFactory.h -/// \author Adam Wegrzynek -/// \author Vladimir Kosmala -/// - -#ifndef QC_TOBJECT2JSON_BACKENDFACTORY_H -#define QC_TOBJECT2JSON_BACKENDFACTORY_H - -#include "TObject2JsonBackend.h" -#include "TObject2JsonServer.h" - -namespace o2 -{ -namespace quality_control -{ -namespace tobject_to_json -{ - -/// Creates a backend instance -class TObject2JsonBackendFactory -{ - public: - /// Disables copy constructor - TObject2JsonBackendFactory& operator=(const TObject2JsonBackendFactory&) = delete; - TObject2JsonBackendFactory(const TObject2JsonBackendFactory&) = delete; - - /// Creates an instance of backend depending on the URL passed - static std::unique_ptr Get(std::string url); - - private: - /// Private constructor disallows to create instance of Factory - TObject2JsonBackendFactory() = default; -}; - -} // namespace tobject_to_json -} // namespace quality_control -} // namespace o2 - -#endif // QC_TOBJECT2JSON_BACKENDFACTORY_H diff --git a/Framework/src/tobject2json/TObject2JsonCcdb.cxx b/Framework/src/tobject2json/TObject2JsonCcdb.cxx deleted file mode 100644 index c8fbbe265d..0000000000 --- a/Framework/src/tobject2json/TObject2JsonCcdb.cxx +++ /dev/null @@ -1,61 +0,0 @@ -// Copyright CERN and copyright holders of ALICE O2. This software is -// distributed under the terms of the GNU General Public License v3 (GPL -// Version 3), copied verbatim in the file "COPYING". -// -// See http://alice-o2.web.cern.ch/license for full licensing information. -// -// In applying this license CERN does not waive the privileges and immunities -// granted to it by virtue of its status as an Intergovernmental Organization -// or submit itself to any jurisdiction. - -/// -/// \file TObject2JsonCcdb.cxx -/// \author Vladimir Kosmala -/// \author Adam Wegrzynek -/// - -#include "TObject2JsonCcdb.h" -// QualityControl -#include "QualityControl/MonitorObject.h" -#include "QualityControl/QcInfoLogger.h" - -// ROOT -#include "TBufferJSON.h" - -using o2::quality_control::core::MonitorObject; -using o2::quality_control::core::QcInfoLogger; -using o2::quality_control::repository::CcdbDatabase; - -namespace o2 -{ -namespace quality_control -{ -namespace tobject_to_json -{ -namespace backends -{ - -Ccdb::Ccdb(std::string host, unsigned int port, std::string database, std::string username, std::string password) -{ - host += ":" + std::to_string(port); - mCcdbClient = std::make_unique(); - mCcdbClient->connect(host, database, username, password); - QcInfoLogger::GetInstance() << "CCDB backend created: " << host << "/" << database << infologger::endm; -} - -std::string Ccdb::getJsonObject(std::string agentName, std::string objectName) -{ - std::unique_ptr monitor(mCcdbClient->retrieve(agentName, objectName)); - if (monitor == nullptr) { - return std::string(); - } - std::unique_ptr obj(monitor->getObject()); - monitor->setIsOwner(false); - TString json = TBufferJSON::ConvertToJSON(obj.get()); - return json.Data(); -} - -} // namespace backends -} // namespace tobject_to_json -} // namespace quality_control -} // namespace o2 diff --git a/Framework/src/tobject2json/TObject2JsonCcdb.h b/Framework/src/tobject2json/TObject2JsonCcdb.h deleted file mode 100644 index 6ecfa9a897..0000000000 --- a/Framework/src/tobject2json/TObject2JsonCcdb.h +++ /dev/null @@ -1,56 +0,0 @@ -// Copyright CERN and copyright holders of ALICE O2. This software is -// distributed under the terms of the GNU General Public License v3 (GPL -// Version 3), copied verbatim in the file "COPYING". -// -// See http://alice-o2.web.cern.ch/license for full licensing information. -// -// In applying this license CERN does not waive the privileges and immunities -// granted to it by virtue of its status as an Intergovernmental Organization -// or submit itself to any jurisdiction. - -/// -/// \file TObejct2JsonCcdb.h -/// \author Barthelemy von Haller -/// \author Adam Wegrzynek -/// - -#ifndef QC_TOBJECT2JSON_CCDB_H -#define QC_TOBJECT2JSON_CCDB_H - -#include "TObject2JsonBackend.h" - -// QualityControl -#include "QualityControl/CcdbDatabase.h" - -using o2::quality_control::repository::CcdbDatabase; - -namespace o2 -{ -namespace quality_control -{ -namespace tobject_to_json -{ -namespace backends -{ - -/// Takes TObject from Ccdb database and returns JSON formatted object -class Ccdb final : public Backend -{ - public: - // Connects to MySQL database - Ccdb(std::string host, unsigned int port, std::string database, std::string username, std::string password); - - /// Gets TObject from database and returns the JSON equivalent - std::string getJsonObject(std::string agentName, std::string objectName) override; - - private: - /// MySQL client instance - std::unique_ptr mCcdbClient; -}; - -} // namespace backends -} // namespace tobject_to_json -} // namespace quality_control -} // namespace o2 - -#endif // QC_TOBJECT2JSON_CCDB_H diff --git a/Framework/src/tobject2json/TObject2JsonMySql.cxx b/Framework/src/tobject2json/TObject2JsonMySql.cxx deleted file mode 100644 index f0fdf916c5..0000000000 --- a/Framework/src/tobject2json/TObject2JsonMySql.cxx +++ /dev/null @@ -1,62 +0,0 @@ -// Copyright CERN and copyright holders of ALICE O2. This software is -// distributed under the terms of the GNU General Public License v3 (GPL -// Version 3), copied verbatim in the file "COPYING". -// -// See http://alice-o2.web.cern.ch/license for full licensing information. -// -// In applying this license CERN does not waive the privileges and immunities -// granted to it by virtue of its status as an Intergovernmental Organization -// or submit itself to any jurisdiction. - -/// -/// \file MySQL.cxx -/// \author Vladimir Kosmala -/// \author Adam Wegrzynek -/// - -#include "TObject2JsonMySql.h" -// QualityControl -#include "QualityControl/MonitorObject.h" -#include "QualityControl/MySqlDatabase.h" -#include "QualityControl/QcInfoLogger.h" - -// ROOT -#include "TBufferJSON.h" - -using o2::quality_control::core::MonitorObject; -using o2::quality_control::core::QcInfoLogger; -using o2::quality_control::repository::MySqlDatabase; - -namespace o2 -{ -namespace quality_control -{ -namespace tobject_to_json -{ -namespace backends -{ - -MySql::MySql(std::string host, unsigned int port, std::string database, std::string username, std::string password) -{ - host += ":" + std::to_string(port); - mSqlClient = std::make_unique(); - mSqlClient->connect(host, database, username, password); - QcInfoLogger::GetInstance() << "MySQL backend created: " << host << "/" << database << infologger::endm; -} - -std::string MySql::getJsonObject(std::string agentName, std::string objectName) -{ - std::unique_ptr monitor(mSqlClient->retrieve(agentName, objectName)); - if (monitor == nullptr) { - return std::string(); - } - std::unique_ptr obj(monitor->getObject()); - monitor->setIsOwner(false); - TString json = TBufferJSON::ConvertToJSON(obj.get()); - return json.Data(); -} - -} // namespace backends -} // namespace tobject_to_json -} // namespace quality_control -} // namespace o2 diff --git a/Framework/src/tobject2json/TObject2JsonMySql.h b/Framework/src/tobject2json/TObject2JsonMySql.h deleted file mode 100644 index 9e65722175..0000000000 --- a/Framework/src/tobject2json/TObject2JsonMySql.h +++ /dev/null @@ -1,56 +0,0 @@ -// Copyright CERN and copyright holders of ALICE O2. This software is -// distributed under the terms of the GNU General Public License v3 (GPL -// Version 3), copied verbatim in the file "COPYING". -// -// See http://alice-o2.web.cern.ch/license for full licensing information. -// -// In applying this license CERN does not waive the privileges and immunities -// granted to it by virtue of its status as an Intergovernmental Organization -// or submit itself to any jurisdiction. - -/// -/// \file TObejct2Json.h -/// \author Vladimir Kosmala -/// \author Adam Wegrzynek -/// - -#ifndef QC_TOBJECT2JSON_MYSQL_H -#define QC_TOBJECT2JSON_MYSQL_H - -#include "TObject2JsonBackend.h" - -// QualityControl -#include "QualityControl/MySqlDatabase.h" - -using o2::quality_control::repository::MySqlDatabase; - -namespace o2 -{ -namespace quality_control -{ -namespace tobject_to_json -{ -namespace backends -{ - -/// Takes TObject from MySQL database and returns JSON formatted object -class MySql final : public Backend -{ - public: - // Connects to MySQL database - MySql(std::string host, unsigned int port, std::string database, std::string username, std::string password); - - /// Gets TObject from database and returns the JSON equivalent - std::string getJsonObject(std::string agentName, std::string objectName) override; - - private: - /// MySQL client instance - std::unique_ptr mSqlClient; -}; - -} // namespace backends -} // namespace tobject_to_json -} // namespace quality_control -} // namespace o2 - -#endif // QC_TOBJECT2JSON_MYSQL_H diff --git a/Framework/src/tobject2json/TObject2JsonServer.cxx b/Framework/src/tobject2json/TObject2JsonServer.cxx deleted file mode 100644 index 53cbec0f0b..0000000000 --- a/Framework/src/tobject2json/TObject2JsonServer.cxx +++ /dev/null @@ -1,87 +0,0 @@ -// Copyright CERN and copyright holders of ALICE O2. This software is -// distributed under the terms of the GNU General Public License v3 (GPL -// Version 3), copied verbatim in the file "COPYING". -// -// See http://alice-o2.web.cern.ch/license for full licensing information. -// -// In applying this license CERN does not waive the privileges and immunities -// granted to it by virtue of its status as an Intergovernmental Organization -// or submit itself to any jurisdiction. - -/// -/// \file TObject2JsonServer.cxx -/// \author Vladimir Kosmala -/// \author Adam Wegrzynek -/// - -// TObject2Json -#include "TObject2JsonServer.h" -#include "QualityControl/QcInfoLogger.h" -#include "TObject2JsonBackendFactory.h" -#include "TObject2JsonWorker.h" - -// ZMQ -#include "zmq.h" - -// Boost -#include - -#include - -using namespace std; -using namespace o2::quality_control::core; -using namespace std::string_literals; -using o2::quality_control::tobject_to_json::TObject2JsonBackendFactory; - -namespace o2 -{ -namespace quality_control -{ -namespace tobject_to_json -{ - -TObject2JsonServer::TObject2JsonServer() : mCtx(1), mFrontend(mCtx, ZMQ_ROUTER), mBackend(mCtx, ZMQ_DEALER) -{ - // Make ROOT aware that workers will do calls from threads - ROOT::EnableThreadSafety(); -} - -void TObject2JsonServer::start(std::string backendUrl, std::string zeromq, uint8_t numThreads) -{ - if (numThreads <= 0) { - throw std::runtime_error("Number of workers must be >= 1"); - } - - std::vector> workers; - - QcInfoLogger::GetInstance() << "Deploying workers..." << infologger::endm; - for (int i = 0; i < numThreads; ++i) { - std::unique_ptr backendInstance = TObject2JsonBackendFactory::Get(backendUrl); - auto worker = std::make_unique(mCtx, std::move(backendInstance)); - workers.push_back(std::move(worker)); - QcInfoLogger::GetInstance() << "Worker " << i << " started" << infologger::endm; - } - - QcInfoLogger::GetInstance() << "Starting ZeroMQ server..." << infologger::endm; - mFrontend.bind(zeromq); - mBackend.bind("inproc://backend"); - QcInfoLogger::GetInstance() << "Ready for incoming requests" << infologger::endm; - - // We start zmq proxy in a separe thread to let main thread continue to handle signals - // (avoid "Interrupted system call" error) - std::thread mThread(std::bind(&TObject2JsonServer::run, this)); - mThread.join(); -} - -void TObject2JsonServer::run() -{ - try { - zmq::proxy(mFrontend, mBackend, nullptr); - } catch (std::exception& e) { - QcInfoLogger::GetInstance() << "Closing server/backend proxy: " << e.what() << infologger::endm; - } -} - -} // namespace tobject_to_json -} // namespace quality_control -} // namespace o2 diff --git a/Framework/src/tobject2json/TObject2JsonServer.h b/Framework/src/tobject2json/TObject2JsonServer.h deleted file mode 100644 index 25ff404013..0000000000 --- a/Framework/src/tobject2json/TObject2JsonServer.h +++ /dev/null @@ -1,61 +0,0 @@ -// Copyright CERN and copyright holders of ALICE O2. This software is -// distributed under the terms of the GNU General Public License v3 (GPL -// Version 3), copied verbatim in the file "COPYING". -// -// See http://alice-o2.web.cern.ch/license for full licensing information. -// -// In applying this license CERN does not waive the privileges and immunities -// granted to it by virtue of its status as an Intergovernmental Organization -// or submit itself to any jurisdiction. - -/// -/// \file TObejct2JsonServer.h -/// \author Vladimir Kosmala -/// \author Adam Wegrzynek -/// - -#ifndef QC_TOBJECT2JSON_SERVER_H -#define QC_TOBJECT2JSON_SERVER_H - -// std -#include - -#include - -#include "TObject2JsonBackend.h" -#include "zmq.h" - -namespace o2 -{ -namespace quality_control -{ -namespace tobject_to_json -{ - -class TObject2JsonServer -{ - public: - TObject2JsonServer(); - - /// Prepare and start all threads (server and workers) - void start(std::string backend, std::string zeromq, uint8_t numThreads); - - /// Thread function of server - void run(); - - private: - /// ZeroMQ context for server and backend sockets - zmq::context_t mCtx; - - /// ZeroMQ server socket - zmq::socket_t mFrontend; - - /// ZeroMQ backend in-process socket - zmq::socket_t mBackend; -}; - -} // namespace tobject_to_json -} // namespace quality_control -} // namespace o2 - -#endif // QC_TOBJECT2JSON_SERVER_H diff --git a/Framework/src/tobject2json/TObject2JsonWorker.cxx b/Framework/src/tobject2json/TObject2JsonWorker.cxx deleted file mode 100644 index 078de9580b..0000000000 --- a/Framework/src/tobject2json/TObject2JsonWorker.cxx +++ /dev/null @@ -1,170 +0,0 @@ - -// Copyright CERN and copyright holders of ALICE O2. This software is -// distributed under the terms of the GNU General Public License v3 (GPL -// Version 3), copied verbatim in the file "COPYING". -// -// See http://alice-o2.web.cern.ch/license for full licensing information. -// -// In applying this license CERN does not waive the privileges and immunities -// granted to it by virtue of its status as an Intergovernmental Organization -// or submit itself to any jurisdiction. - -/// -/// \file TObejct2JsonWorker.cxx -/// \author Vladimir Kosmala -/// - -// TObject2Json -#include "TObject2JsonWorker.h" -#include "QualityControl/QcInfoLogger.h" - -// ZMQ -#include "zmq.h" - -// Boost -#include - -using namespace std; -using namespace o2::quality_control::core; -using namespace std::string_literals; - -namespace o2 -{ -namespace quality_control -{ -namespace tobject_to_json -{ - -TObject2JsonWorker::TObject2JsonWorker(zmq::context_t& ctx, std::unique_ptr backend) - : mBackend(std::move(backend)), - mCtx(ctx), - mWorkerSocket(mCtx, ZMQ_DEALER), - mThread(std::bind(&TObject2JsonWorker::start, this)) -{ -} - -TObject2JsonWorker::~TObject2JsonWorker() -{ - mRun = false; - QcInfoLogger::GetInstance() << "Ending worker" << infologger::endm; - mThread.join(); -} - -void TObject2JsonWorker::start() -{ - mRun = true; - mWorkerSocket.setsockopt(ZMQ_RCVTIMEO, 200); - mWorkerSocket.connect("inproc://backend"); - - try { - while (mRun) { - std::string identity = socketReceive(); - if (identity.empty()) { - // empty or timeout - continue; - } - - std::string payload = socketReceive(); - if (payload.empty()) { - // empty or timeout - continue; - } - - std::string response = handleRequest(payload); - - // always success to send because of inproc communication - socketSend(identity, response); - } - } catch (std::exception& e) { - // Context was terminated - QcInfoLogger::GetInstance() << "Closing worker" << infologger::endm; - } -} - -std::string TObject2JsonWorker::handleRequest(std::string request) -{ - std::string agentName; - std::string objectName; - const auto slashIndex = request.find_first_of('/'); - - if (std::string::npos == slashIndex) { - return responseError(400, request); - } - - agentName = request.substr(0, slashIndex); - objectName = request.substr(slashIndex + 1); - - try { - // calls to getJsonObject implies the process to have a 'Interrupted system call', why? - std::string result = mBackend->getJsonObject(agentName, objectName); - if (result.empty()) { - return responseError(404, request); - } - - return response200(request, result); - } catch (const std::exception& error) { - return responseError(500, request, error.what()); - } -} - -std::string TObject2JsonWorker::response200(std::string request, std::string payload) -{ - std::stringstream response; - QcInfoLogger::GetInstance() << "Successful request: '" << request << "'" << infologger::endm; - - response << "{\"request\": \"" << request << "\", " - << "\"payload\": " << payload << "}"; - - return response.str(); -} - -std::string TObject2JsonWorker::responseError(int code, std::string request, std::string error) -{ - if (code == 400) { - error = "Ill-formed path, slash required"; - } - - if (code == 404) { - error = "The requested object was not found"; - } - - std::stringstream response; - QcInfoLogger::GetInstance() << "ERROR: (" + std::to_string(code) + ") " << error << " FROM REQUEST " << request - << infologger::endm; - - response << "{\"request\": \"" << request << "\", " - << "\"error\": " << code << ", " - << "\"why\": \"" << error << "\"}"; - - return response.str(); -} - -// Receive 0MQ string from socket and convert into string -std::string TObject2JsonWorker::socketReceive() -{ - zmq::message_t message; - bool received = mWorkerSocket.recv(&message); - if (!received) { - // timeout - return std::string(); - } - return std::string(static_cast(message.data()), message.size()); -} - -// Sends string as 0MQ string, as multipart non-terminal -bool TObject2JsonWorker::socketSend(const std::string& identity, const std::string& payload) -{ - zmq::message_t identityMessage(identity.size()); - memcpy(identityMessage.data(), identity.data(), identity.size()); - - mWorkerSocket.send(identityMessage, ZMQ_SNDMORE); - - zmq::message_t payloadMessage(payload.size()); - memcpy(payloadMessage.data(), payload.data(), payload.size()); - - return mWorkerSocket.send(payloadMessage); -} - -} // namespace tobject_to_json -} // namespace quality_control -} // namespace o2 diff --git a/Framework/src/tobject2json/TObject2JsonWorker.h b/Framework/src/tobject2json/TObject2JsonWorker.h deleted file mode 100644 index 80d22d11bb..0000000000 --- a/Framework/src/tobject2json/TObject2JsonWorker.h +++ /dev/null @@ -1,79 +0,0 @@ -// Copyright CERN and copyright holders of ALICE O2. This software is -// distributed under the terms of the GNU General Public License v3 (GPL -// Version 3), copied verbatim in the file "COPYING". -// -// See http://alice-o2.web.cern.ch/license for full licensing information. -// -// In applying this license CERN does not waive the privileges and immunities -// granted to it by virtue of its status as an Intergovernmental Organization -// or submit itself to any jurisdiction. - -/// -/// \file TObejct2JsonWorker.h -/// \author Vladimir Kosmala -/// - -#ifndef QC_TOBJECT2JSON_WORKER_H -#define QC_TOBJECT2JSON_WORKER_H - -#include - -#include "TObject2JsonBackend.h" -#include "zmq.h" - -namespace o2 -{ -namespace quality_control -{ -namespace tobject_to_json -{ - -/*! \brief Translates ROOT objects to JSON inside a thread from backend given - * by responding to requests sent via ZeroMQ - */ -class TObject2JsonWorker -{ - public: - /// Create a thread and listen for requests - TObject2JsonWorker(zmq::context_t& ctx, std::unique_ptr backend); - - /// Stops listening for requests and stop thread - ~TObject2JsonWorker(); - - /// Start listening to requets - void start(); - - /// Handle ZeroMQ request - std::string handleRequest(std::string request); - - /// Receive 0MQ string from socket and convert into string - std::string socketReceive(); - - /// Sends string as 0MQ string, as multipart non-terminal - bool socketSend(const std::string& identity, const std::string& payload); - - std::string response200(std::string request, std::string payload); - std::string responseError(int code, std::string request, std::string error = {}); - - private: - /// Backend instance (MySQL or CCDB) - std::unique_ptr mBackend; - - /// ZeroMQ context - zmq::context_t& mCtx; - - /// ZeroMQ client socket - zmq::socket_t mWorkerSocket; - - /// Thread - std::thread mThread; - - /// Flag to continue listening requests or not and exit - bool mRun; -}; - -} // namespace tobject_to_json -} // namespace quality_control -} // namespace o2 - -#endif // QC_TOBJECT2JSON_WORKER_H diff --git a/Framework/src/tobject2json/UriParser.h b/Framework/src/tobject2json/UriParser.h deleted file mode 100644 index 6457e6e248..0000000000 --- a/Framework/src/tobject2json/UriParser.h +++ /dev/null @@ -1,106 +0,0 @@ -/* -Copyright (c) 2013 Covenant Eyes - -Permission is hereby granted, free of charge, to any person obtaining a copy of this -software and associated documentation files (the "Software"), to deal in the Software -without restriction, including without limitation the rights to use, copy, modify, -merge, publish, distribute, sublicense, and/or sell copies of the Software, and to -permit persons to whom the Software is furnished to do so, subject to the following -conditions: - -The above copyright notice and this permission notice shall be included in all copies -or substantial portions of the Software. - -THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, -INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A -PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT -HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION -OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE -SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. -*/ - -#ifndef ALICEO2_HTTPPARSER_H -#define ALICEO2_HTTPPARSER_H - -#include -#include -#include - -namespace http -{ -struct url { - std::string protocol, user, password, host, path, search; - int port; -}; - -//--- Helper Functions -------------------------------------------------------------~ -static inline std::string TailSlice(std::string& subject, std::string delimiter, bool keep_delim = false) -{ - // Chops off the delimiter and everything that follows (destructively) - // returns everything after the delimiter - auto delimiter_location = subject.find(delimiter); - auto delimiter_length = delimiter.length(); - std::string output = ""; - - if (delimiter_location < std::string::npos) { - auto start = keep_delim ? delimiter_location : delimiter_location + delimiter_length; - auto end = subject.length() - start; - output = subject.substr(start, end); - subject = subject.substr(0, delimiter_location); - } - return output; -} - -static inline std::string HeadSlice(std::string& subject, std::string delimiter) -{ - // Chops off the delimiter and everything that precedes (destructively) - // returns everthing before the delimeter - auto delimiter_location = subject.find(delimiter); - auto delimiter_length = delimiter.length(); - std::string output = ""; - if (delimiter_location < std::string::npos) { - output = subject.substr(0, delimiter_location); - subject = - subject.substr(delimiter_location + delimiter_length, subject.length() - (delimiter_location + delimiter_length)); - } - return output; -} - -//--- Extractors -------------------------------------------------------------------~ -static inline int ExtractPort(std::string& hostport) -{ - int port; - std::string portstring = TailSlice(hostport, ":"); - try { - port = atoi(portstring.c_str()); - } catch (std::exception e) { - port = -1; - } - return port; -} - -static inline std::string ExtractPath(std::string& in) { return TailSlice(in, "/", true); } -static inline std::string ExtractProtocol(std::string& in) { return HeadSlice(in, "://"); } -static inline std::string ExtractSearch(std::string& in) { return TailSlice(in, "?"); } -static inline std::string ExtractPassword(std::string& userpass) { return TailSlice(userpass, ":"); } -static inline std::string ExtractUserpass(std::string& in) { return HeadSlice(in, "@"); } - -//--- Public Interface -------------------------------------------------------------~ -static inline url ParseHttpUrl(std::string& in) -{ - url ret; - ret.port = -1; - - ret.protocol = ExtractProtocol(in); - ret.search = ExtractSearch(in); - ret.path = ExtractPath(in); - std::string userpass = ExtractUserpass(in); - ret.password = ExtractPassword(userpass); - ret.user = userpass; - ret.port = ExtractPort(in); - ret.host = in; - - return ret; -} -} // namespace http -#endif diff --git a/Framework/src/tobject2json/zmq.h b/Framework/src/tobject2json/zmq.h deleted file mode 100644 index 562e5eb261..0000000000 --- a/Framework/src/tobject2json/zmq.h +++ /dev/null @@ -1,1079 +0,0 @@ -/* - Copyright (c) 2016-2017 ZeroMQ community - Copyright (c) 2009-2011 250bpm s.r.o. - Copyright (c) 2011 Botond Ballo - Copyright (c) 2007-2009 iMatix Corporation - - Permission is hereby granted, free of charge, to any person obtaining a copy - of this software and associated documentation files (the "Software"), to - deal in the Software without restriction, including without limitation the - rights to use, copy, modify, merge, publish, distribute, sublicense, and/or - sell copies of the Software, and to permit persons to whom the Software is - furnished to do so, subject to the following conditions: - - The above copyright notice and this permission notice shall be included in - all copies or substantial portions of the Software. - - THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE - AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING - FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS - IN THE SOFTWARE. -*/ - -#ifndef __ZMQ_HPP_INCLUDED__ -#define __ZMQ_HPP_INCLUDED__ - -#if (__cplusplus >= 201402L) -#define ZMQ_DEPRECATED(msg) [[deprecated(msg)]] -#elif defined(_MSC_VER) -#define ZMQ_DEPRECATED(msg) __declspec(deprecated(msg)) -#elif defined(__GNUC__) -#define ZMQ_DEPRECATED(msg) __attribute__((deprecated(msg))) -#endif - -#if (__cplusplus >= 201103L) -#define ZMQ_CPP11 -#define ZMQ_NOTHROW noexcept -#define ZMQ_EXPLICIT explicit -#elif (defined(_MSC_VER) && (_MSC_VER >= 1900)) -#define ZMQ_CPP11 -#define ZMQ_NOTHROW noexcept -#define ZMQ_EXPLICIT explicit -#else -#define ZMQ_CPP03 -#define ZMQ_NOTHROW -#define ZMQ_EXPLICIT -#endif - -#include - -#include -#include - -#include -#include -#include -#include -#include -#include -#include - -/* Version macros for compile-time API version detection */ -#define CPPZMQ_VERSION_MAJOR 4 -#define CPPZMQ_VERSION_MINOR 3 -#define CPPZMQ_VERSION_PATCH 0 - -#define CPPZMQ_VERSION ZMQ_MAKE_VERSION(CPPZMQ_VERSION_MAJOR, CPPZMQ_VERSION_MINOR, CPPZMQ_VERSION_PATCH) - -#ifdef ZMQ_CPP11 -#include -#include -#include -#include -#include -#endif - -// Detect whether the compiler supports C++11 rvalue references. -#if (defined(__GNUC__) && (__GNUC__ > 4 || (__GNUC__ == 4 && __GNUC_MINOR__ > 2)) && \ - defined(__GXX_EXPERIMENTAL_CXX0X__)) -#define ZMQ_HAS_RVALUE_REFS -#define ZMQ_DELETED_FUNCTION = delete -#elif defined(__clang__) -#if __has_feature(cxx_rvalue_references) -#define ZMQ_HAS_RVALUE_REFS -#endif - -#if __has_feature(cxx_deleted_functions) -#define ZMQ_DELETED_FUNCTION = delete -#else -#define ZMQ_DELETED_FUNCTION -#endif -#elif defined(_MSC_VER) && (_MSC_VER >= 1900) -#define ZMQ_HAS_RVALUE_REFS -#define ZMQ_DELETED_FUNCTION = delete -#elif defined(_MSC_VER) && (_MSC_VER >= 1600) -#define ZMQ_HAS_RVALUE_REFS -#define ZMQ_DELETED_FUNCTION -#else -#define ZMQ_DELETED_FUNCTION -#endif - -#if ZMQ_VERSION >= ZMQ_MAKE_VERSION(3, 3, 0) -#define ZMQ_NEW_MONITOR_EVENT_LAYOUT -#endif - -#if ZMQ_VERSION >= ZMQ_MAKE_VERSION(4, 1, 0) -#define ZMQ_HAS_PROXY_STEERABLE -/* Socket event data */ -typedef struct { - uint16_t event; // id of the event as bitfield - int32_t value; // value is either error code, fd or reconnect interval -} zmq_event_t; -#endif - -// Avoid using deprecated message receive function when possible -#if ZMQ_VERSION < ZMQ_MAKE_VERSION(3, 2, 0) -#define zmq_msg_recv(msg, socket, flags) zmq_recvmsg(socket, msg, flags) -#endif - -// In order to prevent unused variable warnings when building in non-debug -// mode use this macro to make assertions. -#ifndef NDEBUG -#define ZMQ_ASSERT(expression) assert(expression) -#else -#define ZMQ_ASSERT(expression) (void)(expression) -#endif - -namespace zmq -{ -typedef zmq_free_fn free_fn; -typedef zmq_pollitem_t pollitem_t; - -class error_t : public std::exception -{ - public: - error_t() : errnum(zmq_errno()) {} -#ifdef ZMQ_CPP11 - virtual const char* what() const noexcept - { - return zmq_strerror(errnum); - } -#else - virtual const char* what() const throw() - { - return zmq_strerror(errnum); - } -#endif - int num() const - { - return errnum; - } - - private: - int errnum; -}; - -inline int poll(zmq_pollitem_t const* items_, size_t nitems_, long timeout_ = -1) -{ - int rc = zmq_poll(const_cast(items_), static_cast(nitems_), timeout_); - if (rc < 0) - throw error_t(); - return rc; -} - -#ifdef ZMQ_CPP11 -inline int poll(zmq_pollitem_t const* items, size_t nitems, std::chrono::milliseconds timeout) -{ - return poll(items, nitems, static_cast(timeout.count())); -} - -inline int poll(std::vector const& items, std::chrono::milliseconds timeout) -{ - return poll(items.data(), items.size(), static_cast(timeout.count())); -} - -inline int poll(std::vector const& items, long timeout_ = -1) -{ - return poll(items.data(), items.size(), timeout_); -} -#endif - -inline void proxy(void* frontend, void* backend, void* capture) -{ - int rc = zmq_proxy(frontend, backend, capture); - if (rc != 0) - throw error_t(); -} - -#ifdef ZMQ_HAS_PROXY_STEERABLE -inline void proxy_steerable(void* frontend, void* backend, void* capture, void* control) -{ - int rc = zmq_proxy_steerable(frontend, backend, capture, control); - if (rc != 0) - throw error_t(); -} -#endif - -inline void version(int* major_, int* minor_, int* patch_) -{ - zmq_version(major_, minor_, patch_); -} - -#ifdef ZMQ_CPP11 -inline std::tuple version() -{ - std::tuple v; - zmq_version(&std::get<0>(v), &std::get<1>(v), &std::get<2>(v)); - return v; -} -#endif - -class message_t -{ - friend class socket_t; - - public: - inline message_t() - { - int rc = zmq_msg_init(&msg); - if (rc != 0) - throw error_t(); - } - - inline explicit message_t(size_t size_) - { - int rc = zmq_msg_init_size(&msg, size_); - if (rc != 0) - throw error_t(); - } - - template - message_t(I first, I last) : msg() - { - typedef typename std::iterator_traits::difference_type size_type; - typedef typename std::iterator_traits::value_type value_t; - - size_type const size_ = std::distance(first, last) * sizeof(value_t); - int const rc = zmq_msg_init_size(&msg, size_); - if (rc != 0) - throw error_t(); - value_t* dest = data(); - while (first != last) { - *dest = *first; - ++dest; - ++first; - } - } - - inline message_t(const void* data_, size_t size_) - { - int rc = zmq_msg_init_size(&msg, size_); - if (rc != 0) - throw error_t(); - memcpy(data(), data_, size_); - } - - inline message_t(void* data_, size_t size_, free_fn* ffn_, void* hint_ = NULL) - { - int rc = zmq_msg_init_data(&msg, data_, size_, ffn_, hint_); - if (rc != 0) - throw error_t(); - } - -#if defined(ZMQ_BUILD_DRAFT_API) && defined(ZMQ_CPP11) - template - message_t(const T& msg_) : message_t(std::begin(msg_), std::end(msg_)) - { - } -#endif - -#ifdef ZMQ_HAS_RVALUE_REFS - inline message_t(message_t&& rhs) : msg(rhs.msg) - { - int rc = zmq_msg_init(&rhs.msg); - if (rc != 0) - throw error_t(); - } - - inline message_t& operator=(message_t&& rhs) ZMQ_NOTHROW - { - std::swap(msg, rhs.msg); - return *this; - } -#endif - - inline ~message_t() ZMQ_NOTHROW - { - int rc = zmq_msg_close(&msg); - ZMQ_ASSERT(rc == 0); - } - - inline void rebuild() - { - int rc = zmq_msg_close(&msg); - if (rc != 0) - throw error_t(); - rc = zmq_msg_init(&msg); - if (rc != 0) - throw error_t(); - } - - inline void rebuild(size_t size_) - { - int rc = zmq_msg_close(&msg); - if (rc != 0) - throw error_t(); - rc = zmq_msg_init_size(&msg, size_); - if (rc != 0) - throw error_t(); - } - - inline void rebuild(const void* data_, size_t size_) - { - int rc = zmq_msg_close(&msg); - if (rc != 0) - throw error_t(); - rc = zmq_msg_init_size(&msg, size_); - if (rc != 0) - throw error_t(); - memcpy(data(), data_, size_); - } - - inline void rebuild(void* data_, size_t size_, free_fn* ffn_, void* hint_ = NULL) - { - int rc = zmq_msg_close(&msg); - if (rc != 0) - throw error_t(); - rc = zmq_msg_init_data(&msg, data_, size_, ffn_, hint_); - if (rc != 0) - throw error_t(); - } - - inline void move(message_t const* msg_) - { - int rc = zmq_msg_move(&msg, const_cast(&(msg_->msg))); - if (rc != 0) - throw error_t(); - } - - inline void copy(message_t const* msg_) - { - int rc = zmq_msg_copy(&msg, const_cast(&(msg_->msg))); - if (rc != 0) - throw error_t(); - } - - inline bool more() const ZMQ_NOTHROW - { - int rc = zmq_msg_more(const_cast(&msg)); - return rc != 0; - } - - inline void* data() ZMQ_NOTHROW { return zmq_msg_data(&msg); } - - inline const void* data() const ZMQ_NOTHROW { return zmq_msg_data(const_cast(&msg)); } - - inline size_t size() const ZMQ_NOTHROW { return zmq_msg_size(const_cast(&msg)); } - - template - T* data() ZMQ_NOTHROW - { - return static_cast(data()); - } - - template - T const* data() const ZMQ_NOTHROW - { - return static_cast(data()); - } - - ZMQ_DEPRECATED("from 4.3.0, use operator== instead") - inline bool equal(const message_t* other) const ZMQ_NOTHROW { return *this == *other; } - - inline bool operator==(const message_t& other) const ZMQ_NOTHROW - { - const size_t my_size = size(); - return my_size == other.size() && 0 == memcmp(data(), other.data(), my_size); - } - - inline bool operator!=(const message_t& other) const ZMQ_NOTHROW { return !(*this == other); } - -#if ZMQ_VERSION >= ZMQ_MAKE_VERSION(4, 1, 0) - inline const char* gets(const char* property_) - { - const char* value = zmq_msg_gets(&msg, property_); - if (value == NULL) - throw error_t(); - return value; - } -#endif - /** Dump content to string. Ascii chars are readable, the rest is printed as hex. - * Probably ridiculously slow. - */ - inline std::string str() const - { - // Partly mutuated from the same method in zmq::multipart_t - std::stringstream os; - - const unsigned char* msg_data = this->data(); - unsigned char byte; - size_t size = this->size(); - int is_ascii[2] = { 0, 0 }; - - os << "zmq::message_t [size " << std::dec << std::setw(3) << std::setfill('0') << size << "] ("; - // Totally arbitrary - if (size >= 1000) { - os << "... too big to print)"; - } else { - while (size--) { - byte = *msg_data++; - - is_ascii[1] = (byte >= 33 && byte < 127); - if (is_ascii[1] != is_ascii[0]) - os << " "; // Separate text/non text - - if (is_ascii[1]) { - os << byte; - } else { - os << std::hex << std::uppercase << std::setw(2) << std::setfill('0') << static_cast(byte); - } - is_ascii[0] = is_ascii[1]; - } - os << ")"; - } - return os.str(); - } - - private: - // The underlying message - zmq_msg_t msg; - - // Disable implicit message copying, so that users won't use shared - // messages (less efficient) without being aware of the fact. - message_t(const message_t&) ZMQ_DELETED_FUNCTION; - void operator=(const message_t&) ZMQ_DELETED_FUNCTION; -}; - -class context_t -{ - friend class socket_t; - - public: - inline context_t() - { - ptr = zmq_ctx_new(); - if (ptr == NULL) - throw error_t(); - } - - inline explicit context_t(int io_threads_, int max_sockets_ = ZMQ_MAX_SOCKETS_DFLT) - { - ptr = zmq_ctx_new(); - if (ptr == NULL) - throw error_t(); - - int rc = zmq_ctx_set(ptr, ZMQ_IO_THREADS, io_threads_); - ZMQ_ASSERT(rc == 0); - - rc = zmq_ctx_set(ptr, ZMQ_MAX_SOCKETS, max_sockets_); - ZMQ_ASSERT(rc == 0); - } - -#ifdef ZMQ_HAS_RVALUE_REFS - inline context_t(context_t&& rhs) ZMQ_NOTHROW : ptr(rhs.ptr) - { - rhs.ptr = NULL; - } - inline context_t& operator=(context_t&& rhs) ZMQ_NOTHROW - { - std::swap(ptr, rhs.ptr); - return *this; - } -#endif - - inline int setctxopt(int option_, int optval_) - { - int rc = zmq_ctx_set(ptr, option_, optval_); - ZMQ_ASSERT(rc == 0); - return rc; - } - - inline int getctxopt(int option_) { return zmq_ctx_get(ptr, option_); } - - inline ~context_t() ZMQ_NOTHROW { close(); } - - inline void close() ZMQ_NOTHROW - { - if (ptr == NULL) - return; - - int rc = zmq_ctx_destroy(ptr); - ZMQ_ASSERT(rc == 0); - ptr = NULL; - } - - // Be careful with this, it's probably only useful for - // using the C api together with an existing C++ api. - // Normally you should never need to use this. - inline ZMQ_EXPLICIT operator void*() ZMQ_NOTHROW { return ptr; } - - inline ZMQ_EXPLICIT operator void const*() const ZMQ_NOTHROW { return ptr; } - - inline operator bool() const ZMQ_NOTHROW { return ptr != NULL; } - - private: - void* ptr; - - context_t(const context_t&) ZMQ_DELETED_FUNCTION; - void operator=(const context_t&) ZMQ_DELETED_FUNCTION; -}; - -#ifdef ZMQ_CPP11 -enum class socket_type : int { - req = ZMQ_REQ, - rep = ZMQ_REP, - dealer = ZMQ_DEALER, - router = ZMQ_ROUTER, - pub = ZMQ_PUB, - sub = ZMQ_SUB, - xpub = ZMQ_XPUB, - xsub = ZMQ_XSUB, - push = ZMQ_PUSH, - pull = ZMQ_PULL, -#ifdef ZMQ_BUILD_DRAFT_API - server = ZMQ_SERVER, - client = ZMQ_CLIENT, -#endif -#if ZMQ_VERSION_MAJOR >= 4 - stream = ZMQ_STREAM, -#endif - pair = ZMQ_PAIR -}; -#endif - -class socket_t -{ - friend class monitor_t; - - public: - inline socket_t(context_t& context_, int type_) { init(context_, type_); } - -#ifdef ZMQ_CPP11 - inline socket_t(context_t& context_, socket_type type_) - { - init(context_, static_cast(type_)); - } -#endif - -#ifdef ZMQ_HAS_RVALUE_REFS - inline socket_t(socket_t&& rhs) ZMQ_NOTHROW : ptr(rhs.ptr), ctxptr(rhs.ctxptr) - { - rhs.ptr = NULL; - rhs.ctxptr = NULL; - } - inline socket_t& operator=(socket_t&& rhs) ZMQ_NOTHROW - { - std::swap(ptr, rhs.ptr); - return *this; - } -#endif - - inline ~socket_t() ZMQ_NOTHROW - { - close(); - } - - inline operator void*() ZMQ_NOTHROW { return ptr; } - - inline operator void const*() const ZMQ_NOTHROW { return ptr; } - - inline void close() ZMQ_NOTHROW - { - if (ptr == NULL) - // already closed - return; - int rc = zmq_close(ptr); - ZMQ_ASSERT(rc == 0); - ptr = 0; - } - - template - void setsockopt(int option_, T const& optval) - { - setsockopt(option_, &optval, sizeof(T)); - } - - inline void setsockopt(int option_, const void* optval_, size_t optvallen_) - { - int rc = zmq_setsockopt(ptr, option_, optval_, optvallen_); - if (rc != 0) - throw error_t(); - } - - inline void getsockopt(int option_, void* optval_, size_t* optvallen_) const - { - int rc = zmq_getsockopt(ptr, option_, optval_, optvallen_); - if (rc != 0) - throw error_t(); - } - - template - T getsockopt(int option_) const - { - T optval; - size_t optlen = sizeof(T); - getsockopt(option_, &optval, &optlen); - return optval; - } - - inline void bind(std::string const& addr) { bind(addr.c_str()); } - - inline void bind(const char* addr_) - { - int rc = zmq_bind(ptr, addr_); - if (rc != 0) - throw error_t(); - } - - inline void unbind(std::string const& addr) { unbind(addr.c_str()); } - - inline void unbind(const char* addr_) - { - int rc = zmq_unbind(ptr, addr_); - if (rc != 0) - throw error_t(); - } - - inline void connect(std::string const& addr) { connect(addr.c_str()); } - - inline void connect(const char* addr_) - { - int rc = zmq_connect(ptr, addr_); - if (rc != 0) - throw error_t(); - } - - inline void disconnect(std::string const& addr) { disconnect(addr.c_str()); } - - inline void disconnect(const char* addr_) - { - int rc = zmq_disconnect(ptr, addr_); - if (rc != 0) - throw error_t(); - } - - inline bool connected() const ZMQ_NOTHROW { return (ptr != NULL); } - - inline size_t send(const void* buf_, size_t len_, int flags_ = 0) - { - int nbytes = zmq_send(ptr, buf_, len_, flags_); - if (nbytes >= 0) - return (size_t)nbytes; - if (zmq_errno() == EAGAIN) - return 0; - throw error_t(); - } - - inline bool send(message_t& msg_, int flags_ = 0) - { - int nbytes = zmq_msg_send(&(msg_.msg), ptr, flags_); - if (nbytes >= 0) - return true; - if (zmq_errno() == EAGAIN) - return false; - throw error_t(); - } - - template - bool send(I first, I last, int flags_ = 0) - { - zmq::message_t msg(first, last); - return send(msg, flags_); - } - -#ifdef ZMQ_HAS_RVALUE_REFS - inline bool send(message_t&& msg_, int flags_ = 0) - { - return send(msg_, flags_); - } -#endif - - inline size_t recv(void* buf_, size_t len_, int flags_ = 0) - { - int nbytes = zmq_recv(ptr, buf_, len_, flags_); - if (nbytes >= 0) - return (size_t)nbytes; - if (zmq_errno() == EAGAIN) - return 0; - throw error_t(); - } - - inline bool recv(message_t* msg_, int flags_ = 0) - { - int nbytes = zmq_msg_recv(&(msg_->msg), ptr, flags_); - if (nbytes >= 0) - return true; - if (zmq_errno() == EAGAIN) - return false; - throw error_t(); - } - - private: - inline void init(context_t& context_, int type_) - { - ctxptr = context_.ptr; - ptr = zmq_socket(context_.ptr, type_); - if (ptr == NULL) - throw error_t(); - } - - void* ptr; - void* ctxptr; - - socket_t(const socket_t&) ZMQ_DELETED_FUNCTION; - void operator=(const socket_t&) ZMQ_DELETED_FUNCTION; -}; - -class monitor_t -{ - public: - monitor_t() : socketPtr(NULL), monitor_socket(NULL) {} - - virtual ~monitor_t() - { - if (socketPtr) - zmq_socket_monitor(socketPtr, NULL, 0); - - if (monitor_socket) - zmq_close(monitor_socket); - } - -#ifdef ZMQ_HAS_RVALUE_REFS - monitor_t(monitor_t&& rhs) ZMQ_NOTHROW : socketPtr(rhs.socketPtr), monitor_socket(rhs.monitor_socket) - { - rhs.socketPtr = NULL; - rhs.monitor_socket = NULL; - } - - socket_t& operator=(socket_t&& rhs) ZMQ_DELETED_FUNCTION; -#endif - - void monitor(socket_t& socket, std::string const& addr, int events = ZMQ_EVENT_ALL) - { - monitor(socket, addr.c_str(), events); - } - - void monitor(socket_t& socket, const char* addr_, int events = ZMQ_EVENT_ALL) - { - init(socket, addr_, events); - while (true) { - check_event(-1); - } - } - - void init(socket_t& socket, std::string const& addr, int events = ZMQ_EVENT_ALL) - { - init(socket, addr.c_str(), events); - } - - void init(socket_t& socket, const char* addr_, int events = ZMQ_EVENT_ALL) - { - int rc = zmq_socket_monitor(socket.ptr, addr_, events); - if (rc != 0) - throw error_t(); - - socketPtr = socket.ptr; - monitor_socket = zmq_socket(socket.ctxptr, ZMQ_PAIR); - assert(monitor_socket); - - rc = zmq_connect(monitor_socket, addr_); - assert(rc == 0); - - on_monitor_started(); - } - - bool check_event(int timeout = 0) - { - assert(monitor_socket); - - zmq_msg_t eventMsg; - zmq_msg_init(&eventMsg); - - zmq::pollitem_t items[] = { - { monitor_socket, 0, ZMQ_POLLIN, 0 }, - }; - - zmq::poll(&items[0], 1, timeout); - - if (items[0].revents & ZMQ_POLLIN) { - int rc = zmq_msg_recv(&eventMsg, monitor_socket, 0); - if (rc == -1 && zmq_errno() == ETERM) - return false; - assert(rc != -1); - } else { - zmq_msg_close(&eventMsg); - return false; - } - -#if ZMQ_VERSION_MAJOR >= 4 - const char* data = static_cast(zmq_msg_data(&eventMsg)); - zmq_event_t msgEvent; - memcpy(&msgEvent.event, data, sizeof(uint16_t)); - data += sizeof(uint16_t); - memcpy(&msgEvent.value, data, sizeof(int32_t)); - zmq_event_t* event = &msgEvent; -#else - zmq_event_t* event = static_cast(zmq_msg_data(&eventMsg)); -#endif - -#ifdef ZMQ_NEW_MONITOR_EVENT_LAYOUT - zmq_msg_t addrMsg; - zmq_msg_init(&addrMsg); - int rc = zmq_msg_recv(&addrMsg, monitor_socket, 0); - if (rc == -1 && zmq_errno() == ETERM) { - zmq_msg_close(&eventMsg); - return false; - } - - assert(rc != -1); - const char* str = static_cast(zmq_msg_data(&addrMsg)); - std::string address(str, str + zmq_msg_size(&addrMsg)); - zmq_msg_close(&addrMsg); -#else - // Bit of a hack, but all events in the zmq_event_t union have the same layout so this will work for all event - // types. - std::string address = event->data.connected.addr; -#endif - -#ifdef ZMQ_EVENT_MONITOR_STOPPED - if (event->event == ZMQ_EVENT_MONITOR_STOPPED) { - zmq_msg_close(&eventMsg); - return true; - } - -#endif - - switch (event->event) { - case ZMQ_EVENT_CONNECTED: - on_event_connected(*event, address.c_str()); - break; - case ZMQ_EVENT_CONNECT_DELAYED: - on_event_connect_delayed(*event, address.c_str()); - break; - case ZMQ_EVENT_CONNECT_RETRIED: - on_event_connect_retried(*event, address.c_str()); - break; - case ZMQ_EVENT_LISTENING: - on_event_listening(*event, address.c_str()); - break; - case ZMQ_EVENT_BIND_FAILED: - on_event_bind_failed(*event, address.c_str()); - break; - case ZMQ_EVENT_ACCEPTED: - on_event_accepted(*event, address.c_str()); - break; - case ZMQ_EVENT_ACCEPT_FAILED: - on_event_accept_failed(*event, address.c_str()); - break; - case ZMQ_EVENT_CLOSED: - on_event_closed(*event, address.c_str()); - break; - case ZMQ_EVENT_CLOSE_FAILED: - on_event_close_failed(*event, address.c_str()); - break; - case ZMQ_EVENT_DISCONNECTED: - on_event_disconnected(*event, address.c_str()); - break; -#ifdef ZMQ_BUILD_DRAFT_API -#if ZMQ_VERSION >= ZMQ_MAKE_VERSION(4, 2, 3) - case ZMQ_EVENT_HANDSHAKE_FAILED_NO_DETAIL: - on_event_handshake_failed_no_detail(*event, address.c_str()); - break; - case ZMQ_EVENT_HANDSHAKE_FAILED_PROTOCOL: - on_event_handshake_failed_protocol(*event, address.c_str()); - break; - case ZMQ_EVENT_HANDSHAKE_FAILED_AUTH: - on_event_handshake_failed_auth(*event, address.c_str()); - break; - case ZMQ_EVENT_HANDSHAKE_SUCCEEDED: - on_event_handshake_succeeded(*event, address.c_str()); - break; -#elif ZMQ_VERSION >= ZMQ_MAKE_VERSION(4, 2, 1) - case ZMQ_EVENT_HANDSHAKE_FAILED: - on_event_handshake_failed(*event, address.c_str()); - break; - case ZMQ_EVENT_HANDSHAKE_SUCCEED: - on_event_handshake_succeed(*event, address.c_str()); - break; -#endif -#endif - default: - on_event_unknown(*event, address.c_str()); - break; - } - zmq_msg_close(&eventMsg); - - return true; - } - -#ifdef ZMQ_EVENT_MONITOR_STOPPED - void abort() - { - if (socketPtr) - zmq_socket_monitor(socketPtr, NULL, 0); - - if (monitor_socket) - zmq_close(monitor_socket); - - socketPtr = NULL; - monitor_socket = NULL; - } -#endif - virtual void on_monitor_started() - { - } - virtual void on_event_connected(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } - virtual void on_event_connect_delayed(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } - virtual void on_event_connect_retried(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } - virtual void on_event_listening(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } - virtual void on_event_bind_failed(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } - virtual void on_event_accepted(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } - virtual void on_event_accept_failed(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } - virtual void on_event_closed(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } - virtual void on_event_close_failed(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } - virtual void on_event_disconnected(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } -#if ZMQ_VERSION >= ZMQ_MAKE_VERSION(4, 2, 3) - virtual void on_event_handshake_failed_no_detail(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } - virtual void on_event_handshake_failed_protocol(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } - virtual void on_event_handshake_failed_auth(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } - virtual void on_event_handshake_succeeded(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } -#elif ZMQ_VERSION >= ZMQ_MAKE_VERSION(4, 2, 1) - virtual void on_event_handshake_failed(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } - virtual void on_event_handshake_succeed(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } -#endif - virtual void on_event_unknown(const zmq_event_t& event_, const char* addr_) - { - (void)event_; - (void)addr_; - } - - private: - monitor_t(const monitor_t&) ZMQ_DELETED_FUNCTION; - void operator=(const monitor_t&) ZMQ_DELETED_FUNCTION; - - void* socketPtr; - void* monitor_socket; -}; - -#if defined(ZMQ_BUILD_DRAFT_API) && defined(ZMQ_CPP11) && defined(ZMQ_HAVE_POLLER) -template -class poller_t -{ - public: - void add(zmq::socket_t& socket, short events, T* user_data) - { - if (0 != zmq_poller_add(poller_ptr.get(), static_cast(socket), user_data, events)) { - throw error_t(); - } - } - - void remove(zmq::socket_t& socket) - { - if (0 != zmq_poller_remove(poller_ptr.get(), static_cast(socket))) { - throw error_t(); - } - } - - void modify(zmq::socket_t& socket, short events) - { - if (0 != zmq_poller_modify(poller_ptr.get(), static_cast(socket), events)) { - throw error_t(); - } - } - - size_t wait_all(std::vector& poller_events, const std::chrono::microseconds timeout) - { - int rc = zmq_poller_wait_all(poller_ptr.get(), poller_events.data(), static_cast(poller_events.size()), - static_cast(timeout.count())); - if (rc > 0) - return static_cast(rc); - -#if ZMQ_VERSION >= ZMQ_MAKE_VERSION(4, 2, 3) - if (zmq_errno() == EAGAIN) -#else - if (zmq_errno() == ETIMEDOUT) -#endif - return 0; - - throw error_t(); - } - - private: - std::unique_ptr> poller_ptr{ []() { - auto poller_new = zmq_poller_new(); - if (poller_new) - return poller_new; - throw error_t(); - }(), - [](void* ptr) { - int rc = zmq_poller_destroy(&ptr); - ZMQ_ASSERT(rc == 0); - } }; -}; -#endif // defined(ZMQ_BUILD_DRAFT_API) && defined(ZMQ_CPP11) && defined(ZMQ_HAVE_POLLER) - -inline std::ostream& operator<<(std::ostream& os, const message_t& msg) -{ - return os << msg.str(); -} - -} // namespace zmq - -#endif // __ZMQ_HPP_INCLUDED__ diff --git a/README.md b/README.md index 28e75a7ab5..41b7129d5a 100644 --- a/README.md +++ b/README.md @@ -32,9 +32,6 @@ * [Use MySQL as QC backend](#use-mysql-as-qc-backend) * [Local CCDB setup](#local-ccdb-setup) * [Local QCG (QC GUI) setup](#local-qcg-qc-gui-setup) - * [tobject2json Usage](#tobject2json-usage) - * [Protocol](#protocol) - * [Architecture](#architecture) * [Information Service](#information-service) * [Usage](#usage) * [Configuration files details](#configuration-files-details) @@ -446,52 +443,6 @@ At the moment, the description of the REST api can be found in this document : h To install and run the QCG locally, and its fellow process tobject2json, please follow these instructions : https://github.com/AliceO2Group/WebUi/tree/dev/QualityControl#run-qcg-locally -`tobject2json` is in charge of converting the MonitorObjects stored in the repository into JSON for their consumption by the QCG. The code is in the QualityControl repository whereas the code of the QCG is in the WebUI repository. - -#### tobject2json Usage - -```bash -alienv enter QualityControl/latest -tobject2json --backend mysql://qc_user:qc_user@localhost/quality_control --zeromq-server tcp://127.0.0.1:7777 --workers 4 -``` - -#### Protocol - -Request: - -``` -/ -``` - -Response (one of the following): - -``` -{"request": "/", "payload": ""} -{"request": "/", "error": 400, "message": "Wrong request", "why": "because..."} -{"request": "/", "error": 404, "message": "Object not found"} -{"request": "/", "error": 500, "message": "Internal error", "why": "because..."} -``` - -#### Architecture - -``` -+-----------+ -| main | -+-----------+ - | - | - v -+-----------+ +-----------+ -| Server |--->| Factory | -+-----------+ +-----------+ - ^ 1 - | - v N -+-----------+ +-----------+ -| Worker |<-->| Backend | -+-----------+1 N+-----------+ -``` - ## Information Service The information service publishes information about the tasks currently