1 | // RUN: %clang_tsan %s -o %t |
2 | // RUN: %run %t 2>&1 | FileCheck %s --implicit-check-not='ThreadSanitizer' |
3 | |
4 | #include <dispatch/dispatch.h> |
5 | |
6 | #include <stdio.h> |
7 | |
8 | long my_global = 0; |
9 | |
10 | int main(int argc, const char *argv[]) { |
11 | fprintf(stderr, format: "Hello world.\n" ); |
12 | |
13 | dispatch_queue_t queue = dispatch_queue_create("my.queue" , DISPATCH_QUEUE_SERIAL); |
14 | dispatch_semaphore_t sem = dispatch_semaphore_create(0); |
15 | |
16 | const char *path = tempnam(NULL, pfx: "libdispatch-fd-" ); |
17 | |
18 | dispatch_io_t channel = dispatch_io_create_with_path(DISPATCH_IO_STREAM, path, O_CREAT | O_WRONLY, |
19 | 0666, queue, ^(int error) { }); |
20 | dispatch_io_set_high_water(channel, 1); |
21 | |
22 | char buf[1000]; |
23 | dispatch_data_t data = dispatch_data_create(buf, sizeof(buf), NULL, DISPATCH_DATA_DESTRUCTOR_DEFAULT); |
24 | |
25 | my_global++; |
26 | dispatch_io_write(channel, 0, data, queue, ^(bool done, dispatch_data_t remainingData, int error) { |
27 | my_global++; |
28 | dispatch_async(queue, ^{ |
29 | my_global++; |
30 | if (done) { |
31 | dispatch_semaphore_signal(sem); |
32 | } |
33 | }); |
34 | }); |
35 | |
36 | dispatch_semaphore_wait(sem, DISPATCH_TIME_FOREVER); |
37 | my_global++; |
38 | dispatch_io_close(channel, 0); |
39 | channel = dispatch_io_create_with_path(DISPATCH_IO_STREAM, path, O_RDONLY, |
40 | 0, queue, ^(int error) { }); |
41 | dispatch_io_set_high_water(channel, 1); |
42 | |
43 | my_global++; |
44 | dispatch_io_read(channel, 0, SIZE_MAX, queue, ^(bool done, dispatch_data_t remainingData, int error) { |
45 | my_global++; |
46 | dispatch_async(queue, ^{ |
47 | my_global++; |
48 | if (done) { |
49 | dispatch_semaphore_signal(sem); |
50 | } |
51 | }); |
52 | }); |
53 | |
54 | dispatch_semaphore_wait(sem, DISPATCH_TIME_FOREVER); |
55 | my_global++; |
56 | fprintf(stderr, format: "Done.\n" ); |
57 | return 0; |
58 | } |
59 | |
60 | // CHECK: Hello world. |
61 | // CHECK: Done. |
62 | |