Skip to content

Commit

Permalink
chore: ament_uncrustify and ament_cpplint
Browse files Browse the repository at this point in the history
  • Loading branch information
YuanYuYuan committed Jan 7, 2025
1 parent 56c65b5 commit 1f9357f
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 3 deletions.
3 changes: 2 additions & 1 deletion rmw_zenoh_cpp/src/detail/rmw_publisher_data.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,8 @@ std::shared_ptr<PublisherData> PublisherData::make(

// Create a Publication Cache if durability is transient_local.
if (adapted_qos_profile.durability == RMW_QOS_POLICY_DURABILITY_TRANSIENT_LOCAL) {
adv_pub_opts.cache = zenoh::ext::SessionExt::AdvancedPublisherOptions::CacheOptions::create_default();
adv_pub_opts.cache =
zenoh::ext::SessionExt::AdvancedPublisherOptions::CacheOptions::create_default();
adv_pub_opts.cache->max_samples = adapted_qos_profile.depth;
}

Expand Down
5 changes: 3 additions & 2 deletions rmw_zenoh_cpp/src/detail/rmw_subscription_data.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -182,7 +182,8 @@ bool SubscriptionData::init()
// as we start supporting more qos settings.
if (entity_->topic_info()->qos_.durability == RMW_QOS_POLICY_DURABILITY_TRANSIENT_LOCAL) {
adv_sub_opts.query_timeout_ms = std::numeric_limits<uint64_t>::max();
adv_sub_opts.history = zenoh::ext::SessionExt::AdvancedSubscriberOptions::HistoryOptions::create_default();
adv_sub_opts.history =
zenoh::ext::SessionExt::AdvancedSubscriberOptions::HistoryOptions::create_default();
adv_sub_opts.history->detect_late_publishers = true;
adv_sub_opts.history->max_samples = entity_->topic_info()->qos_.depth;
adv_sub_opts.recovery = zenoh::ext::SessionExt::AdvancedSubscriberOptions::RecoveryOptions{};
Expand Down Expand Up @@ -216,7 +217,7 @@ bool SubscriptionData::init()
get_system_time_in_ns(),
std::move(attachment_data)),
std::string(sample.get_keyexpr().as_string_view()));
};
};
sub_ = context_impl->session()->ext().declare_advanced_subscriber(
sub_ke,
on_sample,
Expand Down

0 comments on commit 1f9357f

Please sign in to comment.