@@ -75,7 +75,7 @@ void SequentialCompressionWriter::compression_thread_fn()
75
75
int wanted_thread_priority = *compression_options_.thread_priority ;
76
76
if (!SetThreadPriority (GetCurrentThread (), wanted_thread_priority)) {
77
77
ROSBAG2_COMPRESSION_LOG_WARN_STREAM (
78
- " Could not set thread priority of compression thread to the : " << wanted_thread_priority <<
78
+ " Could not set thread priority of compression thread to: " << wanted_thread_priority <<
79
79
" . Error code: " << GetLastError ());
80
80
} else {
81
81
auto detected_thread_priority = GetThreadPriority (GetCurrentThread ());
@@ -84,7 +84,7 @@ void SequentialCompressionWriter::compression_thread_fn()
84
84
" Failed to get current thread priority. Error code: " << GetLastError ());
85
85
} else if (wanted_thread_priority != detected_thread_priority) {
86
86
ROSBAG2_COMPRESSION_LOG_WARN_STREAM (
87
- " Could not set thread priority of compression thread to the : " <<
87
+ " Could not set thread priority of compression thread to: " <<
88
88
wanted_thread_priority << " . Detected thread priority: " << detected_thread_priority);
89
89
}
90
90
}
@@ -95,13 +95,13 @@ void SequentialCompressionWriter::compression_thread_fn()
95
95
int cur_nice_value = getpriority (PRIO_PROCESS, 0 );
96
96
if (cur_nice_value == -1 && errno != 0 ) {
97
97
ROSBAG2_COMPRESSION_LOG_WARN_STREAM (
98
- " Could not set nice value of compression thread to the : " << wanted_nice_value <<
98
+ " Could not set nice value of compression thread to: " << wanted_nice_value <<
99
99
" : Could not determine cur nice value" );
100
100
} else {
101
101
int new_nice_value = nice (wanted_nice_value - cur_nice_value);
102
102
if ((new_nice_value == -1 && errno != 0 )) {
103
103
ROSBAG2_COMPRESSION_LOG_WARN_STREAM (
104
- " Could not set nice value of compression thread to the : " << wanted_nice_value <<
104
+ " Could not set nice value of compression thread to: " << wanted_nice_value <<
105
105
" . Error : " << std::strerror (errno));
106
106
}
107
107
}
0 commit comments