1// RUN: %clang_tsan %s -o %t -framework Foundation
2// RUN: %env_tsan_opts=ignore_interceptors_accesses=1 %run %t 2>&1 | FileCheck %s
3
4#import <Foundation/Foundation.h>
5#import <xpc/xpc.h>
6
7long global;
8
9int main(int argc, const char *argv[]) {
10  @autoreleasepool {
11    NSLog(@"Hello world.");
12
13    dispatch_queue_t server_q = dispatch_queue_create("server.queue", DISPATCH_QUEUE_CONCURRENT);
14    dispatch_queue_t client_q = dispatch_queue_create("client.queue", DISPATCH_QUEUE_CONCURRENT);
15
16    xpc_connection_t server_conn = xpc_connection_create(NULL, server_q);
17
18    global = 42;
19
20    xpc_connection_set_event_handler(server_conn, ^(xpc_object_t client) {
21      NSLog(@"global = %ld", global);
22      NSLog(@"server event handler, client = %@", client);
23
24      if (client == XPC_ERROR_CONNECTION_INTERRUPTED || client == XPC_ERROR_CONNECTION_INVALID) {
25        return;
26      }
27      xpc_connection_set_event_handler(client, ^(xpc_object_t object) {
28        NSLog(@"received message: %@", object);
29
30        xpc_object_t reply = xpc_dictionary_create_reply(object);
31        if (!reply)
32          return;
33        xpc_dictionary_set_string(reply, "reply", "value");
34
35        xpc_connection_t remote = xpc_dictionary_get_remote_connection(object);
36        xpc_connection_send_message(remote, reply);
37      });
38
39      xpc_connection_resume(client);
40    });
41    xpc_connection_resume(server_conn);
42    xpc_endpoint_t endpoint = xpc_endpoint_create(server_conn);
43
44    xpc_connection_t client_conn = xpc_connection_create_from_endpoint(endpoint);
45    xpc_connection_set_event_handler(client_conn, ^(xpc_object_t event) {
46      NSLog(@"client event handler, event = %@", event);
47    });
48
49    xpc_object_t msg = xpc_dictionary_create(NULL, NULL, 0);
50    xpc_dictionary_set_string(msg, "hello", "world");
51    NSLog(@"sending message: %@", msg);
52
53    xpc_connection_send_message_with_reply(
54        client_conn, msg, client_q, ^(xpc_object_t object) {
55          NSLog(@"received reply: %@", object);
56
57          xpc_connection_cancel(client_conn);
58          xpc_connection_cancel(server_conn);
59
60          dispatch_sync(dispatch_get_main_queue(), ^{
61            CFRunLoopStop(CFRunLoopGetCurrent());
62          });
63        });
64    xpc_connection_resume(client_conn);
65
66    CFRunLoopRun();
67
68    NSLog(@"Done.");
69  }
70  return 0;
71}
72
73// CHECK: Done.
74// CHECK-NOT: WARNING: ThreadSanitizer
75