mirror of
https://github.com/micro-ROS/micro-ROS-Agent.git
synced 2026-09-06 18:05:17 +02:00
(cherry picked from commit a623308505)
Co-authored-by: Pablo Garrido <pablogs9@gmail.com>
This commit is contained in:
co-authored by
Pablo Garrido
parent
e133754746
commit
a313a088bd
@@ -309,8 +309,36 @@ void GraphManager::add_participant(
|
|||||||
|
|
||||||
if (node_name != enclave) // Do not add root node
|
if (node_name != enclave) // Do not add root node
|
||||||
{
|
{
|
||||||
|
// Split node name in domain and node name
|
||||||
|
std::istringstream iss(node_name);
|
||||||
|
std::vector<std::string> result;
|
||||||
|
std::string token;
|
||||||
|
|
||||||
|
while(std::getline(iss, token, '/'))
|
||||||
|
{
|
||||||
|
result.push_back(token);
|
||||||
|
}
|
||||||
|
|
||||||
|
std::string isolated_node_name = "";
|
||||||
|
std::string isolated_namespace = "";
|
||||||
|
|
||||||
|
if (result.size() > 1)
|
||||||
|
{
|
||||||
|
isolated_namespace = result[0];
|
||||||
|
for (size_t i = 1; i < result.size(); i++)
|
||||||
|
{
|
||||||
|
isolated_node_name.append(result[i] + "/");
|
||||||
|
}
|
||||||
|
isolated_node_name.pop_back();
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
isolated_node_name = node_name;
|
||||||
|
isolated_namespace = "";
|
||||||
|
}
|
||||||
|
|
||||||
rmw_dds_common::msg::ParticipantEntitiesInfo info =
|
rmw_dds_common::msg::ParticipantEntitiesInfo info =
|
||||||
graphCache_.add_node(gid, node_name, enclave_);
|
graphCache_.add_node(gid, isolated_node_name, isolated_namespace);
|
||||||
ros_discovery_datawriter_->write(static_cast<void *>(&info));
|
ros_discovery_datawriter_->write(static_cast<void *>(&info));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -587,7 +615,7 @@ static eprosima::fastdds::dds::DataReaderQos reader_qos_conversion(
|
|||||||
const eprosima::fastdds::dds::ReaderQos& reader_qos)
|
const eprosima::fastdds::dds::ReaderQos& reader_qos)
|
||||||
{
|
{
|
||||||
eprosima::fastdds::dds::DataReaderQos datareader_qos;
|
eprosima::fastdds::dds::DataReaderQos datareader_qos;
|
||||||
|
|
||||||
datareader_qos.durability(reader_qos.m_durability);
|
datareader_qos.durability(reader_qos.m_durability);
|
||||||
datareader_qos.deadline(reader_qos.m_deadline);
|
datareader_qos.deadline(reader_qos.m_deadline);
|
||||||
datareader_qos.latency_budget(reader_qos.m_latencyBudget);
|
datareader_qos.latency_budget(reader_qos.m_latencyBudget);
|
||||||
|
|||||||
Reference in New Issue
Block a user