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

source code of compiler-rt/test/tsan/Darwin/xpc.mm