3c99391d93
In some cases the license-identification header was missing, so I added that as well. Replaced the remaining headers that specifically identified "Versions 3.13.7 and higher". Makefiles and the build system were deliberately excluded.
123 lines
3.9 KiB
C++
123 lines
3.9 KiB
C++
/*************************************************************************\
|
||
* Copyright (c) 2006 UChicago Argonne LLC, as Operator of Argonne
|
||
* National Laboratory.
|
||
* Copyright (c) 2002 The Regents of the University of California, as
|
||
* Operator of Los Alamos National Laboratory.
|
||
* SPDX-License-Identifier: EPICS
|
||
* EPICS BASE is distributed subject to a Software License Agreement found
|
||
* in file LICENSE that is included with this distribution.
|
||
\*************************************************************************/
|
||
/* epicsdThreadPriorityTest.cpp */
|
||
|
||
/* Author: Marty Kraimer Date: 21NOV2005 */
|
||
|
||
#include <stddef.h>
|
||
#include <stdlib.h>
|
||
#include <stddef.h>
|
||
#include <string.h>
|
||
#include <stdio.h>
|
||
#include <errno.h>
|
||
#include <time.h>
|
||
|
||
#include "epicsThread.h"
|
||
#include "epicsEvent.h"
|
||
#include "epicsExit.h"
|
||
#include "epicsUnitTest.h"
|
||
#include "testMain.h"
|
||
|
||
|
||
typedef struct info {
|
||
epicsEventId waitForMaster;
|
||
epicsEventId waitForClient;
|
||
}info;
|
||
|
||
extern "C" {
|
||
|
||
static void client(void *arg)
|
||
{
|
||
info *pinfo = (info *)arg;
|
||
epicsThreadId idSelf = epicsThreadGetIdSelf();
|
||
int pass;
|
||
|
||
for (pass = 0 ; pass < 3 ; pass++) {
|
||
epicsEventWaitStatus status;
|
||
status = epicsEventWait(pinfo->waitForMaster);
|
||
testOk(status == epicsEventWaitOK,
|
||
"task %p epicsEventWait returned %d", idSelf, status);
|
||
epicsThreadSleep(0.01);
|
||
epicsEventSignal(pinfo->waitForClient);
|
||
}
|
||
}
|
||
|
||
static void runThreadPriorityTest(void *arg)
|
||
{
|
||
epicsEventId testComplete = (epicsEventId) arg;
|
||
unsigned int stackSize = epicsThreadGetStackSize(epicsThreadStackSmall);
|
||
|
||
epicsThreadId myId = epicsThreadGetIdSelf();
|
||
epicsThreadSetPriority(myId, 50);
|
||
|
||
info *pinfo = (info *)calloc(1, sizeof(info));
|
||
pinfo->waitForMaster = epicsEventMustCreate(epicsEventEmpty);
|
||
pinfo->waitForClient = epicsEventMustCreate(epicsEventEmpty);
|
||
|
||
epicsThreadId clientId = epicsThreadCreate("client",
|
||
50, stackSize, client, pinfo);
|
||
epicsEventSignal(pinfo->waitForMaster);
|
||
|
||
epicsEventWaitStatus status;
|
||
status = epicsEventWaitWithTimeout(pinfo->waitForClient, 0.1);
|
||
if (!testOk(status == epicsEventWaitOK,
|
||
"epicsEventWaitWithTimeout returned %d", status)) {
|
||
testSkip(2, "epicsEventWaitWithTimeout failed");
|
||
goto done;
|
||
}
|
||
|
||
epicsThreadSetPriority(clientId, 20);
|
||
/* expect that client will not be able to run */
|
||
epicsEventSignal(pinfo->waitForMaster);
|
||
|
||
status = epicsEventTryWait(pinfo->waitForClient);
|
||
if (status != epicsEventWaitTimeout) {
|
||
testFail("epicsEventTryWait returned %d", status);
|
||
} else {
|
||
status = epicsEventWaitWithTimeout(pinfo->waitForClient, 0.1);
|
||
if (!testOk(status == epicsEventWaitOK,
|
||
"epicsEventWaitWithTimeout returned %d", status)) {
|
||
testSkip(1, "epicsEventWaitWithTimeout failed");
|
||
goto done;
|
||
}
|
||
}
|
||
epicsThreadSetPriority(clientId, 80);
|
||
/* expect that client will be able to run */
|
||
epicsEventSignal(pinfo->waitForMaster);
|
||
status = epicsEventTryWait(pinfo->waitForClient);
|
||
if (status==epicsEventWaitOK) {
|
||
testPass("Strict priority scheduler");
|
||
} else {
|
||
testDiag("No strict priority scheduler");
|
||
status = epicsEventWaitWithTimeout(pinfo->waitForClient,.1);
|
||
testOk(status == epicsEventWaitOK,
|
||
"epicsEventWaitWithTimeout returned %d", status);
|
||
}
|
||
done:
|
||
epicsThreadSleep(1.0);
|
||
epicsEventSignal(testComplete);
|
||
}
|
||
|
||
} /* extern "C" */
|
||
|
||
|
||
MAIN(epicsThreadPriorityTest)
|
||
{
|
||
testPlan(7);
|
||
epicsEventId testComplete = epicsEventMustCreate(epicsEventEmpty);
|
||
epicsThreadMustCreate("threadPriorityTest", epicsThreadPriorityMedium,
|
||
epicsThreadGetStackSize(epicsThreadStackMedium),
|
||
runThreadPriorityTest, testComplete);
|
||
epicsEventWaitStatus status = epicsEventWait(testComplete);
|
||
testOk(status == epicsEventWaitOK,
|
||
"epicsEventWait returned %d", status);
|
||
return testDone();
|
||
}
|