summaryrefslogtreecommitdiff
path: root/test/tsan/Darwin/gcd-groups-leave.mm
blob: 49fd8e2101c873e39a55d9d85f68f6d6a06945ee (plain)
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
// RUN: %clang_tsan %s -o %t -framework Foundation
// RUN: %run %t 2>&1 | FileCheck %s

#import <Foundation/Foundation.h>

#import "../test.h"

dispatch_semaphore_t sem;

long global;
long global2;

void callback(void *context) {
  global2 = 48;
  barrier_wait(&barrier);

  dispatch_semaphore_signal(sem);
}

int main() {
  fprintf(stderr, "Hello world.\n");
  barrier_init(&barrier, 2);

  dispatch_queue_t q = dispatch_queue_create("my.queue", DISPATCH_QUEUE_CONCURRENT);
  dispatch_group_t g = dispatch_group_create();
  sem = dispatch_semaphore_create(0);

  dispatch_group_enter(g);
  dispatch_async(q, ^{
    global = 47;
    dispatch_group_leave(g);
    barrier_wait(&barrier);
  });
  dispatch_group_notify(g, q, ^{
    global = 48;
    barrier_wait(&barrier);

    dispatch_semaphore_signal(sem);
  });
  dispatch_semaphore_wait(sem, DISPATCH_TIME_FOREVER);

  dispatch_group_enter(g);
  dispatch_async(q, ^{
    global2 = 47;
    dispatch_group_leave(g);
    barrier_wait(&barrier);
  });
  dispatch_group_notify_f(g, q, NULL, &callback);
  dispatch_semaphore_wait(sem, DISPATCH_TIME_FOREVER);

  fprintf(stderr, "Done.\n");
}

// CHECK: Hello world.
// CHECK-NOT: WARNING: ThreadSanitizer
// CHECK: Done.