diff options
Diffstat (limited to 'test/tsan/race_on_read.cc')
-rw-r--r-- | test/tsan/race_on_read.cc | 20 |
1 files changed, 12 insertions, 8 deletions
diff --git a/test/tsan/race_on_read.cc b/test/tsan/race_on_read.cc index 1ec0522b9035..d388bbacde5b 100644 --- a/test/tsan/race_on_read.cc +++ b/test/tsan/race_on_read.cc @@ -1,31 +1,35 @@ // RUN: %clangxx_tsan -O1 %s -o %t && %deflake %run %t | FileCheck %s -#include <pthread.h> -#include <stdio.h> -#include <unistd.h> +#include "test.h" #include <sys/types.h> #include <sys/stat.h> #include <fcntl.h> -#include <unistd.h> #include <errno.h> int fd; char buf; -void *Thread(void *x) { - sleep(1); +void *Thread1(void *x) { + barrier_wait(&barrier); read(fd, &buf, 1); return NULL; } +void *Thread2(void *x) { + read(fd, &buf, 1); + barrier_wait(&barrier); + return NULL; +} + int main() { + barrier_init(&barrier, 2); fd = open("/dev/random", O_RDONLY); if (fd < 0) { fprintf(stderr, "failed to open /dev/random (%d)\n", errno); return 1; } pthread_t t[2]; - pthread_create(&t[0], NULL, Thread, NULL); - pthread_create(&t[1], NULL, Thread, NULL); + pthread_create(&t[0], NULL, Thread1, NULL); + pthread_create(&t[1], NULL, Thread2, NULL); pthread_join(t[0], NULL); pthread_join(t[1], NULL); close(fd); |