Collaboration diagram for kcenon::network::integration::NetworkSystemBridge::Impl:

Public Member Functions
	Impl ()=default

	~Impl ()

VoidResult	initialize (const NetworkSystemBridgeConfig &config)

VoidResult	shutdown ()

bool	is_initialized () const

BridgeMetrics	get_metrics () const

std::shared_ptr< ThreadPoolBridge >	get_thread_pool_bridge () const

std::shared_ptr< thread_pool_interface >	get_thread_pool () const

std::shared_ptr< logger_interface >	get_logger () const

std::shared_ptr< monitoring_interface >	get_monitoring () const

VoidResult	set_thread_pool_bridge (std::shared_ptr< ThreadPoolBridge > bridge)

VoidResult	set_logger (std::shared_ptr< logger_interface > logger)

VoidResult	set_monitoring (std::shared_ptr< monitoring_interface > monitoring)

Private Attributes
std::mutex	mutex_

std::atomic< bool >	initialized_ {false}

NetworkSystemBridgeConfig	config_

std::vector< std::string >	initialized_bridges_

std::shared_ptr< ThreadPoolBridge >	thread_pool_bridge_

std::shared_ptr< logger_interface >	logger_

std::shared_ptr< monitoring_interface >	monitoring_

Detailed Description

Definition at line 18 of file network_system_bridge.cpp.

Constructor & Destructor Documentation

◆ Impl()

kcenon::network::integration::NetworkSystemBridge::Impl::Impl ( )

default

◆ ~Impl()

kcenon::network::integration::NetworkSystemBridge::Impl::~Impl ( )

inline

Definition at line 22 of file network_system_bridge.cpp.

            {
        if (initialized_.load()) {
            shutdown();
        }
    }

References initialized_, and shutdown().

Here is the call graph for this function:

Member Function Documentation

◆ get_logger()

std::shared_ptr< logger_interface > kcenon::network::integration::NetworkSystemBridge::Impl::get_logger ( ) const

inline

Definition at line 134 of file network_system_bridge.cpp.

                                                       {
        std::lock_guard<std::mutex> lock(mutex_);
        return logger_;
    }

References logger_, and mutex_.

◆ get_metrics()

BridgeMetrics kcenon::network::integration::NetworkSystemBridge::Impl::get_metrics ( ) const

inline

Definition at line 99 of file network_system_bridge.cpp.

                                      {
        std::lock_guard<std::mutex> lock(mutex_);
 
        BridgeMetrics aggregated;
        aggregated.is_healthy = true;
        aggregated.last_activity = std::chrono::steady_clock::now();
 
        // Aggregate thread pool metrics
        if (thread_pool_bridge_ && thread_pool_bridge_->is_initialized()) {
            auto thread_metrics = thread_pool_bridge_->get_metrics();
            aggregated.is_healthy &= thread_metrics.is_healthy;
 
            for (const auto& [key, value] : thread_metrics.custom_metrics) {
                aggregated.custom_metrics["thread_pool." + key] = value;
            }
        }
 
        // Future: Aggregate logger and monitoring metrics
 
        return aggregated;
    }

References kcenon::network::integration::BridgeMetrics::custom_metrics, kcenon::network::integration::BridgeMetrics::is_healthy, kcenon::network::integration::BridgeMetrics::last_activity, mutex_, and thread_pool_bridge_.

◆ get_monitoring()

std::shared_ptr< monitoring_interface > kcenon::network::integration::NetworkSystemBridge::Impl::get_monitoring ( ) const

inline

Definition at line 139 of file network_system_bridge.cpp.

                                                               {
        std::lock_guard<std::mutex> lock(mutex_);
        return monitoring_;
    }

References monitoring_, and mutex_.

◆ get_thread_pool()

std::shared_ptr< thread_pool_interface > kcenon::network::integration::NetworkSystemBridge::Impl::get_thread_pool ( ) const

inline

Definition at line 126 of file network_system_bridge.cpp.

                                                                 {
        std::lock_guard<std::mutex> lock(mutex_);
        if (thread_pool_bridge_) {
            return thread_pool_bridge_->get_thread_pool();
        }
        return nullptr;
    }

References mutex_, and thread_pool_bridge_.

◆ get_thread_pool_bridge()

std::shared_ptr< ThreadPoolBridge > kcenon::network::integration::NetworkSystemBridge::Impl::get_thread_pool_bridge ( ) const

inline

Definition at line 121 of file network_system_bridge.cpp.

                                                                   {
        std::lock_guard<std::mutex> lock(mutex_);
        return thread_pool_bridge_;
    }

References mutex_, and thread_pool_bridge_.

◆ initialize()

VoidResult kcenon::network::integration::NetworkSystemBridge::Impl::initialize ( const NetworkSystemBridgeConfig & config )

inline

Definition at line 28 of file network_system_bridge.cpp.

                                                                   {
        std::lock_guard<std::mutex> lock(mutex_);
 
        if (initialized_.load()) {
            return error_void(
                error_codes::common_errors::already_exists,
                "NetworkSystemBridge already initialized",
                "NetworkSystemBridge::initialize");
        }
 
        // Store configuration
        config_ = config;
 
        // Initialize thread pool bridge if enabled
        if (config.enable_thread_pool && thread_pool_bridge_) {
            BridgeConfig thread_config;
            thread_config.integration_name = config.integration_name;
            thread_config.properties = config.thread_pool_properties;
 
            auto result = thread_pool_bridge_->initialize(thread_config);
            if (result.is_err()) {
                return error_void(
                    error_codes::common_errors::internal_error,
                    "Failed to initialize thread pool bridge: " + result.error().message,
                    "NetworkSystemBridge::initialize");
            }
            initialized_bridges_.push_back("thread_pool");
        }
 
        // Future: Initialize logger bridge if enabled
        if (config.enable_logger && logger_) {
            // Logger initialization logic here
            initialized_bridges_.push_back("logger");
        }
 
        // Future: Initialize monitoring bridge if enabled
        if (config.enable_monitoring && monitoring_) {
            // Monitoring initialization logic here
            initialized_bridges_.push_back("monitoring");
        }
 
        initialized_.store(true);
        return ok();
    }

References kcenon::network::error_codes::common_errors::already_exists, config, config_, kcenon::network::error_void(), initialized_, initialized_bridges_, kcenon::network::integration::BridgeConfig::integration_name, kcenon::network::error_codes::common_errors::internal_error, logger_, monitoring_, mutex_, kcenon::network::ok(), kcenon::network::integration::BridgeConfig::properties, and thread_pool_bridge_.

Here is the call graph for this function:

◆ is_initialized()

bool kcenon::network::integration::NetworkSystemBridge::Impl::is_initialized ( ) const

inline

Definition at line 95 of file network_system_bridge.cpp.

                                {
        return initialized_.load();
    }

References initialized_.

◆ set_logger()

VoidResult kcenon::network::integration::NetworkSystemBridge::Impl::set_logger ( std::shared_ptr< logger_interface > logger )

inline

Definition at line 165 of file network_system_bridge.cpp.

                                                                  {
        std::lock_guard<std::mutex> lock(mutex_);
 
        if (initialized_.load()) {
            return error_void(
                error_codes::common_errors::already_exists,
                "Cannot set logger after initialization",
                "NetworkSystemBridge::set_logger");
        }
 
        logger_ = std::move(logger);
        return ok();
    }

References kcenon::network::error_codes::common_errors::already_exists, kcenon::network::error_void(), initialized_, logger_, mutex_, and kcenon::network::ok().

Here is the call graph for this function:

◆ set_monitoring()

VoidResult kcenon::network::integration::NetworkSystemBridge::Impl::set_monitoring ( std::shared_ptr< monitoring_interface > monitoring )

inline

Definition at line 179 of file network_system_bridge.cpp.

                                                                              {
        std::lock_guard<std::mutex> lock(mutex_);
 
        if (initialized_.load()) {
            return error_void(
                error_codes::common_errors::already_exists,
                "Cannot set monitoring after initialization",
                "NetworkSystemBridge::set_monitoring");
        }
 
        monitoring_ = std::move(monitoring);
        return ok();
    }

References kcenon::network::error_codes::common_errors::already_exists, kcenon::network::error_void(), initialized_, monitoring_, mutex_, and kcenon::network::ok().

Here is the call graph for this function:

◆ set_thread_pool_bridge()

VoidResult kcenon::network::integration::NetworkSystemBridge::Impl::set_thread_pool_bridge ( std::shared_ptr< ThreadPoolBridge > bridge )

inline

Definition at line 144 of file network_system_bridge.cpp.

                                                                              {
        std::lock_guard<std::mutex> lock(mutex_);
 
        if (initialized_.load()) {
            return error_void(
                error_codes::common_errors::already_exists,
                "Cannot set thread pool bridge after initialization",
                "NetworkSystemBridge::set_thread_pool_bridge");
        }
 
        if (!bridge) {
            return error_void(
                error_codes::common_errors::invalid_argument,
                "Thread pool bridge cannot be null",
                "NetworkSystemBridge::set_thread_pool_bridge");
        }
 
        thread_pool_bridge_ = std::move(bridge);
        return ok();
    }

References kcenon::network::error_codes::common_errors::already_exists, kcenon::network::error_void(), initialized_, kcenon::network::error_codes::common_errors::invalid_argument, mutex_, kcenon::network::ok(), and thread_pool_bridge_.

Here is the call graph for this function:

◆ shutdown()

VoidResult kcenon::network::integration::NetworkSystemBridge::Impl::shutdown ( )

inline

Definition at line 73 of file network_system_bridge.cpp.

                          {
        std::lock_guard<std::mutex> lock(mutex_);
 
        if (!initialized_.load()) {
            return ok(); // Idempotent
        }
 
        // Shutdown in reverse order
        std::reverse(initialized_bridges_.begin(), initialized_bridges_.end());
 
        for (const auto& bridge_name : initialized_bridges_) {
            if (bridge_name == "thread_pool" && thread_pool_bridge_) {
                thread_pool_bridge_->shutdown();
            }
            // Future: Handle other bridges
        }
 
        initialized_bridges_.clear();
        initialized_.store(false);
        return ok();
    }

References initialized_, initialized_bridges_, mutex_, kcenon::network::ok(), and thread_pool_bridge_.

Referenced by ~Impl().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

◆ config_

NetworkSystemBridgeConfig kcenon::network::integration::NetworkSystemBridge::Impl::config_

private

Definition at line 196 of file network_system_bridge.cpp.

Referenced by initialize().

◆ initialized_

std::atomic<bool> kcenon::network::integration::NetworkSystemBridge::Impl::initialized_ {false}

private

Definition at line 195 of file network_system_bridge.cpp.

195{false};

Referenced by initialize(), is_initialized(), set_logger(), set_monitoring(), set_thread_pool_bridge(), shutdown(), and ~Impl().

◆ initialized_bridges_

std::vector<std::string> kcenon::network::integration::NetworkSystemBridge::Impl::initialized_bridges_

private

Definition at line 197 of file network_system_bridge.cpp.

Referenced by initialize(), and shutdown().

◆ logger_

std::shared_ptr<logger_interface> kcenon::network::integration::NetworkSystemBridge::Impl::logger_

private

Definition at line 200 of file network_system_bridge.cpp.

Referenced by get_logger(), initialize(), and set_logger().

◆ monitoring_

std::shared_ptr<monitoring_interface> kcenon::network::integration::NetworkSystemBridge::Impl::monitoring_

private

Definition at line 201 of file network_system_bridge.cpp.

Referenced by get_monitoring(), initialize(), and set_monitoring().

◆ mutex_

std::mutex kcenon::network::integration::NetworkSystemBridge::Impl::mutex_

mutableprivate

Definition at line 194 of file network_system_bridge.cpp.

Referenced by get_logger(), get_metrics(), get_monitoring(), get_thread_pool(), get_thread_pool_bridge(), initialize(), set_logger(), set_monitoring(), set_thread_pool_bridge(), and shutdown().

◆ thread_pool_bridge_

std::shared_ptr<ThreadPoolBridge> kcenon::network::integration::NetworkSystemBridge::Impl::thread_pool_bridge_

private

Definition at line 199 of file network_system_bridge.cpp.

Referenced by get_metrics(), get_thread_pool(), get_thread_pool_bridge(), initialize(), set_thread_pool_bridge(), and shutdown().

The documentation for this class was generated from the following file:

src/integration/network_system_bridge.cpp

Public Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ Impl()

◆ ~Impl()

Member Function Documentation

◆ get_logger()

◆ get_metrics()

◆ get_monitoring()

◆ get_thread_pool()

◆ get_thread_pool_bridge()

◆ initialize()

◆ is_initialized()

◆ set_logger()

◆ set_monitoring()

◆ set_thread_pool_bridge()

◆ shutdown()

Member Data Documentation

◆ config_

◆ initialized_

◆ initialized_bridges_

◆ logger_

◆ monitoring_

◆ mutex_

◆ thread_pool_bridge_