This is an archive of the discontinued LLVM Phabricator instance.

Show First 20 Lines • Show All 48 Lines • ▼ Show 20 Lines	while (!stop) {
}		}
// If you add more actions, update kActions in main.		// If you add more actions, update kActions in main.
}		}
return NULL;		return NULL;
}		}

int main() {		int main() {
ANNOTATE_BENIGN_RACE(stop);		ANNOTATE_BENIGN_RACE(stop);
if (pipe2(fds, O_NONBLOCK))		if (pipe(fds))
exit((perror("pipe2"), 1));		exit((perror("pipe"), 1));
		if (fcntl(fds[0], F_SETFL, O_NONBLOCK))
		exit((perror("fcntl"), 1));
		if (fcntl(fds[1], F_SETFL, O_NONBLOCK))
		exit((perror("fcntl"), 1));
const int kActions = 9;		const int kActions = 9;
const int kMultiplier = 4;		const int kMultiplier = 4;
pthread_t t[kActions * kMultiplier];		pthread_t t[kActions * kMultiplier];
for (int i = 0; i < kActions * kMultiplier; i++)		for (int i = 0; i < kActions * kMultiplier; i++)
pthread_create(&t[i], NULL, Thread, (void *)(long)(i % kActions));		pthread_create(&t[i], NULL, Thread, (void *)(long)(i % kActions));
sleep(5);		sleep(5);
stop = 1;		stop = 1;
for (int i = 0; i < kActions * kMultiplier; i++)		for (int i = 0; i < kActions * kMultiplier; i++)
pthread_join(t[i], NULL);		pthread_join(t[i], NULL);
fprintf(stderr, "DONE\n");		fprintf(stderr, "DONE\n");
return 0;		return 0;
}		}

// CHECK-NOT: ThreadSanitizer:		// CHECK-NOT: ThreadSanitizer:
// CHECK: DONE		// CHECK: DONE
// CHECK-NOT: ThreadSanitizer:		// CHECK-NOT: ThreadSanitizer:

tsan: don't use pipe2 in testsClosedPublic