Cygwin: testsuite: Update pthread tests for default SCHED_FIFO
Update for default (and only) thread scheduler policy is SCHED_FIFO.
This commit is contained in:
parent
736618054c
commit
663922f618
|
@ -65,8 +65,8 @@ main()
|
||||||
int policy;
|
int policy;
|
||||||
int inheritsched = -1;
|
int inheritsched = -1;
|
||||||
|
|
||||||
assert((maxPrio = sched_get_priority_max(SCHED_OTHER)) != -1);
|
assert((maxPrio = sched_get_priority_max(SCHED_FIFO)) != -1);
|
||||||
assert((minPrio = sched_get_priority_min(SCHED_OTHER)) != -1);
|
assert((minPrio = sched_get_priority_min(SCHED_FIFO)) != -1);
|
||||||
|
|
||||||
assert(pthread_attr_init(&attr) == 0);
|
assert(pthread_attr_init(&attr) == 0);
|
||||||
assert(pthread_attr_setinheritsched(&attr, PTHREAD_INHERIT_SCHED) == 0);
|
assert(pthread_attr_setinheritsched(&attr, PTHREAD_INHERIT_SCHED) == 0);
|
||||||
|
@ -78,9 +78,9 @@ main()
|
||||||
mainParam.sched_priority = prio;
|
mainParam.sched_priority = prio;
|
||||||
|
|
||||||
/* Change the main thread priority */
|
/* Change the main thread priority */
|
||||||
assert(pthread_setschedparam(mainThread, SCHED_OTHER, &mainParam) == 0);
|
assert(pthread_setschedparam(mainThread, SCHED_FIFO, &mainParam) == 0);
|
||||||
assert(pthread_getschedparam(mainThread, &policy, &mainParam) == 0);
|
assert(pthread_getschedparam(mainThread, &policy, &mainParam) == 0);
|
||||||
assert(policy == SCHED_OTHER);
|
assert(policy == SCHED_FIFO);
|
||||||
assert(mainParam.sched_priority == prio);
|
assert(mainParam.sched_priority == prio);
|
||||||
|
|
||||||
for (param.sched_priority = prio;
|
for (param.sched_priority = prio;
|
||||||
|
|
|
@ -47,7 +47,7 @@ void * func(void * arg)
|
||||||
struct sched_param param;
|
struct sched_param param;
|
||||||
|
|
||||||
assert(pthread_getschedparam(pthread_self(), &policy, ¶m) == 0);
|
assert(pthread_getschedparam(pthread_self(), &policy, ¶m) == 0);
|
||||||
assert(policy == SCHED_OTHER);
|
assert(policy == SCHED_FIFO);
|
||||||
return (void *)(size_t)param.sched_priority;
|
return (void *)(size_t)param.sched_priority;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -58,8 +58,8 @@ main()
|
||||||
pthread_attr_t attr;
|
pthread_attr_t attr;
|
||||||
void * result = NULL;
|
void * result = NULL;
|
||||||
struct sched_param param;
|
struct sched_param param;
|
||||||
int maxPrio = sched_get_priority_max(SCHED_OTHER);
|
int maxPrio = sched_get_priority_max(SCHED_FIFO);
|
||||||
int minPrio = sched_get_priority_min(SCHED_OTHER);
|
int minPrio = sched_get_priority_min(SCHED_FIFO);
|
||||||
|
|
||||||
assert(pthread_attr_init(&attr) == 0);
|
assert(pthread_attr_init(&attr) == 0);
|
||||||
assert(pthread_attr_setinheritsched(&attr, PTHREAD_EXPLICIT_SCHED) == 0);
|
assert(pthread_attr_setinheritsched(&attr, PTHREAD_EXPLICIT_SCHED) == 0);
|
||||||
|
|
|
@ -51,7 +51,7 @@ void * func(void * arg)
|
||||||
assert(pthread_mutex_lock(&startMx) == 0);
|
assert(pthread_mutex_lock(&startMx) == 0);
|
||||||
assert(pthread_getschedparam(pthread_self(), &policy, ¶m) == 0);
|
assert(pthread_getschedparam(pthread_self(), &policy, ¶m) == 0);
|
||||||
assert(pthread_mutex_unlock(&startMx) == 0);
|
assert(pthread_mutex_unlock(&startMx) == 0);
|
||||||
assert(policy == SCHED_OTHER);
|
assert(policy == SCHED_FIFO);
|
||||||
return (void *) (size_t)param.sched_priority;
|
return (void *) (size_t)param.sched_priority;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -61,8 +61,8 @@ main()
|
||||||
pthread_t t;
|
pthread_t t;
|
||||||
void * result = NULL;
|
void * result = NULL;
|
||||||
struct sched_param param;
|
struct sched_param param;
|
||||||
int maxPrio = sched_get_priority_max(SCHED_OTHER);
|
int maxPrio = sched_get_priority_max(SCHED_FIFO);
|
||||||
int minPrio = sched_get_priority_min(SCHED_OTHER);
|
int minPrio = sched_get_priority_min(SCHED_FIFO);
|
||||||
|
|
||||||
for (param.sched_priority = minPrio;
|
for (param.sched_priority = minPrio;
|
||||||
param.sched_priority <= maxPrio;
|
param.sched_priority <= maxPrio;
|
||||||
|
@ -70,7 +70,7 @@ main()
|
||||||
{
|
{
|
||||||
assert(pthread_mutex_lock(&startMx) == 0);
|
assert(pthread_mutex_lock(&startMx) == 0);
|
||||||
assert(pthread_create(&t, NULL, func, NULL) == 0);
|
assert(pthread_create(&t, NULL, func, NULL) == 0);
|
||||||
assert(pthread_setschedparam(t, SCHED_OTHER, ¶m) == 0);
|
assert(pthread_setschedparam(t, SCHED_FIFO, ¶m) == 0);
|
||||||
assert(pthread_mutex_unlock(&startMx) == 0);
|
assert(pthread_mutex_unlock(&startMx) == 0);
|
||||||
pthread_join(t, &result);
|
pthread_join(t, &result);
|
||||||
assert((int)(size_t)result == param.sched_priority);
|
assert((int)(size_t)result == param.sched_priority);
|
||||||
|
|
Loading…
Reference in New Issue