Commit dbf04d90 authored by Martin Vala's avatar Martin Vala Committed by Branislav Beke

Resolve "Print redirector information about number of workers"

parent 6a01f403
......@@ -97,6 +97,7 @@ void Feeder::onExit(Message * inMsg, std::vector<std::string> & /*out*/)
subscribe(inMsg->uuid());
}
mNodeManager->print();
SPD_INFO("Workers [{}] slots [{}]", mNodeInfo->hosts_size(), mNodeInfo->slots());
}
}
void Feeder::onWhisper(Message * inMsg, std::vector<std::string> & out)
......@@ -209,6 +210,7 @@ void Feeder::onWhisper(Message * inMsg, std::vector<std::string> & out)
slots += m.slots();
}
mNodeInfo->set_slots(slots);
SPD_INFO("Workers [{}] slots [{}]", mNodeInfo->hosts_size(), mNodeInfo->slots());
// mNodeInfo->PrintDebugString();
}
}
......
......@@ -405,12 +405,16 @@ std::shared_ptr<Salsa::Node> create_root_node( //
pSocketZyre->connect(); // Connect to socket
pNodeZyre->addSocket(pSocketZyre); // Add socket to zyre node
SPD_INFO("Node : type [{}] name [{}] discovery [{}] port [{}] discovery [{}]",
SPD_INFO("Node : type [{}] name [{}] discovery type [{}] url [{}] port [{}] ",
name,
zyreName,
props.mType,
props.mPort,
props.mDiscovery);
props.mDiscovery,
props.mPort);
if (Salsa::Object::get_console_output()->level() <
static_cast<int>(spdlog::level::info))
zyre_print(pSocketZyre->zyre());
}
}
pMainNode->add(pNodeZyre); // Add zyre node to main node
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment