tstR0ThreadPreemptionDriver.cpp revision 1d42c7799e7c35c5b36a2494cde9a47e5651cead
/* $Id$ */
/** @file
* IPRT R0 Testcase - Thread Preemption, driver program.
*/
/*
* Copyright (C) 2009-2010 Oracle Corporation
*
* This file is part of VirtualBox Open Source Edition (OSE), as
* available from http://www.virtualbox.org. This file is free software;
* General Public License (GPL) as published by the Free Software
* Foundation, in version 2 as it comes in the "COPYING" file of the
* VirtualBox OSE distribution. VirtualBox OSE is distributed in the
* hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
*
* The contents of this file may alternatively be used under the terms
* of the Common Development and Distribution License Version 1.0
* (CDDL) only, as it comes in the "COPYING.CDDL" file of the
* VirtualBox OSE distribution, in which case the provisions of the
* CDDL are applicable instead of those of the GPL.
*
* You may elect to license modified versions of this file under the
* terms and conditions of either the GPL or the CDDL or both.
*/
/*******************************************************************************
* Header Files *
*******************************************************************************/
#include <iprt/initterm.h>
#ifdef VBOX
# include "tstR0ThreadPreemption.h"
#endif
/*******************************************************************************
* Global Variables *
*******************************************************************************/
static bool volatile g_fTerminate = false;
/**
* Try make sure all online CPUs will be engaged.
*/
{
while (!g_fTerminate)
{
do
{
ASMNopPause();
RTThreadSleep(4);
}
return VINF_SUCCESS;
}
{
#ifndef VBOX
RTPrintf("tstSup: SKIPPED\n");
return 0;
#else
/*
* Init.
*/
if (rc)
return rc;
if (RT_FAILURE(rc))
{
return RTTestSummaryAndDestroy(hTest);
}
char szPath[RTPATH_MAX];
if (RT_SUCCESS(rc))
if (RT_FAILURE(rc))
{
return RTTestSummaryAndDestroy(hTest);
}
void *pvImageBase;
"TSTR0ThreadPreemptionSrvReqHandler",
&pvImageBase);
if (RT_FAILURE(rc))
{
return RTTestSummaryAndDestroy(hTest);
}
/* test request */
struct
{
char szMsg[256];
} Req;
/*
* Sanity checks.
*/
RTTESTI_CHECK_RC(rc = SUPR3CallR0Service("tstR0ThreadPreemption", sizeof("tstR0ThreadPreemption") - 1,
if (RT_FAILURE(rc))
return RTTestSummaryAndDestroy(hTest);
return RTTestSummaryAndDestroy(hTest);
RTTESTI_CHECK_RC(rc = SUPR3CallR0Service("tstR0ThreadPreemption", sizeof("tstR0ThreadPreemption") - 1,
if (RT_FAILURE(rc))
return RTTestSummaryAndDestroy(hTest);
return RTTestSummaryAndDestroy(hTest);
/*
* Basic tests, bail out on failure.
*/
RTTESTI_CHECK_RC(rc = SUPR3CallR0Service("tstR0ThreadPreemption", sizeof("tstR0ThreadPreemption") - 1,
if (RT_FAILURE(rc))
return RTTestSummaryAndDestroy(hTest);
{
return RTTestSummaryAndDestroy(hTest);
}
/*
* Is it trusty.
*/
RTTESTI_CHECK_RC(rc = SUPR3CallR0Service("tstR0ThreadPreemption", sizeof("tstR0ThreadPreemption") - 1,
if (RT_FAILURE(rc))
return RTTestSummaryAndDestroy(hTest);
/*
* Stay in ring-0 until preemption is pending.
*/
{
ahThreads[i] = NIL_RTTHREAD;
if (RTCpuSetIsMemberByIndex(&OnlineSet, i))
RTTHREADFLAGS_WAITABLE, "cpu=%u", i);
}
for (int i = 0; ; i++)
{
RTTESTI_CHECK_RC(rc = SUPR3CallR0Service("tstR0ThreadPreemption", sizeof("tstR0ThreadPreemption") - 1,
|| i >= 64)
{
break;
}
if ((i % 3) == 0)
else if ((i % 16) == 0)
RTThreadSleep(8);
}
ASMAtomicWriteBool(&g_fTerminate, true);
if (ahThreads[i] != NIL_RTTHREAD)
/*
* Test nested RTThreadPreemptDisable calls.
*/
RTTESTI_CHECK_RC(rc = SUPR3CallR0Service("tstR0ThreadPreemption", sizeof("tstR0ThreadPreemption") - 1,
/*
* Test thread-context hooks.
*/
RTTESTI_CHECK_RC(rc = SUPR3CallR0Service("tstR0ThreadPreemption", sizeof("tstR0ThreadPreemption") - 1,
if (RT_FAILURE(rc))
return RTTestSummaryAndDestroy(hTest);
/*
* Done.
*/
return RTTestSummaryAndDestroy(hTest);
#endif
}