asyncselect.cpp File Reference

#include "lspdef.h"
#include <windows.h>
#include <strsafe.h>

Include dependency graph for asyncselect.cpp:

Go to the source code of this file.

Defines
#define	STRSAFE_NO_DEPRECATE
#define	PROVIDER_CLASS   TEXT("Layered WS2 Provider 0x%08x")
#define	PROVIDER_CLASS_CHAR_LEN   32
#define	MAX_ASYNC_RETRIES   7
#define	ASYNC_TIMEOUT   500
Functions
int	StopAsyncWindowManager ()
HWND	GetWorkerWindow ()

---

Define Documentation

#define ASYNC_TIMEOUT   500

Definition at line 54 of file asyncselect.cpp.

#define MAX_ASYNC_RETRIES   7

Definition at line 53 of file asyncselect.cpp.

#define PROVIDER_CLASS   TEXT("Layered WS2 Provider 0x%08x")

Definition at line 42 of file asyncselect.cpp.

#define PROVIDER_CLASS_CHAR_LEN   32

Definition at line 43 of file asyncselect.cpp.

#define STRSAFE_NO_DEPRECATE

Definition at line 33 of file asyncselect.cpp.

---

Function Documentation

HWND GetWorkerWindow

(

)

Definition at line 142 of file asyncselect.cpp.

{
    HANDLE  ReadyEvent = NULL;
    int     rc;

    EnterCriticalSection( &gCriticalSection );
    if ( NULL == WorkerThreadHandle ) 
    {
        // Create an event which the worker thread will signal when its ready
        ReadyEvent = CreateEvent( NULL, TRUE, FALSE, NULL );
        if ( NULL == ReadyEvent )
        {
            dbgprint("GetWorkerWindow: CreateEvent failed: %d", GetLastError() );
            goto cleanup;
        }

        // Create the asyn window message thread
        WorkerThreadHandle = CreateThread(
                NULL, 
                0, 
                AsyncMsgHandler, 
                (LPVOID)ReadyEvent, 
                0, 
                NULL
                ); 
        if ( NULL == WorkerThreadHandle )
        {
            dbgprint( "GetWorkerWindow: CreateThread failed: %d", GetLastError() );
            goto cleanup;
        }

        // Wait for the window to become initialized
        rc = WaitForSingleObject( ReadyEvent, INFINITE );
        if ( ( WAIT_FAILED == rc ) || ( WAIT_TIMEOUT == rc ) )
            dbgprint( "GetWorkerWindow: WaitForSingleObject failed: %d! (error = %d)", 
                    rc, GetLastError() );
    }

cleanup:

    if ( NULL != ReadyEvent )
    {
        // Close the ready event
        rc = CloseHandle( ReadyEvent );
        if ( 0 == rc )
        {
            dbgprint("GetWorkerWindow: CloseHandle failed: %d", GetLastError() );
        }
    }

    LeaveCriticalSection( &gCriticalSection );

    return AsyncWindow;
}

int StopAsyncWindowManager

(

)

Definition at line 96 of file asyncselect.cpp.

{
    int     rc,
            code;

    if ( NULL != AsyncWindow )
    {
        // Post a quit message to the thread
        PostMessage( AsyncWindow, WM_DESTROY, 0, 0 );

        // Wait for the thread to cleanup and exit
        rc = WaitForSingleObject( WorkerThreadHandle, 10000 );
        if ( WAIT_TIMEOUT == rc )
        {
            dbgprint("StopAsyncWindowManager: Timed out waiting for async thread!");
            goto cleanup;
        }

        // Retrieve the exit code and display a simple message
        rc = GetExitCodeThread( WorkerThreadHandle, (LPDWORD) &code );
        if ( 0 == rc )
            dbgprint("StopAsyncWindowManager: Unable to retrieve thread exit code: %d",
                    GetLastError() );
        else if ( 0 != code )
            dbgprint("StopAsyncWindowManager: Async window thread exited abnormally!");

cleanup:

        CloseHandle( WorkerThreadHandle );

        WorkerThreadHandle = NULL;
    }

    return 0;
}