1 // RUN: %clangxx_tsan -O1 %s -o %t && %run %t 2>&1 | FileCheck %s 2 #include "java.h" 3 4 jptr varaddr; 5 jptr lockaddr; 6 7 void *Thread(void *p) { 8 while (__atomic_load_n((int*)lockaddr, __ATOMIC_RELAXED) == 0) 9 usleep(1000); // spin-wait 10 __tsan_java_acquire(lockaddr); 11 *(int*)varaddr = 42; 12 return 0; 13 } 14 15 int main() { 16 barrier_init(&barrier, 2); 17 int const kHeapSize = 1024 * 1024; 18 jptr jheap = (jptr)malloc(kHeapSize + 8) + 8; 19 __tsan_java_init(jheap, kHeapSize); 20 const int kBlockSize = 16; 21 __tsan_java_alloc(jheap, kBlockSize); 22 varaddr = jheap; 23 lockaddr = jheap + 8; 24 pthread_t th; 25 pthread_create(&th, 0, Thread, 0); 26 *(int*)varaddr = 43; 27 __tsan_java_release(lockaddr); 28 __atomic_store_n((int*)lockaddr, 1, __ATOMIC_RELAXED); 29 pthread_join(th, 0); 30 *(int*)lockaddr = 0; 31 pthread_create(&th, 0, Thread, 0); 32 *(int*)varaddr = 43; 33 __tsan_java_release_store(lockaddr); 34 __atomic_store_n((int*)lockaddr, 1, __ATOMIC_RELAXED); 35 pthread_join(th, 0); 36 __tsan_java_free(jheap, kBlockSize); 37 fprintf(stderr, "DONE\n"); 38 return __tsan_java_fini(); 39 } 40 41 // CHECK-NOT: WARNING: ThreadSanitizer: data race 42 // CHECK: DONE 43
