Skip to content

Commit

Permalink
Refs #21841: Linter
Browse files Browse the repository at this point in the history
Signed-off-by: Mario Dominguez <mariodominguez@eprosima.com>
  • Loading branch information
Mario-DL committed Oct 21, 2024
1 parent 8585eb6 commit 6bf201d
Show file tree
Hide file tree
Showing 3 changed files with 22 additions and 18 deletions.
36 changes: 20 additions & 16 deletions src/cpp/rtps/builtin/discovery/endpoint/EDP.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -873,12 +873,12 @@ bool EDP::pairingReader(
{
reader->get_listener()->on_requested_incompatible_qos(reader, incompatible_qos);
#ifdef FASTDDS_STATISTICS
auto proxy_observer = mp_PDP->get_proxy_observer();
// notify monitor service of a qos incompatibility
if (nullptr != proxy_observer)
{
proxy_observer->on_incompatible_qos_matching(R->getGuid(), wdatait->guid(), incompatible_qos);
}
auto proxy_observer = mp_PDP->get_proxy_observer();
// notify monitor service of a qos incompatibility
if (nullptr != proxy_observer)
{
proxy_observer->on_incompatible_qos_matching(R->getGuid(), wdatait->guid(), incompatible_qos);
}
#endif // ifdef FASTDDS_STATISTICS
}

Expand Down Expand Up @@ -973,12 +973,12 @@ bool EDP::pairingWriter(
{
writer->get_listener()->on_offered_incompatible_qos(writer, incompatible_qos);
#ifdef FASTDDS_STATISTICS
auto proxy_observer = mp_PDP->get_proxy_observer();
// notify monitor service of a qos incompatibility
if (nullptr != proxy_observer)
{
proxy_observer->on_incompatible_qos_matching(W->getGuid(), rdatait->guid(), incompatible_qos);
}
auto proxy_observer = mp_PDP->get_proxy_observer();
// notify monitor service of a qos incompatibility
if (nullptr != proxy_observer)
{
proxy_observer->on_incompatible_qos_matching(W->getGuid(), rdatait->guid(), incompatible_qos);
}
#endif // ifdef FASTDDS_STATISTICS
}

Expand Down Expand Up @@ -1060,7 +1060,8 @@ bool EDP::pairing_reader_proxy_with_any_local_writer(
// notify monitor service of a qos incompatibility
if (nullptr != proxy_observer)
{
proxy_observer->on_incompatible_qos_matching(w.getGuid(), rdata->guid(), incompatible_qos);
proxy_observer->on_incompatible_qos_matching(w.getGuid(), rdata->guid(),
incompatible_qos);
}
#endif // ifdef FASTDDS_STATISTICS
}
Expand Down Expand Up @@ -1136,7 +1137,8 @@ bool EDP::pairing_reader_proxy_with_local_writer(
// notify monitor service of a qos incompatibility
if (nullptr != proxy_observer)
{
proxy_observer->on_incompatible_qos_matching(local_writer, rdata.guid(), incompatible_qos);
proxy_observer->on_incompatible_qos_matching(local_writer, rdata.guid(),
incompatible_qos);
}
#endif // ifdef FASTDDS_STATISTICS
}
Expand Down Expand Up @@ -1267,7 +1269,8 @@ bool EDP::pairing_writer_proxy_with_any_local_reader(
// notify monitor service of a qos incompatibility
if (nullptr != proxy_observer)
{
proxy_observer->on_incompatible_qos_matching(r.getGuid(), wdata->guid(), incompatible_qos);
proxy_observer->on_incompatible_qos_matching(r.getGuid(), wdata->guid(),
incompatible_qos);
}
#endif // ifdef FASTDDS_STATISTICS
}
Expand Down Expand Up @@ -1343,7 +1346,8 @@ bool EDP::pairing_writer_proxy_with_local_reader(
// notify monitor service of a qos incompatibility
if (nullptr != proxy_observer)
{
proxy_observer->on_incompatible_qos_matching(local_reader, wdata.guid(), incompatible_qos);
proxy_observer->on_incompatible_qos_matching(local_reader, wdata.guid(),
incompatible_qos);
}
#endif // ifdef FASTDDS_STATISTICS
}
Expand Down
2 changes: 1 addition & 1 deletion src/cpp/statistics/rtps/monitor-service/MonitorService.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -263,7 +263,7 @@ class MonitorService
// Stores the current extended incompatible qos status
// of local entities with remote entities and their policies.
std::map<fastdds::rtps::GUID_t, ExtendedIncompatibleQoSStatusSeq_s>
extended_incompatible_qos_collection_;
extended_incompatible_qos_collection_;

std::mutex extended_incompatible_qos_mtx_;
};
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -265,7 +265,7 @@ class MonitorService
MonitorServiceStatusDataPubSubType type_;

std::map<fastdds::rtps::GUID_t, ExtendedIncompatibleQoSStatusSeq_s>
extended_incompatible_qos_collection_;
extended_incompatible_qos_collection_;

std::mutex extended_incompatible_qos_mtx_;
};
Expand Down

0 comments on commit 6bf201d

Please sign in to comment.