QueueUserAPC.c File Reference

#include "precomp.h"

Include dependency graph for QueueUserAPC.c:

Go to the source code of this file.

Macros
#define	MAX_RECORD   30

Functions
static void	AddValueToRecord (DWORD dwValue)
static VOID	CheckRecord (void)
static DWORD WINAPI	ThreadFunc1 (LPVOID arg)
static DWORD WINAPI	ThreadFunc2 (LPVOID arg)
static VOID NTAPI	DoUserAPC1 (ULONG_PTR Parameter)
static VOID NTAPI	DoUserAPC2 (ULONG_PTR Parameter)
static VOID NTAPI	DoUserAPC3 (ULONG_PTR Parameter)
static void	JustDoIt (LPTHREAD_START_ROUTINE fn)
static void	TestForSleepEx (void)
static void	TestForWaitForSingleObjectEx (void)
static DWORD WINAPI	ThreadFunc3 (LPVOID arg)
static void	TestMultipleUserAPCs (void)
	START_TEST (QueueUserAPC)

Variables
static LONG	s_record_count = 0
static DWORD	s_record [MAX_RECORD+1] = { 0 }
static BOOL	s_terminate_all = FALSE
static const DWORD	s_expected []
static const SIZE_T	s_expected_count = _countof(s_expected)

Macro Definition Documentation

MAX_RECORD

#define MAX_RECORD   30

Definition at line 9 of file QueueUserAPC.c.

Function Documentation

AddValueToRecord()

static void AddValueToRecord ( DWORD  dwValue )

static

Definition at line 25 of file QueueUserAPC.c.

{
    LONG next = InterlockedIncrement(&s_record_count) - 1;
    if (next < MAX_RECORD)
        s_record[next] = dwValue;
}

Referenced by DoUserAPC1(), DoUserAPC2(), DoUserAPC3(), JustDoIt(), ThreadFunc1(), and ThreadFunc2().

CheckRecord()

static VOID CheckRecord ( void  )

static

Definition at line 32 of file QueueUserAPC.c.

{
    SIZE_T i, count = min(s_record_count, s_expected_count);
 
    for (i = 0; i < count; ++i)
    {
        ok(s_record[i] == s_expected[i], "s_record[%u]: got %lu vs expected %lu\n",
           (INT)i, s_record[i], s_expected[i]);
    }
 
    count = abs((int)s_record_count - (int)s_expected_count);
    for (i = 0; i < count; ++i)
    {
        ok(s_record_count == s_expected_count,
           "s_record_count: got %u vs expected %u\n",
           (int)s_record_count, (int)s_expected_count);
    }
}

Referenced by JustDoIt().

DoUserAPC1()

static VOID NTAPI DoUserAPC1 ( ULONG_PTR  Parameter )

static

Definition at line 77 of file QueueUserAPC.c.

{
    ok_int((int)Parameter, 1);
    AddValueToRecord(4);
}

Referenced by JustDoIt(), and TestMultipleUserAPCs().

DoUserAPC2()

static VOID NTAPI DoUserAPC2 ( ULONG_PTR  Parameter )

static

Definition at line 83 of file QueueUserAPC.c.

{
    ok_int((int)Parameter, 2);
    AddValueToRecord(5);
}

Referenced by JustDoIt(), and TestMultipleUserAPCs().

DoUserAPC3()

static VOID NTAPI DoUserAPC3 ( ULONG_PTR  Parameter )

static

Definition at line 89 of file QueueUserAPC.c.

{
    ok_int((int)Parameter, 3);
    AddValueToRecord(6);
    s_terminate_all = TRUE;
}

Referenced by JustDoIt(), and TestMultipleUserAPCs().

JustDoIt()

static void JustDoIt ( LPTHREAD_START_ROUTINE  fn )

static

Definition at line 96 of file QueueUserAPC.c.

{
    HANDLE hThread;
    DWORD dwThreadId;
 
    s_terminate_all = FALSE;
    s_record_count = 0;
    ZeroMemory(s_record, sizeof(s_record));
 
    hThread = CreateThread(NULL, 0, fn, NULL, 0, &dwThreadId);
    ok(hThread != NULL, "hThread was NULL\n");
 
    Sleep(100);
 
    AddValueToRecord(7);
    ok_long(QueueUserAPC(DoUserAPC1, hThread, 1), 1);
    AddValueToRecord(8);
 
    Sleep(100);
 
    AddValueToRecord(9);
    ok_long(QueueUserAPC(DoUserAPC2, hThread, 2), 1);
    AddValueToRecord(10);
 
    Sleep(100);
 
    AddValueToRecord(11);
    ok_long(QueueUserAPC(DoUserAPC3, hThread, 3), 1);
    AddValueToRecord(12);
 
    AddValueToRecord(13);
    ok_long(WaitForSingleObject(hThread, 5 * 1000), WAIT_OBJECT_0);
    AddValueToRecord(14);
 
    AddValueToRecord(15);
    ok_int(CloseHandle(hThread), TRUE);
    hThread = NULL;
    AddValueToRecord(16);
 
    CheckRecord();
}

START_TEST()

START_TEST

(

QueueUserAPC

)

Definition at line 180 of file QueueUserAPC.c.

{
    TestForSleepEx();
    TestForWaitForSingleObjectEx();
    TestMultipleUserAPCs();
}

TestForSleepEx()

static void TestForSleepEx ( void  )

static

Definition at line 138 of file QueueUserAPC.c.

{
    JustDoIt(ThreadFunc1);
}

Referenced by START_TEST().

TestForWaitForSingleObjectEx()

static void TestForWaitForSingleObjectEx ( void  )

static

Definition at line 143 of file QueueUserAPC.c.

{
    JustDoIt(ThreadFunc2);
}

Referenced by START_TEST().

TestMultipleUserAPCs()

static void TestMultipleUserAPCs ( void  )

static

Definition at line 153 of file QueueUserAPC.c.

{
    HANDLE hThread;
    DWORD dwThreadId;
 
    s_record_count = 0;
 
    hThread = CreateThread(NULL, 0, ThreadFunc3, NULL, CREATE_SUSPENDED, &dwThreadId);
    ok(hThread != NULL, "hThread was NULL\n");
 
    ok_long(QueueUserAPC(DoUserAPC1, hThread, 1), 1);
    ok_long(QueueUserAPC(DoUserAPC2, hThread, 2), 1);
    ok_long(QueueUserAPC(DoUserAPC3, hThread, 3), 1);
 
    ok_long(s_record_count, 0);
 
    ResumeThread(hThread);
 
    ok_long(WaitForSingleObject(hThread, 5 * 1000), WAIT_OBJECT_0);
    ok_int(CloseHandle(hThread), TRUE);
 
    ok_long(s_record_count, 3);
    ok_long(s_record[0], 4);
    ok_long(s_record[1], 5);
    ok_long(s_record[2], 6);
}

Referenced by START_TEST().

ThreadFunc1()

static DWORD WINAPI ThreadFunc1 ( LPVOID  arg )

static

Definition at line 51 of file QueueUserAPC.c.

{
    AddValueToRecord(0);
    while (!s_terminate_all)
    {
        AddValueToRecord(1);
        ok_long(SleepEx(INFINITE, TRUE), WAIT_IO_COMPLETION);
        AddValueToRecord(2);
    }
    AddValueToRecord(3);
    return 0;
}

Referenced by TestForSleepEx().

ThreadFunc2()

static DWORD WINAPI ThreadFunc2 ( LPVOID  arg )

static

Definition at line 64 of file QueueUserAPC.c.

{
    AddValueToRecord(0);
    while (!s_terminate_all)
    {
        AddValueToRecord(1);
        ok_long(WaitForSingleObjectEx(GetCurrentThread(), INFINITE, TRUE), WAIT_IO_COMPLETION);
        AddValueToRecord(2);
    }
    AddValueToRecord(3);
    return 0;
}

Referenced by TestForWaitForSingleObjectEx().

ThreadFunc3()

static DWORD WINAPI ThreadFunc3 ( LPVOID  arg )

static

Definition at line 148 of file QueueUserAPC.c.

{
    return 0;
}

Referenced by TestMultipleUserAPCs().

Variable Documentation

s_expected

const DWORD s_expected[]

static

Initial value:

=
{
    0, 1, 7, 8, 4,
    2, 1, 9, 10, 5,
    2, 1, 11, 12, 13,
    6, 2, 3, 14, 15,
    16
}

Definition at line 15 of file QueueUserAPC.c.

Referenced by CheckRecord().

s_expected_count

const SIZE_T s_expected_count = _countof(s_expected)

static

Definition at line 23 of file QueueUserAPC.c.

Referenced by CheckRecord().

s_record

DWORD s_record[MAX_RECORD+1] = { 0 }

static

Definition at line 12 of file QueueUserAPC.c.

Referenced by AddValueToRecord(), CheckRecord(), JustDoIt(), and TestMultipleUserAPCs().

s_record_count

LONG s_record_count = 0

static

Definition at line 11 of file QueueUserAPC.c.

Referenced by AddValueToRecord(), CheckRecord(), JustDoIt(), and TestMultipleUserAPCs().

s_terminate_all

BOOL s_terminate_all = FALSE

static

Definition at line 13 of file QueueUserAPC.c.

Referenced by DoUserAPC3(), JustDoIt(), ThreadFunc1(), and ThreadFunc2().