commit bf6c92aa3a3505116bcf19c16a85fa7a0d4bb3a1
author Hidenori Takeshima <hidenori@a2.ctktv.ne.jp> Mon Apr 08 20:12:50 2002 +0000
committer Alexandre Julliard <julliard@winehq.org> Mon Apr 08 20:12:50 2002 +0000
tree 0e3067472cda712dc13754a32277848f3f98b0cc
parent 2223450ad2ebfdccd39044909dc36cd8ddc6ed5e

Fixed crashing in stopping parser.

dlls/quartz/parser.c

diff --git a/dlls/quartz/parser.c b/dlls/quartz/parser.c
index 1c23ed0..80a9d63 100644
--- a/dlls/quartz/parser.c
+++ b/dlls/quartz/parser.c
@@ -568,9 +568,11 @@
 	DWORD dwRes;
 	HANDLE hEvents[2];
 
-	if ( This->m_hEventInit != (HANDLE)NULL &&
-		 This->m_hThread != (HANDLE)NULL )
+	if ( This->m_bIsRunning )
+	{
+		TRACE("(%p) - already running\n",This);
 		return NOERROR;
+	}
 
 	This->m_hEventInit = CreateEventA(NULL,TRUE,FALSE,NULL);
 	if ( This->m_hEventInit == (HANDLE)NULL )
@@ -601,6 +603,8 @@
 	if ( dwRes != WAIT_OBJECT_0 )
 		return E_FAIL;
 
+	This->m_bIsRunning = TRUE;
+
 	return NOERROR;
 }
 
@@ -613,14 +617,16 @@
 	dwThreadId = This->m_dwThreadId;
 	if ( This->m_hEventInit != (HANDLE)NULL )
 	{
-		if ( dwThreadId != 0 ) /* FIXME? */
+		if ( dwThreadId != 0 )
 			PostThreadMessageA(
 				dwThreadId, QUARTZ_MSG_EXITTHREAD, 0, 0 );
-		if ( bAsync )
+		if ( bAsync &&
+			 WaitForSingleObject( This->m_hEventInit, 0 ) == WAIT_TIMEOUT )
 			return FALSE;
 
 		WaitForSingleObject( This->m_hEventInit, INFINITE );
 		CloseHandle( This->m_hEventInit );
+		This->m_bIsRunning = FALSE;
 		This->m_hEventInit = (HANDLE)NULL;
 	}
 
@@ -724,9 +730,14 @@
 	hr = CParserImpl_MemCommit(This);
 	if ( FAILED(hr) )
 		return hr;
+
+	if ( This->basefilter.fstate == State_Stopped )
+		CParserImpl_EndThread(This,FALSE);
+
 	hr = CParserImpl_BeginThread(This);
 	if ( FAILED(hr) )
 	{
+		FIXME("CParserImpl_BeginThread returns %08lx\n",hr);
 		CParserImpl_EndThread(This,FALSE);
 		return hr;
 	}
@@ -1100,6 +1111,7 @@
 	This->m_pAllocator = NULL;
 	ZeroMemory( &This->m_propAlloc, sizeof(ALLOCATOR_PROPERTIES) );
 	This->m_hEventInit = (HANDLE)NULL;
+	This->m_bIsRunning = FALSE;
 	This->m_hThread = (HANDLE)NULL;
 	This->m_dwThreadId = 0;
 	This->m_bSendEOS = FALSE;

dlls/quartz/parser.h

diff --git a/dlls/quartz/parser.h b/dlls/quartz/parser.h
index f72f4ac..6f1619f 100644
--- a/dlls/quartz/parser.h
+++ b/dlls/quartz/parser.h
@@ -48,6 +48,7 @@
 	IMemAllocator*	m_pAllocator;
 	ALLOCATOR_PROPERTIES	m_propAlloc;
 	HANDLE	m_hEventInit;
+	BOOL	m_bIsRunning;
 	DWORD	m_dwThreadId;
 	HANDLE	m_hThread;
 	BOOL	m_bSendEOS;