utils.hpp

Go to the documentation of this file.

 
#ifndef RAD_MAL_UTILS_HPP
#define RAD_MAL_UTILS_HPP
 
#include <mal/Cii.hpp>
#include <mal/Mal.hpp>
#include <mal/utility/LoadMal.hpp>
 
#include <atomic>
#include <memory>
 
namespace rad {
namespace cii {
 
inline void LoadMiddlewares(const std::vector<std::string>& mal_types) {
    elt::mal::CiiFactory& factory = elt::mal::CiiFactory::getInstance();
    elt::mal::Mal::Properties mal_properties;
    for (auto t : mal_types) {
        auto mal_instance = elt::mal::loadMal(t, mal_properties);
        factory.registerMal(t, mal_instance);
    }
}
 
void LoadMiddlewares(const std::vector<
        std::pair<std::string, elt::mal::Mal::Properties>>& mal_specs);
 
 
class CancellationToken {
   public:
    CancellationToken() : m_is_cancelled(std::make_shared<std::atomic<bool>>(false)) {}
 
    CancellationToken(const CancellationToken&) = default;
    CancellationToken& operator=(const CancellationToken&) = default;
 
    void Cancel() { *m_is_cancelled = true; }
 
    bool IsCancelled() const { return *m_is_cancelled; }
 
   private:
    std::shared_ptr<std::atomic<bool>>
        m_is_cancelled;  // Flag indicating whether a service has been cancelled.
};
 
}  // namespace cii
}  // namespace rad
 
#endif  // RAD_MAL_UTILS_HPP