ReceiveTempSMS
/
Sweden-Number
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

quartz: Release outstanding samples in PullPin::PauseProcessing.

This commit is contained in:
Erich Hoover 2011-05-14 11:15:01 -06:00 committed by Alexandre Julliard
parent 819643ada8
commit 484c952cf2
1 changed files with 31 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
dlls/quartz/pin.c
View File

@ -473,10 +473,22 @@ static void PullPin_Thread_Process(PullPin *This)
}
} while (This->rtCurrent < This->rtStop && hr == S_OK && !This->stop_playback);
/* Sample was rejected, and we are asked to terminate */
if (pSample)
/*
* Sample was rejected, and we are asked to terminate. When there is more than one buffer
* it is possible for a filter to have several queued samples, making it necessary to
* release all of these pending samples.
*/
if (This->stop_playback || FAILED(hr))
{
DWORD_PTR dwUser;
do
{
if (pSample)
IMediaSample_Release(pSample);
pSample = NULL;
IAsyncReader_WaitForNext(This->pReader, 0, &pSample, &dwUser);
} while(pSample);
}
/* Can't reset state to Sleepy here because that might race, instead PauseProcessing will do that for us
@ -625,11 +637,27 @@ HRESULT PullPin_PauseProcessing(PullPin * This)
assert(This->state == Req_Run|| This->state == Req_Sleepy);
assert(WaitForSingleObject(This->thread_sleepy, 0) == WAIT_TIMEOUT);
This->state = Req_Pause;
This->stop_playback = 1;
ResetEvent(This->hEventStateChanged);
SetEvent(This->thread_sleepy);
/* Release any outstanding samples */
if (This->pReader)
{
IMediaSample *pSample;
DWORD_PTR dwUser;
do
{
pSample = NULL;
IAsyncReader_WaitForNext(This->pReader, 0, &pSample, &dwUser);
if (pSample)
IMediaSample_Release(pSample);
} while(pSample);
}
LeaveCriticalSection(This->pin.pCritSec);
}