1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
|
/* BeginSourceFile start_stop.c
This file creates and deletes threads, so that wdb
can be tested on thread delete.
To compile:
cc -Ae +DA1.0 -g -o start_stop -lpthread start_stop.c
To run:
start_stop --normal run
start_stop 1 --waits in each thread to keep it alive.
*/
#include <unistd.h>
#include <stdlib.h>
#include <stdio.h>
#include <assert.h>
#include <pthread.h>
#define TRUE 1
#define FALSE 0
#define OUTER_LOOP_COUNT 3
#define N_THREADS 3
#define MAX_LOCAL_VAL 40
/* Uncomment to turn on debugging output */
/* #define START_DEBUG */
/* True if waiting for attach.
*/
int wait_here;
/* Thing to check for debugging purposes.
*/
int a_global = 0;
/* Thread-local storage.
*/
__thread int a_thread_local;
/* Check the results of thread-local storage.
*/
int thread_local_val[ N_THREADS ];
int val_debugger_saw[ N_THREADS ];
/* Routine for each thread to run, does nothing.
*/
void *spin( vp )
void * vp;
{
int me = (int) vp;
int i;
#ifdef START_DEBUG
printf( "== In thread %d\n", me );
#endif
a_global++;
a_thread_local = 0;
for( i = 0; i < a_global; i++ ) {
a_thread_local += i;
}
thread_local_val[ me ] = a_thread_local; /* Line 67 */
printf( "== Thread %d, a_thread_local is %d\n",
(int) vp, a_thread_local );
if( wait_here ) {
/* Extend life of thread to extend life of thread-local var.
* This makes life easier for human debugging (though you'd
* probably want to make the delay longer).
*/
sleep( 5 );
}
}
void
do_pass( pass )
int pass;
{
int i;
pthread_t t[ N_THREADS ];
int err;
for( i = 0; i < N_THREADS; i++) {
thread_local_val[i] = 0;
val_debugger_saw[i] = 0;
}
/* Start N_THREADS threads, then join them so
* that they are terminated.
*/
for( i = 0; i < N_THREADS; i++ ) {
err = pthread_create( &t[i], NULL, spin, (void *)i );
if( err != 0 ) {
printf( "== Start/stop, error in thread %d create\n", i );
}
}
for( i = 0; i < N_THREADS; i++ ) {
err = pthread_join(t[i], NULL ); /* Line 105 */
if( err != 0 ) { /* Line 106 */
printf( "== Start/stop, error in thread %d join\n", i );
}
}
i = 10; /* Line 109. Null line for setting bpts on. */
/*#ifdef START_DEBUG*/
for( i = 0; i < N_THREADS; i++) {
printf( " Local in thread %d was %d, debugger saw %d\n",
i, thread_local_val[i], val_debugger_saw[i] );
}
printf( "== Pass %d done\n", pass );
/*#endif*/
}
void
do_it()
{
/* We want to start some threads and then
* end them, and then do it again and again
*/
int i;
int dummy;
for( i = 0; i < OUTER_LOOP_COUNT; i++ ) {
do_pass( i );
dummy = i; /* Line 134, null line for setting bps on */
}
}
main( argc, argv )
int argc;
char **argv;
{
wait_here = FALSE;
if((argc > 1) && (0 != argv )) {
if( 1 == atoi( argv[1] ) )
wait_here = TRUE;
}
#ifdef START_DEBUG
printf( "== Test starting\n" );
#endif
do_it();
#ifdef START_DEBUG
printf( "== Test done\n" );
#endif
return(0);
}
/* EndSourceFile */
|
