18329400312

Committed 07 Oct 2025 11:57PM UTC coverage: 47.68% (+0.07%) from 47.615%

Build # 18329400312

Build Type

push

github

Committed by

web-flow

Commit Message

Merge pull request #2680 from mavlink/pr-int64-json

mavlink_direct: handle (u)int > 2^32

Run Details

62 of 67 new or added lines in 3 files covered. (92.54%)

27 existing lines in 10 files now uncovered.

17088 of 35839 relevant lines covered (47.68%)

446.34 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

61.5

/src/mavsdk/core/mavlink_request_message.cpp


#include "log.h"
#include "mavlink_request_message.h"
#include "system_impl.h"
#include <cstdint>
#include <string>

namespace mavsdk {

MavlinkRequestMessage::MavlinkRequestMessage(
    SystemImpl& system_impl,
    MavlinkCommandSender& command_sender,
    MavlinkMessageHandler& message_handler,
    TimeoutHandler& timeout_handler) :
    _system_impl(system_impl),
    _command_sender(command_sender),
    _message_handler(message_handler),
    _timeout_handler(timeout_handler)
{
    if (const char* env_p = std::getenv("MAVSDK_COMMAND_DEBUGGING")) {
        if (std::string(env_p) == "1") {
            LogDebug() << "Command debugging is on.";
            _debugging = true;
        }
    }
}

void MavlinkRequestMessage::request(
    uint32_t message_id,
    uint8_t target_component,
    MavlinkRequestMessageCallback callback,
    uint32_t param2)
{
    std::unique_lock<std::mutex> lock(_mutex);

    // Cleanup previous requests.
    for (const auto id : _deferred_message_cleanup) {
        _message_handler.unregister_one(id, this);
    }
    _deferred_message_cleanup.clear();

    // Respond with 'Busy' if already in progress.
    for (auto& item : _work_items) {
        if (item.message_id == message_id && item.param2 == param2 &&
            item.target_component == target_component) {
            lock.unlock();
            if (callback) {
                callback(MavlinkCommandSender::Result::Busy, {});
            }
            if (_debugging) {
                LogDebug() << "Message " << item.message_id << " already requested";
            }
            return;
        }
    }

    // Otherwise, schedule it.
    _work_items.emplace_back(WorkItem{message_id, target_component, callback, param2});

    // Register for message
    _message_handler.register_one(
        message_id,
        [this](const mavlink_message_t& message) { handle_any_message(message); },
        this);

    // And send off command
    send_request(_work_items.back());
}

void MavlinkRequestMessage::send_request(WorkItem& item)
{
    // Every second time, starting with first retry, we try the old request commands.
    // If no old commands exist, we of course just send the new one again.
    if (item.retries % 2 != 0) {
        if (!try_sending_request_using_old_command(item)) {
            send_request_using_new_command(item);
        }
    } else {
        send_request_using_new_command(item);
    }
}

void MavlinkRequestMessage::send_request_using_new_command(WorkItem& item)
{
    if (_debugging) {
        if (item.retries > 0) {
            LogDebug() << "Request message " << item.message_id
                       << " again using REQUEST_MESSAGE (retries: " << item.retries << ")";
        } else {
            LogDebug() << "Request message " << item.message_id << " using REQUEST_MESSAGE";
        }
    }

    MavlinkCommandSender::CommandLong command_request_message{};
    command_request_message.command = MAV_CMD_REQUEST_MESSAGE;
    command_request_message.target_system_id = _system_impl.get_system_id();
    command_request_message.target_component_id = item.target_component;
    command_request_message.params.maybe_param1 = {static_cast<float>(item.message_id)};
    _command_sender.queue_command_async(
        command_request_message,
        [this, message_id = item.message_id](MavlinkCommandSender::Result result, float) {
            if (result != MavlinkCommandSender::Result::InProgress) {
                handle_command_result(message_id, result);
            }
        },
        1);
}

bool MavlinkRequestMessage::try_sending_request_using_old_command(WorkItem& item)
{
    MavlinkCommandSender::CommandLong command_request_message{};
    command_request_message.target_system_id = _system_impl.get_system_id();
    command_request_message.target_component_id = item.target_component;

    std::string command_name;

    switch (item.message_id) {
        case MAVLINK_MSG_ID_AUTOPILOT_VERSION:
            command_request_message.command = MAV_CMD_REQUEST_AUTOPILOT_CAPABILITIES;
            command_request_message.params.maybe_param1 = {1.f};
            command_name = "REQUEST_AUTOPILOT_CAPABILITIES";
            break;

        case MAVLINK_MSG_ID_CAMERA_INFORMATION:
            command_request_message.command = MAV_CMD_REQUEST_CAMERA_INFORMATION;
            command_request_message.params.maybe_param1 = {1.0f};
            command_name = "REQUEST_CAMERA_INFORMATION";
            break;

        case MAVLINK_MSG_ID_CAMERA_SETTINGS:
            command_request_message.command = MAV_CMD_REQUEST_CAMERA_SETTINGS;
            command_request_message.params.maybe_param1 = {1.0f};
            command_name = "REQUEST_CAMERA_SETTINGS";

            break;

        case MAVLINK_MSG_ID_STORAGE_INFORMATION:
            command_request_message.command = MAV_CMD_REQUEST_STORAGE_INFORMATION;
            command_request_message.params.maybe_param1 = {
                static_cast<float>(item.param2)}; // storage ID
            command_request_message.params.maybe_param2 = {1.0f};
            command_name = "REQUEST_STORAGE_INFORMATION";
            break;

        case MAVLINK_MSG_ID_CAMERA_CAPTURE_STATUS:
            command_request_message.command = MAV_CMD_REQUEST_CAMERA_CAPTURE_STATUS;
            command_request_message.params.maybe_param1 = {1.0f};
            command_name = "REQUEST_CAMERA_CAPTURE_STATUS";
            break;

        case MAVLINK_MSG_ID_FLIGHT_INFORMATION:
            command_request_message.command = MAV_CMD_REQUEST_FLIGHT_INFORMATION;
            command_request_message.params.maybe_param1 = {1.0f};
            command_name = "REQUEST_FLIGHT_INFORMATION";
            break;

        case MAVLINK_MSG_ID_VIDEO_STREAM_STATUS:
            command_request_message.command = MAV_CMD_REQUEST_VIDEO_STREAM_STATUS;
            command_request_message.params.maybe_param1 = {
                static_cast<float>(item.param2)}; // stream ID
            command_name = "REQUEST_VIDEO_STREAM_STATUS";
            break;

        case MAVLINK_MSG_ID_VIDEO_STREAM_INFORMATION:
            command_request_message.command = MAV_CMD_REQUEST_VIDEO_STREAM_INFORMATION;
            command_request_message.params.maybe_param1 = {
                static_cast<float>(item.param2)}; // stream ID
            command_name = "REQUEST_VIDEO_STREAM_INFORMATION";
            break;

        case MAVLINK_MSG_ID_CAMERA_IMAGE_CAPTURED:
            command_request_message.command = MAV_CMD_REQUEST_CAMERA_IMAGE_CAPTURE;
            command_request_message.params.maybe_param1 = {
                static_cast<float>(item.param2)}; // sequence number
            command_name = "REQUEST_CAMERA_IMAGE_CAPTURE";
            break;

        default:
            // No alternative command for this message.
            return false;
    }

    if (_debugging) {
        LogDebug() << "Request message " << item.message_id << " again using " << command_name
                   << " (retries: " << item.retries << ")";
    }

    _command_sender.queue_command_async(
        command_request_message,
        [this, message_id = item.message_id](MavlinkCommandSender::Result result, float) {
            if (result != MavlinkCommandSender::Result::InProgress) {
                handle_command_result(message_id, result);
            }
        },
        1);

    return true;
}

void MavlinkRequestMessage::handle_any_message(const mavlink_message_t& message)
{
    std::unique_lock<std::mutex> lock(_mutex);

    for (auto it = _work_items.begin(); it != _work_items.end(); ++it) {
        // Check if we're waiting for this message.
        // TODO: check if params are correct.
        if (it->message_id != message.msgid && it->target_component == message.compid) {
            continue;
        }

        _timeout_handler.remove(it->timeout_cookie);
        // We have at least the message which is what we care about most, so we
        // tell the user about it and call it a day. If we receive the result
        // of the command later, we ignore it, and we fake the result to be successful
        // anyway.
        auto temp_callback = it->callback;
        // We can now get rid of the entry now.
        _work_items.erase(it);
        // We have to clean up later outside this callback, otherwise we lock ourselves out.
        _deferred_message_cleanup.push_back(message.msgid);
        lock.unlock();

        if (temp_callback) {
            temp_callback(MavlinkCommandSender::Result::Success, message);
        }
        return;
    }
}

void MavlinkRequestMessage::handle_command_result(
    uint32_t message_id, MavlinkCommandSender::Result result)
{
    std::unique_lock<std::mutex> lock(_mutex);

    for (auto it = _work_items.begin(); it != _work_items.end(); ++it) {
        // Check if we're waiting for this result
        if (it->message_id != message_id) {
            continue;
        }

        switch (result) {
            case MavlinkCommandSender::Result::Success:
                // This is promising, let's hope the message will actually arrive.
                // We'll set a timeout in case we need to retry.
                it->timeout_cookie = _timeout_handler.add(
                    [this, message_id, target_component = it->target_component]() {
                        handle_timeout(message_id, target_component);
                    },
                    1.0);
                return;

            case MavlinkCommandSender::Result::Busy:
                // FALLTHROUGH
            case MavlinkCommandSender::Result::Denied:
                // FALLTHROUGH
            case MavlinkCommandSender::Result::Unsupported:
                // FALLTHROUGH
            case MavlinkCommandSender::Result::Timeout:
                // FALLTHROUGH
            case MavlinkCommandSender::Result::TemporarilyRejected:
                // It looks like we should try again
                if (++it->retries > RETRIES) {
                    // We have already retried, let's give up.
                    auto temp_callback = it->callback;
                    _message_handler.unregister_one(it->message_id, this);
                    _work_items.erase(it);
                    lock.unlock();
                    if (temp_callback) {
                        temp_callback(MavlinkCommandSender::Result::Timeout, {});
                    }
                } else {
                    send_request(*it);
                }
                return;

            case MavlinkCommandSender::Result::NoSystem:
                // FALLTHROUGH
            case MavlinkCommandSender::Result::ConnectionError:
                // FALLTHROUGH
            case MavlinkCommandSender::Result::Failed:
                // FALLTHROUGH
            case MavlinkCommandSender::Result::Cancelled:
                // FALLTHROUGH
            case MavlinkCommandSender::Result::UnknownError: {
                // It looks like this did not work, and we can report the error
                // No need to try again.
                auto temp_callback = it->callback;
                _message_handler.unregister_one(it->message_id, this);
                _work_items.erase(it);
                lock.unlock();
                if (temp_callback) {
                    temp_callback(result, {});
                }
                return;
            }

            case MavlinkCommandSender::Result::InProgress:
                // Should not happen, as it is already filtered out.
                return;
        }
    }
}

void MavlinkRequestMessage::handle_timeout(uint32_t message_id, uint8_t target_component)
{
    std::unique_lock<std::mutex> lock(_mutex);

    for (auto it = _work_items.begin(); it != _work_items.end(); ++it) {
        // Check if we're waiting for this result
        if (it->message_id != message_id || it->target_component != target_component) {
            continue;
        }

        if (++it->retries > RETRIES) {
            // We have already retried, let's give up.
            auto temp_callback = it->callback;
            _message_handler.unregister_one(it->message_id, this);
            _work_items.erase(it);
            lock.unlock();
            if (temp_callback) {
                temp_callback(MavlinkCommandSender::Result::Timeout, {});
            }
            return;
        }

        send_request(*it);
    }
}

} // namespace mavsdk

1
2	#include "log.h"
3	#include "mavlink_request_message.h"
4	#include "system_impl.h"
5	#include <cstdint>
6	#include <string>
7
8	namespace mavsdk {
9
10	MavlinkRequestMessage::MavlinkRequestMessage(	129✔
11	SystemImpl& system_impl,
12	MavlinkCommandSender& command_sender,
13	MavlinkMessageHandler& message_handler,
14	TimeoutHandler& timeout_handler) :	129✔
15	_system_impl(system_impl),	129✔
16	_command_sender(command_sender),	129✔
17	_message_handler(message_handler),	129✔
18	_timeout_handler(timeout_handler)	129✔
19	{
20	if (const char* env_p = std::getenv("MAVSDK_COMMAND_DEBUGGING")) {	129✔
21	if (std::string(env_p) == "1") {	×
22	LogDebug() << "Command debugging is on.";	×
23	_debugging = true;	×
24	}
25	}
26	}	129✔
27
28	void MavlinkRequestMessage::request(	103✔
29	uint32_t message_id,
30	uint8_t target_component,
31	MavlinkRequestMessageCallback callback,
32	uint32_t param2)
33	{
34	std::unique_lock<std::mutex> lock(_mutex);	103✔
35
36	// Cleanup previous requests.
37	for (const auto id : _deferred_message_cleanup) {	106✔
38	_message_handler.unregister_one(id, this);	3✔
39	}
40	_deferred_message_cleanup.clear();	103✔
41
42	// Respond with 'Busy' if already in progress.
43	for (auto& item : _work_items) {	203✔
44	if (item.message_id == message_id && item.param2 == param2 &&	100✔
45	item.target_component == target_component) {	×
46	lock.unlock();	×
47	if (callback) {	×
48	callback(MavlinkCommandSender::Result::Busy, {});	×
49	}
50	if (_debugging) {	×
51	LogDebug() << "Message " << item.message_id << " already requested";	×
52	}
53	return;	×
54	}
55	}
56
57	// Otherwise, schedule it.
58	_work_items.emplace_back(WorkItem{message_id, target_component, callback, param2});	103✔
59
60	// Register for message
61	_message_handler.register_one(	103✔
62	message_id,
63	[this](const mavlink_message_t& message) { handle_any_message(message); },	90✔
64	this);
65
66	// And send off command
67	send_request(_work_items.back());	103✔
68	}	103✔
69
70	void MavlinkRequestMessage::send_request(WorkItem& item)	189✔
71	{
72	// Every second time, starting with first retry, we try the old request commands.
73	// If no old commands exist, we of course just send the new one again.
74	if (item.retries % 2 != 0) {	189✔
75	if (!try_sending_request_using_old_command(item)) {	48✔
76	send_request_using_new_command(item);	4✔
77	}
78	} else {
79	send_request_using_new_command(item);	141✔
80	}
81	}	189✔
82
83	void MavlinkRequestMessage::send_request_using_new_command(WorkItem& item)	145✔
84	{
85	if (_debugging) {	145✔
86	if (item.retries > 0) {	×
87	LogDebug() << "Request message " << item.message_id	×
88	<< " again using REQUEST_MESSAGE (retries: " << item.retries << ")";	×
89	} else {
90	LogDebug() << "Request message " << item.message_id << " using REQUEST_MESSAGE";	×
91	}
92	}
93
94	MavlinkCommandSender::CommandLong command_request_message{};	145✔
95	command_request_message.command = MAV_CMD_REQUEST_MESSAGE;	145✔
96	command_request_message.target_system_id = _system_impl.get_system_id();	145✔
97	command_request_message.target_component_id = item.target_component;	145✔
98	command_request_message.params.maybe_param1 = {static_cast<float>(item.message_id)};	145✔
99	_command_sender.queue_command_async(	145✔
100	command_request_message,
101	[this, message_id = item.message_id](MavlinkCommandSender::Result result, float) {	145✔
102	if (result != MavlinkCommandSender::Result::InProgress) {	140✔
103	handle_command_result(message_id, result);	140✔
104	}
105	},	140✔
106	1);
107	}	145✔
108
109	bool MavlinkRequestMessage::try_sending_request_using_old_command(WorkItem& item)	48✔
110	{
111	MavlinkCommandSender::CommandLong command_request_message{};	48✔
112	command_request_message.target_system_id = _system_impl.get_system_id();	48✔
113	command_request_message.target_component_id = item.target_component;	48✔
114
115	std::string command_name;	48✔
116
117	switch (item.message_id) {	48✔
118	case MAVLINK_MSG_ID_AUTOPILOT_VERSION:	×
119	command_request_message.command = MAV_CMD_REQUEST_AUTOPILOT_CAPABILITIES;	×
120	command_request_message.params.maybe_param1 = {1.f};	×
121	command_name = "REQUEST_AUTOPILOT_CAPABILITIES";	×
122	break;	×
123
124	case MAVLINK_MSG_ID_CAMERA_INFORMATION:	×
125	command_request_message.command = MAV_CMD_REQUEST_CAMERA_INFORMATION;	×
126	command_request_message.params.maybe_param1 = {1.0f};	×
127	command_name = "REQUEST_CAMERA_INFORMATION";	×
128	break;	×
129
130	case MAVLINK_MSG_ID_CAMERA_SETTINGS:	7✔
131	command_request_message.command = MAV_CMD_REQUEST_CAMERA_SETTINGS;	7✔
132	command_request_message.params.maybe_param1 = {1.0f};	7✔
133	command_name = "REQUEST_CAMERA_SETTINGS";	7✔
134
135	break;	7✔
136
137	case MAVLINK_MSG_ID_STORAGE_INFORMATION:	13✔
138	command_request_message.command = MAV_CMD_REQUEST_STORAGE_INFORMATION;	13✔
139	command_request_message.params.maybe_param1 = {	26✔
140	static_cast<float>(item.param2)}; // storage ID	13✔
141	command_request_message.params.maybe_param2 = {1.0f};	13✔
142	command_name = "REQUEST_STORAGE_INFORMATION";	13✔
143	break;	13✔
144
145	case MAVLINK_MSG_ID_CAMERA_CAPTURE_STATUS:	×
146	command_request_message.command = MAV_CMD_REQUEST_CAMERA_CAPTURE_STATUS;	×
147	command_request_message.params.maybe_param1 = {1.0f};	×
148	command_name = "REQUEST_CAMERA_CAPTURE_STATUS";	×
149	break;	×
150
151	case MAVLINK_MSG_ID_FLIGHT_INFORMATION:	×
152	command_request_message.command = MAV_CMD_REQUEST_FLIGHT_INFORMATION;	×
153	command_request_message.params.maybe_param1 = {1.0f};	×
154	command_name = "REQUEST_FLIGHT_INFORMATION";	×
155	break;	×
156
157	case MAVLINK_MSG_ID_VIDEO_STREAM_STATUS:	13✔
158	command_request_message.command = MAV_CMD_REQUEST_VIDEO_STREAM_STATUS;	13✔
159	command_request_message.params.maybe_param1 = {	26✔
160	static_cast<float>(item.param2)}; // stream ID	13✔
161	command_name = "REQUEST_VIDEO_STREAM_STATUS";	13✔
162	break;	13✔
163
164	case MAVLINK_MSG_ID_VIDEO_STREAM_INFORMATION:	11✔
165	command_request_message.command = MAV_CMD_REQUEST_VIDEO_STREAM_INFORMATION;	11✔
166	command_request_message.params.maybe_param1 = {	22✔
167	static_cast<float>(item.param2)}; // stream ID	11✔
168	command_name = "REQUEST_VIDEO_STREAM_INFORMATION";	11✔
169	break;	11✔
170
171	case MAVLINK_MSG_ID_CAMERA_IMAGE_CAPTURED:	×
172	command_request_message.command = MAV_CMD_REQUEST_CAMERA_IMAGE_CAPTURE;	×
173	command_request_message.params.maybe_param1 = {	×
174	static_cast<float>(item.param2)}; // sequence number	×
175	command_name = "REQUEST_CAMERA_IMAGE_CAPTURE";	×
176	break;	×
177
178	default:	4✔
179	// No alternative command for this message.
180	return false;	4✔
181	}
182
183	if (_debugging) {	44✔
184	LogDebug() << "Request message " << item.message_id << " again using " << command_name	×
185	<< " (retries: " << item.retries << ")";	×
186	}
187
188	_command_sender.queue_command_async(	44✔
189	command_request_message,
190	[this, message_id = item.message_id](MavlinkCommandSender::Result result, float) {	44✔
191	if (result != MavlinkCommandSender::Result::InProgress) {	44✔
192	handle_command_result(message_id, result);	44✔
193	}
194	},	44✔
195	1);
196
197	return true;	44✔
198	}	48✔
199
200	void MavlinkRequestMessage::handle_any_message(const mavlink_message_t& message)	90✔
201	{
202	std::unique_lock<std::mutex> lock(_mutex);	90✔
203
204	for (auto it = _work_items.begin(); it != _work_items.end(); ++it) {	120✔
205	// Check if we're waiting for this message.
206	// TODO: check if params are correct.
207	if (it->message_id != message.msgid && it->target_component == message.compid) {	109✔
208	continue;	30✔
209	}
210
211	_timeout_handler.remove(it->timeout_cookie);	79✔
212	// We have at least the message which is what we care about most, so we
213	// tell the user about it and call it a day. If we receive the result
214	// of the command later, we ignore it, and we fake the result to be successful
215	// anyway.
216	auto temp_callback = it->callback;	79✔
217	// We can now get rid of the entry now.
218	_work_items.erase(it);	79✔
219	// We have to clean up later outside this callback, otherwise we lock ourselves out.
220	_deferred_message_cleanup.push_back(message.msgid);	79✔
221	lock.unlock();	79✔
222
223	if (temp_callback) {	79✔
224	temp_callback(MavlinkCommandSender::Result::Success, message);	1✔
225	}
226	return;	79✔
227	}	79✔
228	}	90✔
229
230	void MavlinkRequestMessage::handle_command_result(	184✔
231	uint32_t message_id, MavlinkCommandSender::Result result)
232	{
233	std::unique_lock<std::mutex> lock(_mutex);	184✔
234
235	for (auto it = _work_items.begin(); it != _work_items.end(); ++it) {	307✔
236	// Check if we're waiting for this result
237	if (it->message_id != message_id) {	246✔
238	continue;	123✔
239	}
240
241	switch (result) {	123✔
242	case MavlinkCommandSender::Result::Success:	18✔
243	// This is promising, let's hope the message will actually arrive.
244	// We'll set a timeout in case we need to retry.
245	it->timeout_cookie = _timeout_handler.add(	18✔
246	[this, message_id, target_component = it->target_component]() {	18✔
UNCOV 247	handle_timeout(message_id, target_component);	×
UNCOV 248	},	×
249	1.0);
250	return;	123✔
251
252	case MavlinkCommandSender::Result::Busy:	105✔
253	// FALLTHROUGH
254	case MavlinkCommandSender::Result::Denied:
255	// FALLTHROUGH
256	case MavlinkCommandSender::Result::Unsupported:
257	// FALLTHROUGH
258	case MavlinkCommandSender::Result::Timeout:
259	// FALLTHROUGH
260	case MavlinkCommandSender::Result::TemporarilyRejected:
261	// It looks like we should try again
262	if (++it->retries > RETRIES) {	105✔
263	// We have already retried, let's give up.
264	auto temp_callback = it->callback;	19✔
265	_message_handler.unregister_one(it->message_id, this);	19✔
266	_work_items.erase(it);	19✔
267	lock.unlock();	19✔
268	if (temp_callback) {	19✔
269	temp_callback(MavlinkCommandSender::Result::Timeout, {});	×
270	}
271	} else {	19✔
272	send_request(*it);	86✔
273	}
274	return;	105✔
275
276	case MavlinkCommandSender::Result::NoSystem:	×
277	// FALLTHROUGH
278	case MavlinkCommandSender::Result::ConnectionError:
279	// FALLTHROUGH
280	case MavlinkCommandSender::Result::Failed:
281	// FALLTHROUGH
282	case MavlinkCommandSender::Result::Cancelled:
283	// FALLTHROUGH
284	case MavlinkCommandSender::Result::UnknownError: {
285	// It looks like this did not work, and we can report the error
286	// No need to try again.
287	auto temp_callback = it->callback;	×
288	_message_handler.unregister_one(it->message_id, this);	×
289	_work_items.erase(it);	×
290	lock.unlock();	×
291	if (temp_callback) {	×
292	temp_callback(result, {});	×
293	}
294	return;	×
295	}	×
296
297	case MavlinkCommandSender::Result::InProgress:	×
298	// Should not happen, as it is already filtered out.
299	return;	×
300	}
301	}
302	}	184✔
303
UNCOV 304	void MavlinkRequestMessage::handle_timeout(uint32_t message_id, uint8_t target_component)	×
305	{
UNCOV 306	std::unique_lock<std::mutex> lock(_mutex);	×
307
UNCOV 308	for (auto it = _work_items.begin(); it != _work_items.end(); ++it) {	×
309	// Check if we're waiting for this result
UNCOV 310	if (it->message_id != message_id \|\| it->target_component != target_component) {	×
311	continue;	×
312	}
313
UNCOV 314	if (++it->retries > RETRIES) {	×
315	// We have already retried, let's give up.
316	auto temp_callback = it->callback;	×
317	_message_handler.unregister_one(it->message_id, this);	×
318	_work_items.erase(it);	×
319	lock.unlock();	×
320	if (temp_callback) {	×
321	temp_callback(MavlinkCommandSender::Result::Timeout, {});	×
322	}
323	return;	×
324	}	×
325
UNCOV 326	send_request(*it);	×
327	}
UNCOV 328	}	×
329
330	} // namespace mavsdk

mavlink / MAVSDK / 18329400312

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous