blob: 899a1937c26a9acdec03e4e0c7d82d26c6cfe67b (
plain) (
blame)
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
|
// Test minitrace with multiple threads.
#include <inttypes.h>
#include <string.h>
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include "minitrace.h"
// Does some meaningless work.
int work(int cycles) {
int a = cycles;
for (int i = 0; i < cycles; i++) {
a ^= 373;
a = (a << 13) | (a >> (32 - 13));
}
return a;
}
void *worker_thread(void *param) {
int id = (int)(intptr_t)param;
char temp[256]; sprintf(temp, "Worker Thread %i", id);
MTR_META_THREAD_NAME(temp);
int x = 0;
for (int i = 0; i < 32; i++) {
MTR_BEGIN_I(__FILE__, "Worker", "ID", id);
x += work((rand() & 0x7fff) * 1000);
MTR_END(__FILE__, "Worker");
}
return (void *)(intptr_t)x;
}
void phase2() {
for (int i = 0; i < 10000; i++) {
MTR_BEGIN_FUNC();
MTR_END_FUNC();
}
}
int main() {
int i;
mtr_init("mt_trace.json");
MTR_META_PROCESS_NAME("Multithreaded Test");
MTR_META_THREAD_NAME("Main Thread");
MTR_BEGIN_FUNC();
#define NUMT 8
pthread_t threads[NUMT];
for (i = 0; i < NUMT; i++) {
pthread_create(&threads[i], 0, &worker_thread, (void *)(intptr_t)i);
}
for (i = 0; i < NUMT; i++) {
pthread_join(threads[i], 0);
}
phase2();
MTR_END_FUNC();
mtr_shutdown();
return 0;
}
|
