itten/DMF-Studio
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fabric-bridge: flush logs on info, log worker thread start

Browse Source
This commit is contained in:
Johanness
2026-06-14 21:09:50 +03:00
parent 62e2dc49bf
commit 0a49b31094
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
libs/dmf-node/src/node_runner.cpp
+1
View File
@@ -57,6 +57,7 @@ int NodeRunner::exec(std::unique_ptr<Node> node) {
std::signal(SIGINT, signal_handler); std::signal(SIGINT, signal_handler);
std::signal(SIGTERM, signal_handler); std::signal(SIGTERM, signal_handler);
spdlog::flush_on(spdlog::level::info);
spdlog::info("Starting node '{}' type='{}'", node_id_, node->type()); spdlog::info("Starting node '{}' type='{}'", node_id_, node->type());
if (!std::filesystem::exists(mxl_domain_)) { if (!std::filesystem::exists(mxl_domain_)) {
nodes/fabric-bridge/src/fabric_bridge_node.cpp
+1 -1
View File
@@ -87,7 +87,7 @@ void FabricBridgeNode::on_remove_reader(const std::string& port_id) {
void FabricBridgeNode::process() { void FabricBridgeNode::process() {
if (!worker_thread_.has_value() && start_requested_.load()) { 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) { if (mode_ == FabricMode::Initiator) {
worker_thread_ = std::thread(&FabricBridgeNode::run_initiator, this); worker_thread_ = std::thread(&FabricBridgeNode::run_initiator, this);
} else { } else {