123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162 |
- #include "test.h"
- #include <stdio.h>
- #include <stdlib.h>
- #define MAX_COUNT OS_MAX_SIMUL_THREADS
- static sem_t s;
- static void *
- thr (void * arg)
- {
- if ((int) arg == 5)
- {
-
-
- assert(sem_wait(&s) == -1);
- assert(errno == EINTR);
- }
- else
- {
-
- assert(sem_wait(&s) == 0);
- }
- return NULL;
- }
- int pthread_test_semaphore4(void)
- {
- int value = 0;
- int i;
- pthread_t t[MAX_COUNT+1];
- assert(sem_init(&s, PTHREAD_PROCESS_PRIVATE, 0) == 0);
- assert(sem_getvalue(&s, &value) == 0);
- assert(value == 0);
- for (i = 1; i <= MAX_COUNT; i++)
- {
- assert(pthread_create(&t[i], NULL, thr, (void *)i) == 0);
- do
- {
- sched_yield();
- assert(sem_getvalue(&s, &value) == 0);
- }
- while (value != -i);
- assert(-value == i);
- }
- assert(sem_getvalue(&s, &value) == 0);
- assert(-value == MAX_COUNT);
- assert(pthread_cancel(t[5]) == 0);
- {
- int result;
- assert(pthread_join(t[5], (void **) &result) == 0);
- }
- assert(sem_getvalue(&s, &value) == 0);
- assert(-value == (MAX_COUNT - 1));
- for (i = MAX_COUNT - 2; i >= 0; i--)
- {
- assert(sem_post(&s) == 0);
- assert(sem_getvalue(&s, &value) == 0);
- assert(-value == i);
- }
- for (i = 1; i <= MAX_COUNT; i++)
- {
- if (i != 5)
- assert(pthread_join(t[i], NULL) == 0);
- }
- assert(sem_destroy(&s) == 0);
- return 0;
- }
|