From 0a49b31094f5a3414686b20f69f953369705dfb0 Mon Sep 17 00:00:00 2001 From: Johanness Date: Sun, 14 Jun 2026 21:09:50 +0300 Subject: [PATCH] fabric-bridge: flush logs on info, log worker thread start --- libs/dmf-node/src/node_runner.cpp | 1 + nodes/fabric-bridge/src/fabric_bridge_node.cpp | 2 +- 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/libs/dmf-node/src/node_runner.cpp b/libs/dmf-node/src/node_runner.cpp index 397acce..603ba30 100644 --- a/libs/dmf-node/src/node_runner.cpp +++ b/libs/dmf-node/src/node_runner.cpp @@ -57,6 +57,7 @@ int NodeRunner::exec(std::unique_ptr node) { std::signal(SIGINT, signal_handler); std::signal(SIGTERM, signal_handler); + spdlog::flush_on(spdlog::level::info); spdlog::info("Starting node '{}' type='{}'", node_id_, node->type()); if (!std::filesystem::exists(mxl_domain_)) { diff --git a/nodes/fabric-bridge/src/fabric_bridge_node.cpp b/nodes/fabric-bridge/src/fabric_bridge_node.cpp index ebb6fb5..d8b39c2 100644 --- a/nodes/fabric-bridge/src/fabric_bridge_node.cpp +++ b/nodes/fabric-bridge/src/fabric_bridge_node.cpp @@ -87,7 +87,7 @@ void FabricBridgeNode::on_remove_reader(const std::string& port_id) { void FabricBridgeNode::process() { if (!worker_thread_.has_value() && start_requested_.load()) { - running_ = true; + spdlog::info("Fabric-bridge: starting worker thread (mode={})", mode_ == FabricMode::Initiator ? "initiator" : "target"); if (mode_ == FabricMode::Initiator) { worker_thread_ = std::thread(&FabricBridgeNode::run_initiator, this); } else {