core: add missing locks in command queue

mavlink · Nov 11, 2024 · e393094 · e393094
1 parent 6a93d83
commit e393094
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/mavsdk/core/mavlink_command_sender.cpp b/src/mavsdk/core/mavlink_command_sender.cpp
@@ -88,6 +88,7 @@ void MavlinkCommandSender::queue_command_async(
 
     CommandIdentification identification = identification_from_command(command);
 
+    LockedQueue<Work>::Guard work_queue_guard(_work_queue);
     for (const auto& work : _work_queue) {
         if (work->identification == identification && callback == nullptr) {
             if (_command_debugging) {
@@ -117,6 +118,7 @@ void MavlinkCommandSender::queue_command_async(
 
     CommandIdentification identification = identification_from_command(command);
 
+    LockedQueue<Work>::Guard work_queue_guard(_work_queue);
     for (const auto& work : _work_queue) {
         if (work->identification == identification && callback == nullptr) {
             if (_command_debugging) {