mirrors/FreeRDP
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

libfreerdp-core: initialize queue objects earlier

Browse Source
This commit is contained in:
Marc-André Moreau 2013-07-17 15:27:55 -04:00
parent 67b972a021
commit a55fbc7b68
3 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
libfreerdp/core/input.c
View File

@ -495,6 +495,8 @@ rdpInput* input_new(rdpRdp* rdp)
if (input != NULL)
{
ZeroMemory(input, sizeof(rdpInput));
input->queue = MessageQueue_New();
}
return input;
@ -507,6 +509,8 @@ void input_free(rdpInput* input)
if (input->asynchronous)
input_message_proxy_free(input->proxy);
MessageQueue_Free(input->queue);
free(input);
}
}

4
libfreerdp/core/message.c
View File

@ -1741,7 +1741,6 @@ rdpUpdateProxy* update_message_proxy_new(rdpUpdate* update)
ZeroMemory(message, sizeof(rdpUpdateProxy));
message->update = update;
update->queue = MessageQueue_New();
update_message_register_interface(message, update);
}
@ -1752,7 +1751,6 @@ void update_message_proxy_free(rdpUpdateProxy* message)
{
if (message)
{
MessageQueue_Free(message->update->queue);
free(message);
}
}
@ -1940,7 +1938,6 @@ rdpInputProxy* input_message_proxy_new(rdpInput* input)
ZeroMemory(proxy, sizeof(rdpInputProxy));
proxy->input = input;
input->queue = MessageQueue_New();
input_message_proxy_register(proxy, input);
}
@ -1951,7 +1948,6 @@ void input_message_proxy_free(rdpInputProxy* proxy)
{
if (proxy)
{
MessageQueue_Free(proxy->input->queue);
free(proxy);
}
}

4
libfreerdp/core/update.c
View File

@ -1512,6 +1512,8 @@ rdpUpdate* update_new(rdpRdp* rdp)
update->SuppressOutput = update_send_suppress_output;
update->initialState = TRUE;
update->queue = MessageQueue_New();
}
return update;
@ -1545,6 +1547,8 @@ void update_free(rdpUpdate* update)
if (update->asynchronous)
update_message_proxy_free(update->proxy);
MessageQueue_Free(update->queue);
free(update);
}
}