Intravision/reactos
1
0
Fork 0
mirror of https://github.com/reactos/reactos.git synced 2025-02-25 09:50:02 +00:00
Code Issues Projects Releases Packages Wiki Activity

- Move PostThreadMessage internals into its own function.

Browse source 
svn path=/trunk/; revision=41778
This commit is contained in:
James Tabor 2009-07-05 07:47:41 +00:00
parent 4419fee70a
commit 0d5243017d
1 changed files with 60 additions and 37 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

97
reactos/subsystems/win32/win32k/ntuser/message.c
View file

@ -1307,6 +1307,55 @@ CopyMsgToUserMem(MSG *UserModeMsg, MSG *KernelModeMsg)
return STATUS_SUCCESS; return STATUS_SUCCESS;
} }
BOOL FASTCALL
UserPostThreadMessage( DWORD idThread,
UINT Msg,
WPARAM wParam,
LPARAM lParam)
{
MSG Message;
PETHREAD peThread;
PTHREADINFO pThread;
LARGE_INTEGER LargeTickCount;
NTSTATUS Status;
DPRINT1("UserPostThreadMessage wParam 0x%x lParam 0x%x\n", wParam,lParam);
if (FindMsgMemory(Msg) != 0)
{
SetLastWin32Error(ERROR_MESSAGE_SYNC_ONLY );
return FALSE;
}
Status = PsLookupThreadByThreadId((HANDLE)idThread,&peThread);
if( Status == STATUS_SUCCESS )
{
pThread = (PTHREADINFO)peThread->Tcb.Win32Thread;
if( !pThread || !pThread->MessageQueue )
{
ObDereferenceObject( peThread );
return FALSE;
}
Message.hwnd = NULL;
Message.message = Msg;
Message.wParam = wParam;
Message.lParam = lParam;
IntGetCursorLocation(pThread->Desktop->WindowStation, &Message.pt);
KeQueryTickCount(&LargeTickCount);
pThread->timeLast = Message.time = MsqCalculateMessageTime(&LargeTickCount);
MsqPostMessage(pThread->MessageQueue, &Message, FALSE, QS_POSTMESSAGE);
ObDereferenceObject( peThread );
return TRUE;
}
else
{
SetLastNtError( Status );
}
return FALSE;
}
BOOL FASTCALL BOOL FASTCALL
UserPostMessage(HWND Wnd, UserPostMessage(HWND Wnd,
UINT Msg, UINT Msg,
@ -1323,6 +1372,12 @@ UserPostMessage(HWND Wnd,
return FALSE; return FALSE;
} }
if (!Wnd)
return UserPostThreadMessage( PtrToInt(PsGetCurrentThreadId()),
Msg,
wParam,
lParam);
pti = PsGetCurrentThreadWin32Thread(); pti = PsGetCurrentThreadWin32Thread();
if (Wnd == HWND_BROADCAST) if (Wnd == HWND_BROADCAST)
{ {
@ -1372,7 +1427,6 @@ UserPostMessage(HWND Wnd,
MsqPostMessage(Window->MessageQueue, &Message, FALSE, QS_POSTMESSAGE); MsqPostMessage(Window->MessageQueue, &Message, FALSE, QS_POSTMESSAGE);
} }
} }
return TRUE; return TRUE;
} }
@ -1388,7 +1442,7 @@ NtUserPostMessage(HWND hWnd,
DPRINT("Enter NtUserPostMessage\n"); DPRINT("Enter NtUserPostMessage\n");
UserEnterExclusive(); UserEnterExclusive();
RETURN(UserPostMessage(hWnd, Msg, wParam, lParam)); RETURN( UserPostMessage(hWnd, Msg, wParam, lParam));
CLEANUP: CLEANUP:
DPRINT("Leave NtUserPostMessage, ret=%i\n",_ret_); DPRINT("Leave NtUserPostMessage, ret=%i\n",_ret_);
@ -1404,46 +1458,15 @@ NtUserPostThreadMessage(DWORD idThread,
WPARAM wParam, WPARAM wParam,
LPARAM lParam) LPARAM lParam)
{ {
MSG Message;
PETHREAD peThread;
PTHREADINFO pThread;
NTSTATUS Status;
DECLARE_RETURN(BOOL); DECLARE_RETURN(BOOL);
DPRINT("Enter NtUserPostThreadMessage\n"); DPRINT("Enter NtUserPostThreadMessage\n");
if (FindMsgMemory(Msg) != 0)
{
SetLastWin32Error(ERROR_MESSAGE_SYNC_ONLY );
return FALSE;
}
UserEnterExclusive(); UserEnterExclusive();
Status = PsLookupThreadByThreadId((HANDLE)idThread,&peThread); RETURN( UserPostThreadMessage( idThread,
Msg,
if( Status == STATUS_SUCCESS ) wParam,
{ lParam));
pThread = (PTHREADINFO)peThread->Tcb.Win32Thread;
if( !pThread || !pThread->MessageQueue )
{
ObDereferenceObject( peThread );
RETURN( FALSE);
}
Message.hwnd = NULL;
Message.message = Msg;
Message.wParam = wParam;
Message.lParam = lParam;
MsqPostMessage(pThread->MessageQueue, &Message, FALSE, QS_POSTMESSAGE);
ObDereferenceObject( peThread );
RETURN( TRUE);
}
else
{
SetLastNtError( Status );
RETURN( FALSE);
}
CLEANUP: CLEANUP:
DPRINT("Leave NtUserPostThreadMessage, ret=%i\n",_ret_); DPRINT("Leave NtUserPostThreadMessage, ret=%i\n",_ret_);