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
|
#include <stdlib.h>
#include <dlfcn.h>
#include <stdio.h>
#include "vtv_utils.h"
#include "vtv_rts.h"
#include "pthread.h"
#define NUM_REPEATS 10
#define NUM_THREADS 10
#define NUM_SOS 100
#define NUM_SOS_PER_THREAD (NUM_SOS/NUM_THREADS)
typedef void (*voidfn)(void);
int failures = 0;
void
__vtv_verify_fail (void **data_set_ptr, const void *vtbl_pointer)
{
failures++;
return;
}
void do_dlopen(int so_num)
{
char so_name [sizeof("soxxx.so")];
sprintf(so_name, "so%d.so", so_num);
// printf("dl-opening %s\n", so_name);
void * dlhandle = dlopen(so_name, RTLD_NOW);
if (!dlhandle)
{
fprintf(stderr, "dlopen so:%s error: %s\n", so_name, dlerror());
exit(1);
}
char so_entry [sizeof("so_entry_xxx")];
sprintf(so_entry, "so_entry_%d", so_num);
voidfn so_entry_fn = (voidfn)dlsym(dlhandle, so_entry);
if (!so_entry_fn)
{
fprintf(stderr, "so:%s dlsym error: %s\n", so_name, dlerror());
exit(2);
}
so_entry_fn();
dlclose(dlhandle);
}
volatile int threads_completed_it = 0;
volatile int current_wave = -1;
void * do_dlopens(void * ptid)
{
for (int k = 0; k < NUM_REPEATS; k++)
{
for (int i = 0; i < NUM_SOS_PER_THREAD; i++)
{
while (current_wave < (k*NUM_SOS_PER_THREAD + i)) /* from 0 to 99 */
;
do_dlopen((NUM_SOS_PER_THREAD * *(int *)ptid) + i);
int old_value;
do {
old_value = threads_completed_it;
} while (!__sync_bool_compare_and_swap(&threads_completed_it, old_value, old_value + 1));
if (old_value == (NUM_THREADS - 1)) // Only one thread will do this.
{
threads_completed_it = 0;
printf("%c%d", 13, current_wave + 1);
fflush(stdout);
current_wave++;
}
}
}
return NULL;
}
int main()
{
pthread_t thread_ids[NUM_THREADS];
int thread_nids[NUM_THREADS];
for (int t = 0; t < NUM_THREADS; t++ )
{
thread_nids[t] = t;
if (pthread_create(&thread_ids[t], NULL, do_dlopens, &thread_nids[t]) != 0)
{
printf("failed pthread_create\n");
exit(1);
}
}
current_wave = 0; // start the work on the other threads
for (int t = 0; t < NUM_THREADS; t++)
if (pthread_join(thread_ids[t], NULL) != 0)
{
printf("failed pthread_join\n");
exit(2);
}
printf("\n");
return 0;
}
|
