morgan/FreeRDP
1
0
Fork 0
mirror of https://github.com/morgan9e/FreeRDP synced 2026-04-15 00:44:19 +09:00
Code Issues Packages Projects Releases Wiki Activity

[core,client] flush pending channel messages

Browse Source 
on disconnect flush all pending messages to avoid sending on reconnect.
This commit is contained in:
akallabeth
2024-08-28 14:13:28 +02:00
parent de5b7c8e42
commit 4ccfbc96ac
1 changed files with 12 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
libfreerdp/core/client.c
View File

@@ -656,16 +656,17 @@ fail:
/**
* called only from main thread
*/
static int freerdp_channels_process_sync(rdpChannels* channels, freerdp* instance)
static BOOL freerdp_channels_process_sync(rdpChannels* channels, freerdp* instance)
{
int status = TRUE;
BOOL status = TRUE;
wMessage message = { 0 };
WINPR_ASSERT(channels);
while (MessageQueue_Peek(channels->queue, &message, TRUE))
{
freerdp_channels_process_message(instance, &message);
if (!freerdp_channels_process_message(instance, &message))
status = FALSE;
}
return status;
@@ -730,14 +731,16 @@ int freerdp_channels_process_pending_messages(freerdp* instance)
*/
BOOL freerdp_channels_check_fds(rdpChannels* channels, freerdp* instance)
{
BOOL status = TRUE;
WINPR_ASSERT(channels);
if (WaitForSingleObject(MessageQueue_Event(channels->queue), 0) == WAIT_OBJECT_0)
{
freerdp_channels_process_sync(channels, instance);
if (!freerdp_channels_process_sync(channels, instance))
status = FALSE;
}
return TRUE;
return status;
}
UINT freerdp_channels_disconnect(rdpChannels* channels, freerdp* instance)
@@ -751,7 +754,7 @@ UINT freerdp_channels_disconnect(rdpChannels* channels, freerdp* instance)
if (!channels->connected)
return 0;
freerdp_channels_check_fds(channels, instance);
(void)freerdp_channels_check_fds(channels, instance);
/* tell all libraries we are shutting down */
for (int index = 0; index < channels->clientDataCount; index++)
@@ -782,6 +785,9 @@ UINT freerdp_channels_disconnect(rdpChannels* channels, freerdp* instance)
}
channels->connected = FALSE;
/* Flush pending messages */
(void)freerdp_channels_check_fds(channels, instance);
return error;
}