ModuleHubComponent.hpp

Go to the documentation of this file.

#pragma once
#ifndef _CONSOLIX_MODULE_HUB_COMPONENT_HPP_INCLUDED
#define _CONSOLIX_MODULE_HUB_COMPONENT_HPP_INCLUDED

 
#if CONSOLIX_USE_EVENT_HUB == 1
 
#include <cstddef>
 
#include <event_hub.hpp>
 
namespace consolix {

    class ModuleHubComponent :
        public IAppComponent,
        public IShutdownable {
    public:
        ModuleHubComponent() = default;

        explicit ModuleHubComponent(event_hub::ModuleHub* module_hub) :
            m_module_hub(module_hub) {
        }

        void set_module_hub(event_hub::ModuleHub* module_hub) {
            m_module_hub = module_hub;
        }

        std::size_t last_work_count() const {
            return m_last_work_count;
        }
 
    protected:
        bool initialize() override {
            if (m_module_hub) {
                m_module_hub->initialize();
            }
            m_is_init = true;
            return true;
        }
 
        bool is_initialized() const override {
            return m_is_init;
        }
 
        void process() override {
            if (!m_module_hub) {
                m_last_work_count = 0;
                return;
            }
 
            m_last_work_count = m_module_hub->process();
        }
 
        void shutdown(int /*signal*/) override {
            if (m_module_hub) {
                m_module_hub->request_stop();
                m_module_hub->shutdown();
            }
        }
 
    private:
        event_hub::ModuleHub* m_module_hub{nullptr}; 
        std::size_t           m_last_work_count{0};
        bool                  m_is_init{false};
    };
 
} // namespace consolix
 
#endif // CONSOLIX_USE_EVENT_HUB == 1
 
#endif // _CONSOLIX_MODULE_HUB_COMPONENT_HPP_INCLUDED