Uncrustify

Signed-off-by: Patrick Roncagliolo <[email protected]>

rosbag2_transport/src/rosbag2_transport/config_options_from_node_params.cpp

@@ -160,7 +160,10 @@ PlayOptions get_play_options_from_node_params(rclcpp::Node * node)
   auto playback_until_timestamp_nsec = node->declare_parameter<int32_t>(
     "playback_until_timestamp.nsec",
     0.0);
-  play_options.playback_until_timestamp = rclcpp::Duration(playback_until_timestamp_sec, playback_until_timestamp_nsec).nanoseconds();
+  play_options.playback_until_timestamp = rclcpp::Duration(
+    playback_until_timestamp_sec,
+    playback_until_timestamp_nsec).
+    nanoseconds();
 
   play_options.start_paused = node->declare_parameter<bool>(
     "start_paused",
@@ -184,7 +187,8 @@ PlayOptions get_play_options_from_node_params(rclcpp::Node * node)
   auto wait_acked_timeout_nsec = node->declare_parameter<int32_t>(
     "wait_acked_timeout.nsec",
     0.0);
-  play_options.wait_acked_timeout = rclcpp::Duration(wait_acked_timeout_sec, wait_acked_timeout_nsec).nanoseconds();
+  play_options.wait_acked_timeout =
+    rclcpp::Duration(wait_acked_timeout_sec, wait_acked_timeout_nsec).nanoseconds();
 
   play_options.disable_loan_message = node->declare_parameter<bool>(
     "disable_loan_message",
@@ -218,7 +222,9 @@ RecordOptions get_record_options_from_node_params(rclcpp::Node * node)
   auto topic_polling_interval_nsec = node->declare_parameter<int32_t>(
     "topic_polling_interval.nsec",
     1000000.0);
-  record_options.topic_polling_interval = rclcpp::Duration(topic_polling_interval_sec, topic_polling_interval_nsec).to_chrono<std::chrono::milliseconds>();
+  record_options.topic_polling_interval = rclcpp::Duration(
+    topic_polling_interval_sec,
+    topic_polling_interval_nsec).to_chrono<std::chrono::milliseconds>();
 
   record_options.regex = node->declare_parameter<std::string>(
     "regex",
@@ -316,7 +322,8 @@ get_storage_options_from_node_params(rclcpp::Node * node)
 
   storage_options.storage_id = node->declare_parameter<std::string>("storage_id", "");
 
-  storage_options.storage_config_uri = node->declare_parameter<std::string>("storage_config_uri", "");
+  storage_options.storage_config_uri =
+    node->declare_parameter<std::string>("storage_config_uri", "");
 
   auto desc_mbs = param_utils::int_param_description(
     "Max bagfile size (bytes)",

rosbag2_transport/src/rosbag2_transport/play_options.cpp

@@ -22,7 +22,7 @@
 
 namespace YAML
 {
-  
+
 Node convert<rosbag2_transport::PlayOptions>::encode(
   const rosbag2_transport::PlayOptions & play_options)
 {

rosbag2_transport/src/rosbag2_transport/player.cpp

@@ -1376,4 +1376,4 @@ rosbag2_transport::PlayOptions Player::get_play_options()
 // Register the component with class_loader.
 // This acts as a sort of entry point, allowing the component to be
 // discoverable when its library is being loaded into a running process.
-RCLCPP_COMPONENTS_REGISTER_NODE(rosbag2_transport::Player)
+RCLCPP_COMPONENTS_REGISTER_NODE(rosbag2_transport::Player)

rosbag2_transport/test/rosbag2_transport/test_load_components.cpp

@@ -61,7 +61,7 @@ TEST_F(TestComponentManager, test_load_components)
     auto request = std::make_shared<composition_interfaces::srv::LoadNode::Request>();
     request->package_name = "rosbag2_transport";
     request->plugin_name = "rosbag2_transport::Player";
-    for (auto p: pl){
+    for (auto p: pl) {
       request->parameters.push_back(p.to_parameter_msg());
     }
 
@@ -91,7 +91,7 @@ TEST_F(TestComponentManager, test_load_components)
     auto request = std::make_shared<composition_interfaces::srv::LoadNode::Request>();
     request->package_name = "rosbag2_transport";
     request->plugin_name = "rosbag2_transport::Recorder";
-    for (auto p: pl){
+    for (auto p: pl) {
       request->parameters.push_back(p.to_parameter_msg());
     }
 
@@ -109,4 +109,4 @@ TEST_F(TestComponentManager, test_load_components)
     EXPECT_EQ(result->full_node_name, "/rosbag2_recorder");
     EXPECT_EQ(result->unique_id, 2u);
   }
-}
+}

rosbag2_transport/test/rosbag2_transport/test_play_params.cpp

@@ -54,15 +54,15 @@ TEST_F(RosBag2PlayTestFixture, parse_parameter_from_file) {
   auto qos_node = YAML::LoadFile(_SRC_RESOURCES_DIR_PATH "/overrides.yaml");
 
   YAML::Emitter emitter;
-  emitter 
-  << YAML::Newline << YAML::Comment("params_player.yaml")
-  << param_node << YAML::Newline 
-  << YAML::Newline << YAML::Comment("overrides.yaml")
-  << qos_node << YAML::Newline 
-  << YAML::Newline << YAML::Comment("node play parameters")
-  << yaml_play_opt << YAML::Newline
-  << YAML::Newline << YAML::Comment("node storage parameters")
-  << yaml_storage_opt << YAML::Newline;
+  emitter
+    << YAML::Newline << YAML::Comment("params_player.yaml")
+    << param_node << YAML::Newline
+    << YAML::Newline << YAML::Comment("overrides.yaml")
+    << qos_node << YAML::Newline
+    << YAML::Newline << YAML::Comment("node play parameters")
+    << yaml_play_opt << YAML::Newline
+    << YAML::Newline << YAML::Comment("node storage parameters")
+    << yaml_storage_opt << YAML::Newline;
 
   std::cout << emitter.c_str() << std::endl;
 
@@ -73,4 +73,4 @@ TEST_F(RosBag2PlayTestFixture, parse_parameter_from_file) {
 TEST_F(RosBag2PlayTestFixture, test_negative_durations) {
 // TODO(roncapat): implement
 }
-*/
+*/

rosbag2_transport/test/rosbag2_transport/test_record_params.cpp

@@ -46,23 +46,24 @@ TEST_F(RosBag2RecordTestFixture, parse_parameter_from_file) {
   auto node = std::make_shared<MockRecorder>("recorder_params_node", opts);
   auto record_options = node->retrieve_record_options();
   auto storage_options = node->retrieve_storage_options();
-  YAML::Node yaml_record_opt = YAML::convert<rosbag2_transport::RecordOptions>().encode(record_options);
+  YAML::Node yaml_record_opt = YAML::convert<rosbag2_transport::RecordOptions>().encode(
+    record_options);
   YAML::Node yaml_storage_opt = YAML::convert<rosbag2_storage::StorageOptions>().encode(
     storage_options);
 
   auto param_node = YAML::LoadFile(_SRC_RESOURCES_DIR_PATH "/params_recorder.yaml");
   auto qos_node = YAML::LoadFile(_SRC_RESOURCES_DIR_PATH "/overrides.yaml");
 
   YAML::Emitter emitter;
-  emitter 
-  << YAML::Newline << YAML::Comment("params.yaml")
-  << param_node << YAML::Newline
-  << YAML::Newline << YAML::Comment("overrides.yaml")
-  << qos_node << YAML::Newline 
-  << YAML::Newline << YAML::Comment("node record parameters")
-  << yaml_record_opt << YAML::Newline
-  << YAML::Newline << YAML::Comment("node storage parameters")
-  << yaml_storage_opt << YAML::Newline;
+  emitter
+    << YAML::Newline << YAML::Comment("params.yaml")
+    << param_node << YAML::Newline
+    << YAML::Newline << YAML::Comment("overrides.yaml")
+    << qos_node << YAML::Newline
+    << YAML::Newline << YAML::Comment("node record parameters")
+    << yaml_record_opt << YAML::Newline
+    << YAML::Newline << YAML::Comment("node storage parameters")
+    << yaml_storage_opt << YAML::Newline;
 
   std::cout << emitter.c_str() << std::endl;
 
@@ -73,4 +74,4 @@ TEST_F(RosBag2RecordTestFixture, parse_parameter_from_file) {
 TEST_F(RosBag2PlayTestFixture, test_negative_durations) {
 // TODO(roncapat): implement
 }
-*/
+*/