123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235 |
- #include "test.h"
- enum
- {
- NUMTHREADS = 1
- };
- typedef struct bag_t_ bag_t;
- struct bag_t_
- {
- int threadnum;
- int started;
-
- };
- static bag_t threadbag[NUMTHREADS + 1];
- static pthread_mutex_t waitLock = PTHREAD_MUTEX_INITIALIZER;
- static void *
- mythread(void * arg)
- {
- bag_t * bag = (bag_t *) arg;
- assert(bag == &threadbag[bag->threadnum]);
- assert(bag->started == 0);
- bag->started = 1;
-
- assert(pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL) == 0);
- switch (bag->threadnum % 2)
- {
- case 0:
- assert(pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL) == 0);
- break;
- case 1:
- assert(pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED, NULL) == 0);
- break;
- }
- #if defined(__cplusplus)
- try
- #endif
- {
-
- assert(pthread_mutex_lock(&waitLock) == 0);
- assert(pthread_mutex_unlock(&waitLock) == 0);
- sched_yield();
- for (;;)
- {
- pthread_testcancel();
- sched_yield();
- }
- }
- #if defined(__cplusplus)
- catch (...)
- {
-
- }
- #endif
-
- return 0;
- }
- int pthread_test_cancel2()
- {
- int failed = 0;
- int i;
- pthread_t t[NUMTHREADS + 1];
- waitLock = PTHREAD_MUTEX_INITIALIZER;
- assert((t[0] = pthread_self()).p != NULL);
- assert(pthread_mutex_lock(&waitLock) == 0);
- for (i = 1; i <= NUMTHREADS; i++)
- {
- threadbag[i].started = 0;
- threadbag[i].threadnum = i;
- assert(pthread_create(&t[i], NULL, mythread, (void *) &threadbag[i]) == 0);
- }
-
- pte_osThreadSleep(500);
- assert(pthread_mutex_unlock(&waitLock) == 0);
- pte_osThreadSleep(500);
- for (i = 1; i <= NUMTHREADS; i++)
- {
- assert(pthread_cancel(t[i]) == 0);
- }
-
- pte_osThreadSleep(NUMTHREADS * 100);
-
- for (i = 1; i <= NUMTHREADS; i++)
- {
- if (!threadbag[i].started)
- {
- failed |= !threadbag[i].started;
- }
- }
- assert(!failed);
-
- failed = 0;
- for (i = 1; i <= NUMTHREADS; i++)
- {
- int fail = 0;
- int result = 0;
- assert(pthread_join(t[i], (void **) &result) == 0);
- fail = (result != (int) PTHREAD_CANCELED);
- failed |= fail;
- }
- assert(!failed);
- assert(pthread_mutex_destroy(&waitLock) == 0);
-
- return 0;
- }
|