1 /* Test whether assigning names to threads works properly. */
2
3
4 #include <pthread.h>
5 #include <stddef.h>
6 #include <stdio.h>
7 #include <string.h>
8 #include "../../drd/drd.h"
9
10
11 #define NUM_THREADS 10
12
13
14 static pthread_mutex_t s_mutex;
15 static pthread_cond_t s_cond;
16 static int s_counter;
17
thread_func(void * argp)18 static void* thread_func(void* argp)
19 {
20 const int thread_num = (ptrdiff_t)(argp);
21 pthread_mutex_t invalid_mutex;
22 char thread_name[32];
23
24 snprintf(thread_name, sizeof(thread_name),
25 "thread_func instance %d", thread_num + 1);
26 ANNOTATE_THREAD_NAME(thread_name);
27
28 memset(&invalid_mutex, 0xff, sizeof(invalid_mutex));
29
30 pthread_mutex_lock(&s_mutex);
31 while (s_counter != thread_num)
32 pthread_cond_wait(&s_cond, &s_mutex);
33 fprintf(stderr, "\n%s\n\n", thread_name);
34 pthread_mutex_unlock(&invalid_mutex);
35 s_counter++;
36 pthread_cond_broadcast(&s_cond);
37 pthread_mutex_unlock(&s_mutex);
38
39 return 0;
40 }
41
42
main(int arg,char ** argv)43 int main(int arg, char** argv)
44 {
45 int i;
46 pthread_t tid[NUM_THREADS];
47
48 pthread_mutex_init(&s_mutex, 0);
49 pthread_cond_init(&s_cond, 0);
50
51 for (i = 0; i < NUM_THREADS; i++)
52 pthread_create(&tid[i], 0, thread_func, (void*)(ptrdiff_t)i);
53
54 for (i = 0; i < NUM_THREADS; i++)
55 pthread_join(tid[i], 0);
56
57 pthread_cond_destroy(&s_cond);
58 pthread_mutex_destroy(&s_mutex);
59
60 return 0;
61 }
62