Skip to content

Commit

Permalink
Uncrustify
Browse files Browse the repository at this point in the history
Signed-off-by: Juan López Fernández <[email protected]>
  • Loading branch information
juanlofer-eprosima committed May 29, 2023
1 parent 26b5861 commit ed5405e
Show file tree
Hide file tree
Showing 4 changed files with 17 additions and 17 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -35,7 +35,7 @@ namespace dds {
/**
* TODO comment
*/
class DdsCommonParticipant : public core::IParticipant , public eprosima::fastdds::dds::DomainParticipantListener
class DdsCommonParticipant : public core::IParticipant, public eprosima::fastdds::dds::DomainParticipantListener
{
public:

Expand All @@ -60,7 +60,7 @@ class DdsCommonParticipant : public core::IParticipant , public eprosima::fastdd
// TODO
DDSPIPE_PARTICIPANTS_DllAPI
DdsCommonParticipant(
const std::shared_ptr<SimpleParticipantConfiguration>& participant_configuration);
const std::shared_ptr<SimpleParticipantConfiguration>& participant_configuration);

eprosima::fastdds::dds::DomainParticipant* dds_participant_;
eprosima::fastdds::dds::Publisher* dds_publisher_;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -71,19 +71,19 @@ class DynTypesPublicationParticipant : public dds::DdsCommonParticipant

DDSPIPE_PARTICIPANTS_DllAPI
void create_empty_datawriter_nts_(
const core::types::DdsTopic& topic);
const core::types::DdsTopic& topic);

static
DDSPIPE_PARTICIPANTS_DllAPI
fastdds::dds::DataWriterQos
default_empty_datawriter_qos_(
const core::types::DdsTopic& topic) noexcept;
const core::types::DdsTopic& topic) noexcept;

static
DDSPIPE_PARTICIPANTS_DllAPI
fastdds::dds::TopicQos
default_topic_qos_(
const core::types::DdsTopic& topic) noexcept;
const core::types::DdsTopic& topic) noexcept;

std::map<
core::types::DdsTopic,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ DynTypesPublicationParticipant::DynTypesPublicationParticipant(

discovery_database->add_endpoint(
rtps::CommonParticipant::simulate_endpoint(type_object_topic(), this->id())
);
);
}

DynTypesPublicationParticipant::~DynTypesPublicationParticipant()
Expand Down Expand Up @@ -188,7 +188,7 @@ void DynTypesPublicationParticipant::create_empty_datawriter_nts_(
topic.topic_name(),
topic.type_name,
default_topic_qos_(topic)
);
);

// Create writer
writers_[topic] =
Expand All @@ -204,32 +204,32 @@ void DynTypesPublicationParticipant::create_empty_datawriter_nts_(

fastdds::dds::DataWriterQos
DynTypesPublicationParticipant::default_empty_datawriter_qos_(
const core::types::DdsTopic& topic) noexcept
const core::types::DdsTopic& topic) noexcept
{
// TODO decide which qos to use. Using less restrictive
auto qos = fastdds::dds::DataWriterQos();
qos.durability().kind =
( topic.topic_qos.is_transient_local() ?
( topic.topic_qos.is_transient_local() ?
fastdds::dds::DurabilityQosPolicyKind::TRANSIENT_LOCAL_DURABILITY_QOS :
fastdds::dds::DurabilityQosPolicyKind::VOLATILE_DURABILITY_QOS
);
);
qos.reliability().kind =
( topic.topic_qos.is_reliable() ?
( topic.topic_qos.is_reliable() ?
fastdds::dds::ReliabilityQosPolicyKind::RELIABLE_RELIABILITY_QOS :
fastdds::dds::ReliabilityQosPolicyKind::BEST_EFFORT_RELIABILITY_QOS
);
);
qos.ownership().kind =
( topic.topic_qos.has_ownership() ?
( topic.topic_qos.has_ownership() ?
fastdds::dds::OwnershipQosPolicyKind::EXCLUSIVE_OWNERSHIP_QOS :
fastdds::dds::OwnershipQosPolicyKind::SHARED_OWNERSHIP_QOS
);
);

return qos;
}

fastdds::dds::TopicQos
DynTypesPublicationParticipant::default_topic_qos_(
const core::types::DdsTopic& topic) noexcept
const core::types::DdsTopic& topic) noexcept
{
// TODO decide which qos to use
return fastdds::dds::TopicQos();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,11 +52,11 @@ DynTypesSubscriptionParticipant::DynTypesSubscriptionParticipant(
const std::shared_ptr<core::DiscoveryDatabase>& discovery_database)
: dds::DdsCommonParticipant(participant_configuration)
, type_object_reader_(std::make_shared<InternalReader>(
participant_configuration->id))
participant_configuration->id))
{
discovery_database->add_endpoint(
rtps::CommonParticipant::simulate_endpoint(type_object_topic(), this->id())
);
);
}

std::shared_ptr<IWriter> DynTypesSubscriptionParticipant::create_writer(
Expand Down

0 comments on commit ed5405e

Please sign in to comment.