167 lines
5.6 KiB
C++
167 lines
5.6 KiB
C++
/****************************************************************************/
|
|
/* Module: rcvapi.cpp */
|
|
/* */
|
|
/* Purpose: Receiver Thread initialization - in the Core */
|
|
/* */
|
|
/* Copyright(C) Microsoft Corporation 1999 */
|
|
/* */
|
|
/****************************************************************************/
|
|
|
|
#include <adcg.h>
|
|
extern "C" {
|
|
#define TRC_GROUP TRC_GROUP_CORE
|
|
#define TRC_FILE "rcvapi"
|
|
#include <atrcapi.h>
|
|
}
|
|
|
|
#include "rcv.h"
|
|
#include "autil.h"
|
|
#include "cd.h"
|
|
#include "op.h"
|
|
#include "cm.h"
|
|
#include "wui.h"
|
|
#include "uh.h"
|
|
#include "od.h"
|
|
#include "sp.h"
|
|
#include "clx.h"
|
|
|
|
DWORD g_dwRCVDbgStatus = 0;
|
|
#define RCV_DBG_INIT_CALLED 0x01
|
|
#define RCV_DBG_INIT_DONE 0x02
|
|
#define RCV_DBG_TERM_CALLED 0x04
|
|
#define RCV_DBG_TERM_ACTUAL_DONE1 0x08
|
|
#define RCV_DBG_TERM_ACTUAL_DONE2 0x10
|
|
#define RCV_DBG_TERM_RETURN 0x20
|
|
|
|
CRCV::CRCV(CObjs* objs)
|
|
{
|
|
_pClientObjects = objs;
|
|
_fRCVInitComplete = FALSE;
|
|
}
|
|
|
|
|
|
CRCV::~CRCV()
|
|
{
|
|
}
|
|
|
|
|
|
|
|
/****************************************************************************/
|
|
/* Name: RCV_Init */
|
|
/* */
|
|
/* Purpose: Initialize the Receiver Thread */
|
|
/* */
|
|
/* Returns: None */
|
|
/* */
|
|
/* Params: None */
|
|
/* */
|
|
/****************************************************************************/
|
|
DCVOID DCAPI CRCV::RCV_Init(DCVOID)
|
|
{
|
|
DC_BEGIN_FN("RCV_Init");
|
|
|
|
g_dwRCVDbgStatus |= RCV_DBG_INIT_CALLED;
|
|
|
|
TRC_ASSERT(_pClientObjects, (TB,_T("_pClientObjects is NULL")));
|
|
_pClientObjects->AddObjReference(RCV_OBJECT_FLAG);
|
|
|
|
_pCm = _pClientObjects->_pCMObject;
|
|
_pUh = _pClientObjects->_pUHObject;
|
|
_pOd = _pClientObjects->_pODObject;
|
|
_pOp = _pClientObjects->_pOPObject;
|
|
_pSp = _pClientObjects->_pSPObject;
|
|
_pClx = _pClientObjects->_pCLXObject;
|
|
_pUt = _pClientObjects->_pUtObject;
|
|
_pCd = _pClientObjects->_pCdObject;
|
|
_pUi = _pClientObjects->_pUiObject;
|
|
|
|
|
|
// Initialize subcomponents of the Core in the Receiver Thread.
|
|
_pCm->CM_Init();
|
|
_pUh->UH_Init();
|
|
_pOd->OD_Init();
|
|
_pOp->OP_Init();
|
|
_pSp->SP_Init();
|
|
|
|
// Initialize Client Extension DLL
|
|
TRC_DBG((TB, _T("RCV Initialising Client Extension DLL")));
|
|
_pClx->CLX_Init(_pUi->UI_GetUIMainWindow(), _pUi->_UI.CLXCmdLine);
|
|
|
|
// Allow UI to call Core functions
|
|
_pUi->UI_SetCoreInitialized();
|
|
|
|
//
|
|
// This needs to be a direct call because the CD won't be able
|
|
// to post to the UI layer because the ActiveX control is blocked
|
|
// waiting on the core init event (blocking the main wnd loop on thread 0).
|
|
//
|
|
_pUi->UI_NotifyAxLayerCoreInit();
|
|
|
|
// Tell the UI that the core has initialized
|
|
_pCd->CD_DecoupleSimpleNotification(CD_UI_COMPONENT,
|
|
_pUi,
|
|
CD_NOTIFICATION_FUNC(CUI,UI_OnCoreInitialized),
|
|
(ULONG_PTR) 0);
|
|
|
|
_fRCVInitComplete = TRUE;
|
|
|
|
g_dwRCVDbgStatus |= RCV_DBG_INIT_DONE;
|
|
|
|
DC_END_FN();
|
|
|
|
return;
|
|
|
|
} /* RCV_Init */
|
|
|
|
/****************************************************************************/
|
|
/* Name: RCV_Term */
|
|
/* */
|
|
/* Purpose: Terminate the Receiver Thread */
|
|
/* */
|
|
/* Returns: None */
|
|
/* */
|
|
/* Params: None */
|
|
/* */
|
|
/****************************************************************************/
|
|
DCVOID DCAPI CRCV::RCV_Term(DCVOID)
|
|
{
|
|
DC_BEGIN_FN("RCV_Term");
|
|
|
|
g_dwRCVDbgStatus |= RCV_DBG_TERM_CALLED;
|
|
|
|
if(_fRCVInitComplete)
|
|
{
|
|
g_dwRCVDbgStatus |= RCV_DBG_TERM_ACTUAL_DONE1;
|
|
// Terminate subcomponents of the Core in the Receiver Thread.
|
|
_pSp->SP_Term();
|
|
_pOp->OP_Term();
|
|
_pOd->OD_Term();
|
|
_pUh->UH_Term();
|
|
_pCm->CM_Term();
|
|
|
|
//
|
|
// Terminate utilities.
|
|
//
|
|
_pUt->UT_Term();
|
|
|
|
// Terminate the Client Extension DLL
|
|
// CLX_Term used to be called before CO_Term in UI_Term. CLX_Term
|
|
// needs to be called after the SND and RCV threads are terminated.
|
|
// So, we move CLX_Term after UI_Term in the recv thread
|
|
//
|
|
_pClx->CLX_Term();
|
|
|
|
_pClientObjects->ReleaseObjReference(RCV_OBJECT_FLAG);
|
|
g_dwRCVDbgStatus |= RCV_DBG_TERM_ACTUAL_DONE2;
|
|
}
|
|
|
|
g_dwRCVDbgStatus |= RCV_DBG_TERM_RETURN;
|
|
|
|
DC_END_FN();
|
|
|
|
return;
|
|
|
|
} /* RCV_Term */
|
|
|
|
|