1 | // RUN: %clangxx_tsan -O1 %s -o %t |
2 | // RUN: %run %t 2>&1 | FileCheck %s |
3 | // RUN: %run %t arg 2>&1 | FileCheck %s |
4 | #include "java.h" |
5 | |
6 | jptr varaddr1_old; |
7 | jptr varaddr2_old; |
8 | jptr lockaddr1_old; |
9 | jptr lockaddr2_old; |
10 | jptr varaddr1_new; |
11 | jptr varaddr2_new; |
12 | jptr lockaddr1_new; |
13 | jptr lockaddr2_new; |
14 | |
15 | void *Thread(void *p) { |
16 | barrier_wait(barrier: &barrier); |
17 | __tsan_java_mutex_lock(addr: lockaddr1_new); |
18 | *(char*)varaddr1_new = 43; |
19 | __tsan_java_mutex_unlock(addr: lockaddr1_new); |
20 | __tsan_java_mutex_lock(addr: lockaddr2_new); |
21 | *(char*)varaddr2_new = 43; |
22 | __tsan_java_mutex_unlock(addr: lockaddr2_new); |
23 | return 0; |
24 | } |
25 | |
26 | int main(int argc, char **argv) { |
27 | barrier_init(barrier: &barrier, count: 2); |
28 | int const kHeapSize = 1024 * 1024; |
29 | void *jheap = malloc(size: kHeapSize); |
30 | jheap = (char*)jheap + 8; |
31 | __tsan_java_init(heap_begin: (jptr)jheap, heap_size: kHeapSize); |
32 | const int kBlockSize = 64; |
33 | int const kMove = 32; |
34 | varaddr1_old = (jptr)jheap; |
35 | lockaddr1_old = (jptr)jheap + 1; |
36 | varaddr2_old = (jptr)jheap + kBlockSize - 1; |
37 | lockaddr2_old = (jptr)jheap + kBlockSize - 16; |
38 | varaddr1_new = varaddr1_old + kMove; |
39 | lockaddr1_new = lockaddr1_old + kMove; |
40 | varaddr2_new = varaddr2_old + kMove; |
41 | lockaddr2_new = lockaddr2_old + kMove; |
42 | if (argc > 1) { |
43 | // Move memory backwards. |
44 | varaddr1_old += kMove; |
45 | lockaddr1_old += kMove; |
46 | varaddr2_old += kMove; |
47 | lockaddr2_old += kMove; |
48 | varaddr1_new -= kMove; |
49 | lockaddr1_new -= kMove; |
50 | varaddr2_new -= kMove; |
51 | lockaddr2_new -= kMove; |
52 | } |
53 | __tsan_java_alloc(ptr: varaddr1_old, size: kBlockSize); |
54 | |
55 | pthread_t th; |
56 | pthread_create(newthread: &th, attr: 0, start_routine: Thread, arg: 0); |
57 | |
58 | __tsan_java_mutex_lock(addr: lockaddr1_old); |
59 | *(char*)varaddr1_old = 43; |
60 | __tsan_java_mutex_unlock(addr: lockaddr1_old); |
61 | __tsan_java_mutex_lock(addr: lockaddr2_old); |
62 | *(char*)varaddr2_old = 43; |
63 | __tsan_java_mutex_unlock(addr: lockaddr2_old); |
64 | |
65 | __tsan_java_move(src: varaddr1_old, dst: varaddr1_new, size: kBlockSize); |
66 | barrier_wait(barrier: &barrier); |
67 | pthread_join(th: th, thread_return: 0); |
68 | __tsan_java_free(ptr: varaddr1_new, size: kBlockSize); |
69 | fprintf(stderr, format: "DONE\n" ); |
70 | return __tsan_java_fini(); |
71 | } |
72 | |
73 | // CHECK-NOT: WARNING: ThreadSanitizer: data race |
74 | // CHECK: DONE |
75 | |