message.c

深圳市微逻辑电子有限公司 巨果&#8226 Kingmos&reg 系统核心

/******************************************************
Copyright(c) 版权所有，1998-2005微逻辑。保留所有权利。
******************************************************/


/*****************************************************
文件说明：消息分发处理
版本号：3.0.0
开发时期：1999
作者：李林
修改记录：
	2004-12-08, _CallThreadWindowProc 增加对 窗口的判断
    2003.07.07: LN in DispatchMessage, 去掉对PowerOff的处理
    2003.05.30: LN 增加 WINS_INUSERPROC 的 处理
******************************************************/

#include <eframe.h>
#include <estring.h>
#include <ekeybrd.h>
#include <eassert.h>
#include <eapisrv.h>
#include <epwin.h>
#include <bheap.h>
#include <gwmeobj.h>

#include <winsrv.h>
#include <gdisrv.h>
#include <eobjcall.h>

static BOOL CALLBACK _PostAllTopLevel( HWND, LPARAM );
static BOOL TranslatePosMsg( LPMSG lpMsg );

static HWND GetChildWindow( HWND hWNd, POINT pt );
static BOOL HandlePosEvent( LPMSG lpMsg, BOOL fEnable );
LRESULT _CallWindowProc( _LPWINDATA lpws, WNDPROC lpCallProc, UINT message, WPARAM wParam, LPARAM lParam );

///////////////////////////////////////////////////////////
// private proc define end

typedef struct __THREADMSG
{
	MSG msg;
	LRESULT lResult;
	DWORD dwThreadIDOfSender;
	UINT uFlag;   // 0 , usable, 1 sended, 2 handled by the reveier
}THREADMSG, FAR * LPTHREADMSG;

// **************************************************
// 声明：
// 参数：
// 	无
// 返回值：
//	假入成功，返回TRUE；否则，返回FALSE
// 功能描述：
//	
// 引用: 
//	
// ************************************************

static LPTHREADMSG _AllocThreadMsgData( DWORD * lpID )
{
	return (LPTHREADMSG)( *lpID = (DWORD)BlockHeap_Alloc( hgwmeBlockHeap, 0, sizeof(THREADMSG) ) );
}

// **************************************************
// 声明：
// 参数：
// 	无
// 返回值：
//	假入成功，返回TRUE；否则，返回FALSE
// 功能描述：
//	
// 引用: 
//	
// ************************************************

static LPTHREADMSG _GetThreadMsgPtr( DWORD dwID )
{
	return (LPTHREADMSG)dwID;
}

// **************************************************
// 声明：
// 参数：
// 	无
// 返回值：
//	假入成功，返回TRUE；否则，返回FALSE
// 功能描述：
//	
// 引用: 
//	
// ************************************************

static void _ReleaseThreadMsgPtr( LPTHREADMSG lptm )
{
	BlockHeap_Free( hgwmeBlockHeap, 0, lptm, sizeof(THREADMSG) );
}



// **************************************************
// 声明：
// 参数：
// 	无
// 返回值：
//	假入成功，返回TRUE；否则，返回FALSE
// 功能描述：
//	
// 引用: 
//	
// ************************************************

LRESULT WINAPI WinMsg_Dispatch( const MSG * lpMsg )
{
    ASSERT( lpMsg->hwnd );
    if( lpMsg->hwnd )
	{
	    _LPWINDATA lpws = _GetHWNDPtr( lpMsg->hwnd );
		if( lpws )
		{
            //MapPtrParam( message, &wParam, &lParam );
			if( lpMsg->message == WM_SYSTIMER && lpMsg->wParam == IDCARET )
			{
				extern void CALLBACK AutoCaretBlink( 
					HWND hwnd, 
					UINT uMsg,     // WM_SYSTIMER message
					UINT idEvent,  // timer identifier
					DWORD dwTime  );
				AutoCaretBlink( lpMsg->hwnd, WM_SYSTIMER, IDCARET, 0 );
				return 0;
			}
			else
				return _CallWindowProc( lpws, NULL, lpMsg->message, lpMsg->wParam, lpMsg->lParam );
		}
	}
    return 0;
}

// **************************************************
// 声明：
// 参数：
// 	无
// 返回值：
//	假入成功，返回TRUE；否则，返回FALSE
// 功能描述：
//	
// 引用: 
//	
// ************************************************

BOOL WINAPI WinMsg_Get( MSG FAR* lpMsg, HWND hWnd, UINT wMsgFiltenMin, UINT wMsgFiltenMax )
{
    BOOL retv = TRUE;

    while( 1 )
    {
        while( PeekMessage( lpMsg, hWnd, wMsgFiltenMin, wMsgFiltenMax, PM_REMOVE ) == FALSE )
        { 
            WinMsg_Wait();
        }
        if( lpMsg->message == WM_QUIT )
        {
            retv = FALSE;
        }
        break;
    }
    return retv;
}

// **************************************************
// 声明：
// 参数：
// 	无
// 返回值：
//	假入成功，返回TRUE；否则，返回FALSE
// 功能描述：
//	
// 引用: 
//	
// ************************************************

BOOL WINAPI WinMsg_Peek( MSG FAR* lpMsgUser, HWND hWnd, UINT wMsgFiltenMin, UINT wMsgFiltenMax, UINT wRemoveMsg )
{
    POINT pt;
    int retv;
	_MSGDATA msgData;
	LPMSG lpMsg = &msgData.msg;

	retv = FALSE;

_REPEAT_PEEK:    

    memset( &msgData, 0, sizeof( msgData ) );
    if( CheckThreadQueue( &msgData, hWnd, wMsgFiltenMin, wMsgFiltenMax, wRemoveMsg, 1 ) )
    {
        if( msgData.eventType & QS_KEY )
		{
			ASSERT( lpMsg->message >= WM_KEYFIRST && lpMsg->message <= WM_KEYLAST );
            lpMsg->hwnd = GetFocus();
		}
        else if( msgData.eventType & QS_MOUSE )
        {
			ASSERT( lpMsg->message >= WM_MOUSEFIRST && lpMsg->message <= WM_MOUSELAST );
			pt = lpMsg->pt;
            if( GetCapture() == NULL )
            {
                int flag;
                if( ( flag = IsWindowEnabled( lpMsg->hwnd ) ) )
                {
                    HWND hs = lpMsg->hwnd;
                    lpMsg->hwnd = GetChildWindow( lpMsg->hwnd, pt );
                    if( lpMsg->hwnd == 0 )
                    {
                        if( wRemoveMsg == PM_NOREMOVE )
                            CheckThreadQueue( &msgData, hWnd, wMsgFiltenMin, wMsgFiltenMax, PM_REMOVE, 1 );
                        goto _REPEAT_PEEK;
                    }
                }
                if( HandlePosEvent( lpMsg, flag ) == FALSE )
                {  // the message has been handle myself, continue to peek next message
                    if( wRemoveMsg == PM_NOREMOVE )
                        CheckThreadQueue( &msgData, hWnd, wMsgFiltenMin, wMsgFiltenMax, PM_REMOVE, 1 );
                    goto _REPEAT_PEEK;
                }       
            }
            else  //
            {
				
				lpMsg->hwnd = GetCapture();
				// 2003-09-30-ADD-begin
				if( lpMsg->message == WM_LBUTTONDOWN || 
					lpMsg->message == WM_RBUTTONDOWN )
				{
					if( !IsForegroundThread()  )
					{
						Win_SetForeground( lpMsg->hwnd );
					}
				}
				// 2003-09-30-ADD-end
                
				Win_ScreenToClient( lpMsg->hwnd, &pt );
                lpMsg->lParam = MAKELONG( pt.x, pt.y );
            }
        }
		else if( lpMsg->message == WM_SYSTHREADMSG )
		{
			if( lpMsg->wParam == STM_SEND )
			{	//由其它线程发送到本线程
				LPTHREADMSG lptm = _GetThreadMsgPtr( lpMsg->lParam );
				
				if( lptm )
				{
					extern VOID WINAPI _WinSys_SetMessageEvent( DWORD dwThreadId );
				    lptm->lResult = WinMsg_Send( lptm->msg.hwnd, lptm->msg.message, lptm->msg.wParam, lptm->msg.lParam );
				    lptm->uFlag = 2;
					//通知发送线程
					//_WinSys_PostThreadMessage( lptm->dwThreadIDOfSender, WM_SYSTHREADMSG, STM_REPLY, lpMsg->lParam );
					//2005-03-15, 重新激活发送线程
					//不能用消息，因为，发送线程不会清除其消息队列
					_WinSys_SetMessageEvent(lptm->dwThreadIDOfSender);
					//
				}
			}
            if( wRemoveMsg == PM_NOREMOVE )
                 CheckThreadQueue( &msgData, hWnd, wMsgFiltenMin, wMsgFiltenMax, PM_REMOVE, 1 );

			goto _REPEAT_PEEK;
		}
		*lpMsgUser = *lpMsg;
        retv = TRUE;
    }
//PK_RET:
    return retv;
}

// **************************************************
// 声明：
// 参数：
// 	无
// 返回值：
//	假入成功，返回TRUE；否则，返回FALSE
// 功能描述：
//	
// 引用: 
//	
// ************************************************

BOOL _Msg_PutSoftKeybrdEvent( BYTE bVirtualKey, WORD wCode, DWORD dwState )
{
    HWND hWnd;
    hWnd = GetFocus();
    if( hWnd )
    {
        if( bVirtualKey )
        {   // it is virtual key
            // put key down
			keybd_event( bVirtualKey, 0, 0,  0 );
        }
        if( wCode )
        {// put char message
			keybd_event( bVirtualKey, 0, KEYEVENTF_CHAR,  0 );			
        }
        if( bVirtualKey )
        {   // it is virtual key
            // put key down
			keybd_event( bVirtualKey, 0, KEYEVENTF_KEYUP,  0 );
        }
        return TRUE;
    }
    return FALSE;

}

// **************************************************
// 声明：
// 参数：
// 	无
// 返回值：
//	假入成功，返回TRUE；否则，返回FALSE
// 功能描述：
//	
// 引用: 
//	
// ************************************************

BOOL WINAPI WinMsg_Post(HWND hWnd, UINT message, WPARAM wParam, LPARAM lParam )
{
    MSG msg;

    if( message == WM_PAINT || message == WM_NCPAINT )
        return FALSE;
    msg.message = message;
    msg.wParam = wParam;
    msg.lParam = lParam;
    if( hWnd == HWND_BROADCAST )
    {   // post message to all top level

		MSG msg;

		msg.message = message;
		msg.wParam = wParam;
		msg.lParam = lParam;		
		
		DoEnumTopLevelWindow( _PostAllTopLevel, (LPARAM)&msg, NULL );
		return TRUE;
    }
    else
    {
        AddMsgToThreadQueue( hWnd, message, wParam, lParam, QS_POSTMESSAGE );
        return TRUE;
    }
}

// **************************************************
// 声明：
// 参数：
// 	无
// 返回值：
//	假入成功，返回TRUE；否则，返回FALSE
// 功能描述：
//	
// 引用: 
//	
// ************************************************

static BOOL _CallThreadWindowProc( HWND hWnd, UINT message, WPARAM wParam, LPARAM lParam, UINT uiTimeout, UINT fuFlags, LPDWORD lpdwRetv )
{
	DWORD dwMsgID;
    UINT uiTickCount;
	MSG msg;
	LPTHREADMSG lptm;
	BOOL lret = FALSE;

	lptm = _AllocThreadMsgData( &dwMsgID );
	if( lptm  )
	{
		UINT uErrorState = 0;  // 没有错误
		DWORD dwWait;
		lptm->msg.hwnd = hWnd;
		lptm->msg.message = message;//WM_SYSTHREADMSG;
		lptm->msg.wParam = wParam;//dwMsgID;
		lptm->msg.lParam = lParam;
		lptm->dwThreadIDOfSender = GetCurrentThreadId();
		lptm->uFlag = 1;
		lptm->lResult = 0;

		AddMsgToThreadQueue( hWnd, WM_SYSTHREADMSG, STM_SEND, dwMsgID, QS_SENDMESSAGE );

		if( uiTimeout != INFINITE )
		    uiTickCount = GetTickCount();
        while( lptm->uFlag != 2 )
		{	//等待消息
			dwWait = _WinSys_WaitMessage( uiTimeout );
			
			if( !IsWindow(hWnd) )
			{
				uErrorState = -1; //error
				break;
			}
			//
			if( dwWait == WAIT_OBJECT_0 )
			{   //有消息
				if( lptm->uFlag == 2 )
				{   // 处理完，数据有效
					break;
				}
				else
				{   // 别的消息
					if( fuFlags == SMTO_NORMAL )
					{   // 处理所有消息
						while( PeekMessage( &msg, NULL, 0, 0, PM_REMOVE ) )
						{
							TranslateMessage( &msg );
							DispatchMessage( &msg );
							if( lptm->uFlag == 2 )
								break;
						}
					}
				}
				if( lptm->uFlag != 2 )
				{
					if( uiTimeout != INFINITE )
					{   // 更新 timeout 值
						DWORD uiCurTick = GetTickCount();
						DWORD dwDiff;
						if( uiCurTick >= uiTickCount )
							dwDiff = uiCurTick - uiTickCount;
						else
							dwDiff = uiCurTick + (~uiTickCount);  //上溢
						if( dwDiff >= uiTimeout )
						{	// timeout
							uErrorState = 1;
							break;
						}
						//得到新的 timeout
						uiTimeout -= dwDiff;
					}
				}
			}
			else if( dwWait == WAIT_TIMEOUT )
			{
				uErrorState = 1;
				break;  // timeout
			}
			else
			{
				uErrorState = -1;
				break;  // 出错
			}
		}		

		if( uErrorState == 0 )
			lret = TRUE;	//成功
		else if( uErrorState == 1 )
		{	//timeout
			SetLastError( 0 );
		}

		if( lpdwRetv )
		{
			if( uErrorState == 0 )
				*lpdwRetv = lptm->lResult; //成功
			else
				*lpdwRetv  = 0;	//出错
		}
		_ReleaseThreadMsgPtr( lptm );

	}
	return lret;
}

// **************************************************
// 声明：
// 参数：
// 	无
// 返回值：
//	假入成功，返回TRUE；否则，返回FALSE
// 功能描述：
//	
// 引用: 
//	
// ************************************************

LRESULT _CallWindowProc( _LPWINDATA lpws, WNDPROC lpCallProc, UINT message, WPARAM wParam, LPARAM lParam )
{
	LRESULT lr; 
	BOOL bCallBack = FALSE;
	HANDLE hProcess;

#ifdef __DEBUG
#endif
	if( lpws->lpClass->hOwnerProcess != hgwmeProcess )
	{   //  类是被某进程注册