thread_msg.c File Reference

#include <windows.h>
#include <stdio.h>
#include <assert.h>

Include dependency graph for thread_msg.c:

Go to the source code of this file.

Functions
DWORD WINAPI	thread (LPVOID crap)
int	main (int argc, char **argv)

Variables
HANDLE	hWaitForFailure
HANDLE	hOkToPostThreadMessage
HANDLE	hOkToTerminate

Function Documentation

main()

int main	(	int argc	,
		char **	argv
	)

Definition at line 57 of file thread_msg.c.

{
    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;
}

thread()

DWORD WINAPI thread

(

LPVOID

crap

)

Definition at line 20 of file thread_msg.c.

{
    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;
}

Variable Documentation

hOkToPostThreadMessage

HANDLE hOkToPostThreadMessage

Definition at line 17 of file thread_msg.c.

Referenced by main(), and thread().

hOkToTerminate

HANDLE hOkToTerminate

Definition at line 18 of file thread_msg.c.

Referenced by main(), and thread().

hWaitForFailure

HANDLE hWaitForFailure

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.

Definition at line 16 of file thread_msg.c.

Referenced by main(), and thread().