Add compression_threads_priority to the node params parser

Signed-off-by: Michael Orlov <michael.orlov@apex.ai>

Author: morlov-apexai

rosbag2_transport/src/rosbag2_transport/config_options_from_node_params.cpp

@@ -235,6 +235,10 @@ RecordOptions get_record_options_from_node_params(rclcpp::Node & node)
     node, "record.compression_threads", 0, std::numeric_limits<int64_t>::max(),
     record_options.compression_threads);
 
+  record_options.compression_threads_priority = param_utils::declare_integer_node_params<int32_t>(
+    node, "record.compression_threads_priority", std::numeric_limits<int32_t>::min(),
+    std::numeric_limits<int32_t>::max(), record_options.compression_threads_priority);
+
   std::string qos_profile_overrides_path =
     node.declare_parameter<std::string>("record.qos_profile_overrides_path", "");
 

rosbag2_transport/test/resources/recorder_node_params.yaml

@@ -18,6 +18,7 @@ recorder_params_node:
       compression_format: "h264"
       compression_queue_size: 10
       compression_threads: 2
+      compression_threads_priority: -1
       qos_profile_overrides_path: ""
       include_hidden_topics: true
       include_unpublished_topics: true

rosbag2_transport/test/rosbag2_transport/test_composable_recorder.cpp

@@ -220,6 +220,7 @@ TEST_P(ComposableRecorderTests, recorder_can_parse_parameters_from_file) {
   EXPECT_EQ(record_options.compression_format, "h264");
   EXPECT_EQ(record_options.compression_queue_size, 10);
   EXPECT_EQ(record_options.compression_threads, 2);
+  EXPECT_EQ(record_options.compression_threads_priority, -1);
   std::unordered_map<std::string, rclcpp::QoS> topic_qos_profile_overrides{
     std::pair{
       "/overrided_topic_qos",