mirror of
https://github.com/reactos/reactos.git
synced 2024-07-01 02:10:07 +00:00
98 lines
2.4 KiB
C
98 lines
2.4 KiB
C
/**
|
|
* Test case for PostThreadMessage
|
|
* (C) 2003 ReactOS
|
|
* License: LGPL
|
|
* See: LGPL.txt in top directory.
|
|
* Author: arty
|
|
*
|
|
* Windows thread message queue test case.
|
|
* Derived from ../event/event.c in part.
|
|
*/
|
|
|
|
#include <windows.h>
|
|
#include <stdio.h>
|
|
#include <assert.h>
|
|
|
|
HANDLE hWaitForFailure;
|
|
HANDLE hOkToPostThreadMessage;
|
|
HANDLE hOkToTerminate;
|
|
|
|
DWORD WINAPI thread( LPVOID crap )
|
|
{
|
|
MSG msg;
|
|
|
|
/* Failure case ... Wait for the parent to try to post a message
|
|
before queue creation */
|
|
printf( "Waiting to create the message queue.\n" );
|
|
|
|
WaitForSingleObject(hWaitForFailure,INFINITE);
|
|
|
|
printf( "Creating message queue.\n" );
|
|
|
|
/* "Create" a message queue */
|
|
PeekMessage( &msg, NULL, 0, 0, PM_NOREMOVE );
|
|
|
|
printf( "Signalling the parent that we're ready.\n" );
|
|
|
|
/* Signal that it's ok to post */
|
|
SetEvent( hOkToPostThreadMessage );
|
|
|
|
printf( "Listening messages.\n" );
|
|
|
|
/* Now read some messages */
|
|
while( GetMessage( &msg, 0,0,0 ) ) {
|
|
printf( "Received message: %04x %04x %08lx\n",
|
|
(msg.message & 0xffff),
|
|
(msg.wParam & 0xffff),
|
|
msg.lParam );
|
|
assert( !msg.hwnd );
|
|
}
|
|
|
|
printf( "Finished receiving messages.\n" );
|
|
SetEvent( hOkToTerminate );
|
|
|
|
return 0;
|
|
}
|
|
|
|
int main( int argc, char **argv )
|
|
{
|
|
DWORD id;
|
|
|
|
printf( "Creating events\n" );
|
|
|
|
hOkToPostThreadMessage = CreateEvent( NULL, FALSE, FALSE, NULL );
|
|
hOkToTerminate = CreateEvent( NULL, FALSE, FALSE, NULL );
|
|
hWaitForFailure = CreateEvent( NULL, FALSE, FALSE, NULL );
|
|
|
|
printf( "Created events\n" );
|
|
|
|
if( CreateThread( 0, 0, thread, 0, 0, &id ) == NULL ) {
|
|
printf( "Couldn't create one thread.\n" );
|
|
return 0;
|
|
}
|
|
|
|
printf( "Posting to non-existent queue\n" );
|
|
|
|
/* Check failure case */
|
|
assert( PostThreadMessage( id, WM_USER + 0, 1, 2 ) == FALSE );
|
|
|
|
printf( "Signalling thread to advance.\n" );
|
|
|
|
SetEvent( hWaitForFailure );
|
|
|
|
printf( "Waiting for signal from thread.\n" );
|
|
WaitForSingleObject( hOkToPostThreadMessage, INFINITE );
|
|
|
|
printf( "Sending three messages, then quit.\n" );
|
|
assert( PostThreadMessage( id, WM_USER + 0, 1, 2 ) );
|
|
assert( PostThreadMessage( id, WM_USER + 1, 3, 4 ) );
|
|
Sleep( 500 ); /* Sleep a bit, so that the queue is empty for a bit. */
|
|
assert( PostThreadMessage( id, WM_USER + 2, 5, 6 ) );
|
|
assert( PostThreadMessage( id, WM_QUIT, 0,0 ) );
|
|
|
|
WaitForSingleObject( hOkToTerminate, INFINITE );
|
|
printf( "Test complete.\n" );
|
|
|
|
return 0;
|
|
}
|