xiahb
/
Micro-XRCE-DDS-Client
mirror of https://github.com/eProsima/Micro-XRCE-DDS-Client.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update

This commit is contained in:
acuadros95 2021-12-09 12:52:36 +01:00
parent ec4f8bcf99
commit bfba38b76e
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/c/core/session/session.c
View File

@ -394,17 +394,17 @@ bool uxr_run_session_until_confirm_delivery(
int64_t start_timestamp = uxr_millis(); int64_t start_timestamp = uxr_millis();
int remaining_time = timeout_ms; int remaining_time = timeout_ms;
bool ret = false;
uxr_flash_output_streams(session); uxr_flash_output_streams(session);
do do
{ {
listen_message_reliably(session, remaining_time); listen_message_reliably(session, remaining_time);
ret = uxr_output_streams_confirmed(&session->streams);
remaining_time = timeout_ms - (int)(uxr_millis() - start_timestamp); remaining_time = timeout_ms - (int)(uxr_millis() - start_timestamp);
} }
while (!uxr_output_streams_confirmed(&session->streams) && (remaining_time > 0)); while (!ret && (remaining_time > 0));
bool ret = uxr_output_streams_confirmed(&session->streams);
UXR_UNLOCK_SESSION(session); UXR_UNLOCK_SESSION(session);
return ret; return ret;