Re: CoMarshalInterThreadInterfaceInStream FinalRelease not called
Your thread seems to be wating on an event that is triggered
from within your FinalRelease. Since the thread itself holds
a reference to your object, this would never execute. You need
an external party to tell your thread to stop. This in turn will
cause it to release its reference on your obect and FinalRelease
will execute. Since this will happen on the thread itself, you
shouldn't wait for the thread to finish (clear deadlock). However,
once the object is destroyed, your thread may not touch any
object state (the engine pointer) since that is no longer valid
(your code is ok in that regard right now). This is quite tangled
IMHO. I suggest you decouple your thread from COM and
have it use an internal C++ class pointer only and no self-
reference count bump. Then it'll be your client releasing an
interface pointer to the object that causes your destruction
sequence, not your internal event.
--
=====================================
Alexander Nickolov
Microsoft MVP [VC], MCSD
email: agnickolov@mvps.org
MVP VC FAQ: http://vcfaq.mvps.org
=====================================
"Phil Riera" <Phil Riera@discussions.microsoft.com> wrote in message
news:2AC1DA39-CB45-4D9F-B825-2B3291A98727@microsoft.com...
I've created an object that marshals an interface with
CoMarshalInterThreadInterfaceInStream/CoGetInterfaceAndReleaseStream. The
interface pointer is working as intended but my FinalRelease is not being
called. Here is a sample of what I am doing.
unsigned __stdcall CEngineObj::AnalysisThreadProc( void* args )
{
CoInitializeEx(NULL, COINIT_MULTITHREADED);
CEngineObj* engine = static_cast<CEngineObj*>(args);
DWORD dwResult;
HRESULT hr = S_OK;
// unmarshal interface pointer
IInternalEngineCallback* pCallback;
hr = CoGetInterfaceAndReleaseStream (*(engine->m_ppStream),
IID_IInternalEngineCallback,
(void**) &pCallback);
delete engine->m_ppStream;
engine->m_ppStream = NULL;
while(true)
{
dwResult = WaitForMultipleObjects( engine->NUM_EVENTS, engine->m_hEvents,
FALSE, INFINITE );
switch( dwResult )
{
case WAIT_OBJECT_0 + EVTEXIT:
pCallback->Release();
_endthreadex(0);
return 0;
}
}
CoUninitialize();
return 0;
}
HRESULT CEngineObj::FinalConstruct()
{
HRESULT hr = S_OK;
// Marshal interface pointer
m_ppStream = new IStream*;
hr = ::CoMarshalInterThreadInterfaceInStream(IID_IInternalEngineCallback,
reinterpret_cast<IInternalEngineCallback*>(this), m_ppStream);
if (FAILED (hr)) {
delete m_ppStream;
m_ppStream = NULL;
return hr;
}
// Create the thread
unsigned threadID;
m_hAnalysisThread = (HANDLE)_beginthreadex( NULL, 0, &AnalysisThreadProc,
this, 0, &threadID );
if( 0 == m_hAnalysisThread )
return E_FAIL;
return hr;
}
void CEngineObj::FinalRelease()
{
if( m_hAnalysisThread && m_hEvents[EVTEXIT] )
{
SetEvent(m_hEvents[EVTEXIT]);
WaitForSingleObject( m_hAnalysisThread, INFINITE );
CloseHandle(m_hAnalysisThread);
}
}
Any help would be greatly appreciated.