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

channels/rdpsnd: emulate timing of old queue

Browse Source
This commit is contained in:
Marc-André Moreau 2013-02-20 12:11:19 -05:00
parent 5e8d35c4ac
commit fbdcd03a42
1 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
channels/rdpsnd/client/rdpsnd_main.c
View File

@ -82,12 +82,11 @@ static void rdpsnd_process_interval(rdpSvcPlugin* plugin)
{
STREAM* data;
wMessage message;
UINT16 wTimeDiff;
UINT16 wTimeStamp;
UINT16 wCurrentTime;
rdpsndPlugin* rdpsnd = (rdpsndPlugin*) plugin;
while (MessageQueue_Peek(rdpsnd->OutQueue, &message, TRUE))
while (MessageQueue_Peek(rdpsnd->OutQueue, &message, FALSE))
{
if (message.id == WMQ_QUIT)
break;
@ -95,16 +94,16 @@ static void rdpsnd_process_interval(rdpSvcPlugin* plugin)
wTimeStamp = (UINT16) (size_t) message.lParam;
wCurrentTime = (UINT16) GetTickCount();
if (wTimeStamp - wCurrentTime > 0)
if (wCurrentTime <= wTimeStamp)
break;
if (MessageQueue_Peek(rdpsnd->OutQueue, &message, TRUE))
{
wTimeDiff = wTimeStamp - wCurrentTime;
//Sleep(wTimeDiff / 16);
data = (STREAM*) message.wParam;
svc_plugin_send(plugin, data);
DEBUG_SVC("processed output data");
}
data = (STREAM*) message.wParam;
svc_plugin_send(plugin, data);
DEBUG_SVC("processed output data");
}
if (rdpsnd->is_open && (rdpsnd->close_timestamp > 0))
@ -121,7 +120,7 @@ static void rdpsnd_process_interval(rdpSvcPlugin* plugin)
}
}
if (!rdpsnd->is_open)
if ((MessageQueue_Size(rdpsnd->OutQueue) == 0) && !rdpsnd->is_open)
rdpsnd->plugin.interval_ms = 0;
}