tmrqueue.c File Reference

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

Include dependency graph for tmrqueue.c:

Go to the source code of this file.

Classes
struct	_TEST
struct	_TESTINFO

Macros
#define	N_TIMEOUT   3

Typedefs
typedef struct _TEST *	PTEST
typedef VOID(*	PFNTEST) (PTEST Test, HANDLE hEvent)
typedef struct _TEST	TEST
typedef struct _TESTINFO	TESTINFO
typedef struct _TESTINFO *	PTESTINFO

Functions
VOID	RunTests (VOID)
VOID	PrintTestResults (VOID)
VOID CALLBACK	TimerCallback1 (PVOID Param, BOOLEAN Fired)
VOID	Test1 (PTEST Test, HANDLE hEvent)
VOID CALLBACK	TimerCallback2 (PVOID Param, BOOLEAN Fired)
VOID	Test2 (PTEST Test, HANDLE hEvent)
VOID CALLBACK	TimerCallback3 (PVOID Param, BOOLEAN Fired)
VOID	Test3 (PTEST Test, HANDLE hEvent)
VOID	InitTests (VOID)
int	main (int argc, char *argv[])

Variables
static TEST	Tests [3]

Macro Definition Documentation

N_TIMEOUT

#define N_TIMEOUT   3

Definition at line 5 of file tmrqueue.c.

Typedef Documentation

PFNTEST

typedef VOID(* PFNTEST) (PTEST Test, HANDLE hEvent)

Definition at line 11 of file tmrqueue.c.

PTEST

typedef struct _TEST* PTEST

Definition at line 9 of file tmrqueue.c.

PTESTINFO

typedef struct _TESTINFO * PTESTINFO

TEST

typedef struct _TEST TEST

TESTINFO

typedef struct _TESTINFO TESTINFO

Function Documentation

InitTests()

VOID InitTests

(

VOID

)

Definition at line 338 of file tmrqueue.c.

{
  ZeroMemory(Tests, sizeof(Tests));
 
  Tests[0].description = _T("non-blocking DeleteTimerQueueTimer() call from callback");
  Tests[0].Routine = Test1;
 
  Tests[1].description = _T("blocking DeleteTimerQueueTimer() call");
  Tests[1].Routine = Test2;
 
  Tests[2].description = _T("blocking DeleteTimerQueueTimer() call with specified event");
  Tests[2].Routine = Test3;
}

Referenced by main().

main()

int main	(	int argc	,
		char *	argv[]
	)

Definition at line 352 of file tmrqueue.c.

{
  _tprintf(_T("+++ TimerQueue test running +++\n\n"));
 
  InitTests();
 
  RunTests();
 
  _tprintf(_T("\n+++ RESULTS +++\n"));
 
  PrintTestResults();
 
  return 0;
}

PrintTestResults()

VOID PrintTestResults

(

VOID

)

Definition at line 58 of file tmrqueue.c.

{
  int i, nTests, nsuccess = 0, nfailed = 0;
  TCHAR *status;
 
  nTests = sizeof(Tests) / sizeof(TEST);
 
  for(i = 0; i < nTests; i++)
  {
    if(Tests[i].Routine == NULL)
    {
      status = _T("SKIPPED");
    }
    else if(Tests[i].Result == TRUE)
    {
      status = _T("SUCCESS");
      nsuccess++;
    }
    else
    {
      status = _T("FAILED ");
      nfailed++;
    }
 
    _tprintf(_T("Test %d: %s %s\n"), i, status, Tests[i].description);
  }
 
  _tprintf(_T("\nTests succeeded: %d, failed: %d\n"), nsuccess, nfailed);
  if(nfailed == 0)
  {
    _tprintf(_T("  ALL TESTS SUCCESSFUL!\n"));
  }
}

Referenced by main().

RunTests()

VOID RunTests

(

VOID

)

Definition at line 23 of file tmrqueue.c.

{
  int i, nTests;
  static HANDLE hEvent;
 
  hEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
  if(hEvent == NULL)
  {
    _tprintf(_T("Unable to create event!"));
    return;
  }
 
  nTests = sizeof(Tests) / sizeof(TEST);
 
  for(i = 0; i < nTests; i++)
  {
    Tests[i].id = i + 1;
 
    if(Tests[i].Routine == NULL)
    {
      continue;
    }
 
    _tprintf(_T("+++ TEST %d: %s\n"), Tests[i].id, Tests[i].description);
 
    Tests[i].Routine(&Tests[i], hEvent);
 
    WaitForSingleObject(hEvent, INFINITE);
 
    _tprintf(_T("\n\n"));
  }
 
  CloseHandle(hEvent);
}

Test1()

VOID Test1	(	PTEST	Test,
		HANDLE	hEvent
	)

Definition at line 155 of file tmrqueue.c.

{
  static TESTINFO Info;
 
  Info.Test = Test;
  Info.hEvent = hEvent;
  Info.secsleft = N_TIMEOUT;
 
  if(!CreateTimerQueueTimer(&Info.hTimer, NULL, TimerCallback1, &Info, 1000, 1000, 0))
  {
    _tprintf(_T("[%d]CreateTimerQueueTimer() failed, LastError: %d!"), (int)Info.Test->id, (int)GetLastError());
    /* we failed, set the event to continue tests */
    SetEvent(hEvent);
    return;
  }
 
  _tprintf(_T("[%d]CreateTimerQueueTimer() created timer 0x%x, countdown (%d sec)...\n"), (int)Info.Test->id, (int)Info.hTimer, (int)Info.secsleft);
}

Test2()

VOID Test2	(	PTEST	Test,
		HANDLE	hEvent
	)

Definition at line 192 of file tmrqueue.c.

{
  static TESTINFO Info;
  BOOL stat;
 
  Info.Test = Test;
  Info.hEvent = hEvent;
  Info.secsleft = N_TIMEOUT;
 
  Info.Test2.hWaitEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
  if(Info.Test2.hWaitEvent == NULL)
  {
    _tprintf(_T("[%d]Unable to create event!\n"), (int)Info.Test->id);
    return;
  }
 
  if(!CreateTimerQueueTimer(&Info.hTimer, NULL, TimerCallback2, &Info, 1000, 1000, 0))
  {
    _tprintf(_T("[%d]CreateTimerQueueTimer() failed, LastError: %d!"), (int)Info.Test->id, (int)GetLastError());
 
    CloseHandle(Info.Test2.hWaitEvent);
    /* we failed, set the event to continue tests */
    SetEvent(hEvent);
    return;
  }
 
  _tprintf(_T("[%d]CreateTimerQueueTimer() created timer 0x%x, countdown (%d sec)...\n"), (int)Test->id, (int)Info.hTimer, (int)Info.secsleft);
 
  WaitForSingleObject(Info.Test2.hWaitEvent, INFINITE);
 
  _tprintf(_T("[%d]Timout finished, delete timer queue..."), (int)Test->id);
  stat = DeleteTimerQueueTimer(NULL, Info.hTimer, INVALID_HANDLE_VALUE);
  if(stat)
  {
    _tprintf(_T("OK\n"));
    /* this test is only successful in this case */
    Test->Result = TRUE;
  }
  else
  {
    int error = GetLastError();
 
    switch(error)
    {
      case ERROR_IO_PENDING:
        _tprintf(_T("FAILED, Overlapped I/O operation in progress\n"));
        break;
      default:
        _tprintf(_T("Failed, LastError: %d\n"), (int)GetLastError());
        break;
    }
  }
 
  SetEvent(Info.hEvent);
}

Test3()

VOID Test3	(	PTEST	Test,
		HANDLE	hEvent
	)

Definition at line 266 of file tmrqueue.c.

{
  static TESTINFO Info;
  BOOL stat;
 
  Info.Test = Test;
  Info.hEvent = hEvent;
  Info.secsleft = N_TIMEOUT;
 
  Info.Test3.hWaitEvent = CreateEvent(NULL, FALSE, FALSE, NULL);
  if(Info.Test3.hWaitEvent == NULL)
  {
    _tprintf(_T("[%d]Unable to create event!\n"), (int)Info.Test->id);
    return;
  }
 
  Info.Test3.hNotification = CreateEvent(NULL, FALSE, FALSE, NULL);
  if(Info.Test3.hNotification == NULL)
  {
    _tprintf(_T("[%d]Unable to create notification event!\n"), (int)Info.Test->id);
    return;
  }
 
  if(!CreateTimerQueueTimer(&Info.hTimer, NULL, TimerCallback3, &Info, 1000, 1000, 0))
  {
    _tprintf(_T("[%d]CreateTimerQueueTimer() failed, LastError: %d!"), (int)Info.Test->id, (int)GetLastError());
 
    CloseHandle(Info.Test3.hWaitEvent);
    CloseHandle(Info.Test3.hNotification);
    /* we failed, set the event to continue tests */
    SetEvent(hEvent);
    return;
  }
 
  _tprintf(_T("[%d]CreateTimerQueueTimer() created timer 0x%x, countdown (%d sec)...\n"), (int)Test->id, (int)Info.hTimer, (int)Info.secsleft);
 
  WaitForSingleObject(Info.Test3.hWaitEvent, INFINITE);
 
  _tprintf(_T("[%d]Timout finished, delete timer queue..."), (int)Test->id);
  stat = DeleteTimerQueueTimer(NULL, Info.hTimer, Info.Test3.hNotification);
  if(stat)
  {
    _tprintf(_T("returned OK -> test FAILED!\n"));
  }
  else
  {
    int error = GetLastError();
 
    switch(error)
    {
      case ERROR_IO_PENDING:
        _tprintf(_T("OK, Overlapped I/O operation in progress\n"));
        /* this test is only successful in this case */
        Test->Result = TRUE;
        break;
      default:
        _tprintf(_T("Failed, LastError: %d\n"), (int)GetLastError());
        break;
    }
  }
 
  WaitForSingleObject(Info.Test3.hNotification, INFINITE);
 
  CloseHandle(Info.Test3.hWaitEvent);
  CloseHandle(Info.Test3.hNotification);
 
  SetEvent(Info.hEvent);
}

Referenced by InitTests(), MainWndProc(), and SymlinkCreateTests().

TimerCallback1()

VOID CALLBACK TimerCallback1	(	PVOID	Param,
		BOOLEAN	Fired
	)

Definition at line 119 of file tmrqueue.c.

{
  PTESTINFO Info = (PTESTINFO)Param;
 
  _tprintf(_T("[%d]TimerCallback(0x%x, %d) called (%d)\n"), (int)Info->Test->id, (int)Info->hTimer, (int)Fired, --Info->secsleft);
 
  if(Info->secsleft == 0)
  {
    BOOL stat;
 
    _tprintf(_T("[%d]Timout finished, delete timer queue..."), (int)Info->Test->id);
    stat = DeleteTimerQueueTimer(NULL, Info->hTimer, NULL);
    if(stat)
      _tprintf(_T("returned OK -> test FAILED!\n"));
    else
    {
      int error = GetLastError();
 
      switch(error)
      {
        case ERROR_IO_PENDING:
          _tprintf(_T("OK, Overlapped I/O operation in progress\n"));
          /* this test is only successful in this case */
          Info->Test->Result = TRUE;
          break;
        default:
          _tprintf(_T("Failed, LastError: %d\n"), (int)GetLastError());
          break;
      }
    }
 
    /* set the event to continue tests */
    SetEvent(Info->hEvent);
  }
}

Referenced by Test1().

TimerCallback2()

VOID CALLBACK TimerCallback2	(	PVOID	Param,
		BOOLEAN	Fired
	)

Definition at line 176 of file tmrqueue.c.

{
  PTESTINFO Info = (PTESTINFO)Param;
 
  _tprintf(_T("[%d]TimerCallback(0x%x, %d) called (%d)\n"), (int)Info->Test->id, (int)Info->hTimer, (int)Fired, --Info->secsleft);
 
  if(Info->secsleft == 0)
  {
    /* set the event to continue tests */
    SetEvent(Info->Test2.hWaitEvent);
 
    /* sleep a bit */
    Sleep(1500);
  }
}

Referenced by Test2().

TimerCallback3()

VOID CALLBACK TimerCallback3	(	PVOID	Param,
		BOOLEAN	Fired
	)

Definition at line 250 of file tmrqueue.c.

{
  PTESTINFO Info = (PTESTINFO)Param;
 
  _tprintf(_T("[%d]TimerCallback(0x%x, %d) called (%d)\n"), (int)Info->Test->id, (int)Info->hTimer, (int)Fired, --Info->secsleft);
 
  if(Info->secsleft == 0)
  {
    /* set the event to continue tests */
    SetEvent(Info->Test3.hWaitEvent);
 
    /* sleep a bit */
    Sleep(1500);
  }
}

Referenced by Test3().

Variable Documentation

Tests

TEST Tests[3]

static

Definition at line 21 of file tmrqueue.c.

Referenced by InitTests(), PrintTestResults(), and RunTests().