123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156 |
- #include "test.h"
- enum
- {
- PTW32TEST_THREAD_INIT_PRIO = 0,
- PTW32TEST_MAXPRIORITIES = 512
- };
- static pthread_barrier_t startBarrier, endBarrier;
- static void * func(void * arg)
- {
- int policy;
- int result;
- struct sched_param param;
- result = pthread_barrier_wait(&startBarrier);
- assert(result == 0 || result == PTHREAD_BARRIER_SERIAL_THREAD);
- assert(pthread_getschedparam(pthread_self(), &policy, ¶m) == 0);
- assert(policy == SCHED_OTHER);
- result = pthread_barrier_wait(&endBarrier);
- assert(result == 0 || result == PTHREAD_BARRIER_SERIAL_THREAD);
- assert(pte_osThreadGetPriority(pte_osThreadGetHandle()) == param.sched_priority);
- return (void *) param.sched_priority;
- }
- int pthread_test_priority2()
- {
- pthread_t t;
- void * result = NULL;
- int result2;
- struct sched_param param;
-
- assert(pthread_barrier_init(&startBarrier, NULL, 2) == 0);
- assert(pthread_barrier_init(&endBarrier, NULL, 2) == 0);
-
-
- for (param.sched_priority = pte_osThreadGetMinPriority();
- param.sched_priority <= pte_osThreadGetMaxPriority();
- param.sched_priority++)
- {
- assert(pthread_create(&t, NULL, func, NULL) == 0);
- assert(pthread_setschedparam(t, SCHED_OTHER, ¶m) == 0);
- result2 = pthread_barrier_wait(&startBarrier);
- assert(result2 == 0 || result2 == PTHREAD_BARRIER_SERIAL_THREAD);
- result2 = pthread_barrier_wait(&endBarrier);
- assert(result2 == 0 || result2 == PTHREAD_BARRIER_SERIAL_THREAD);
- pthread_join(t, &result);
- assert(param.sched_priority == (int)result);
- }
- assert(pthread_barrier_destroy(&startBarrier) == 0);
- assert(pthread_barrier_destroy(&endBarrier) == 0);
- return 0;
- }
|