Lines Matching full:emitter
474 pthread_t emitter; in TEST() local
490 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
498 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
499 pthread_kill(emitter, SIGUSR1); in TEST()
500 pthread_join(emitter, NULL); in TEST()
517 pthread_t emitter; in TEST() local
533 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
541 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
542 pthread_kill(emitter, SIGUSR1); in TEST()
543 pthread_join(emitter, NULL); in TEST()
560 pthread_t emitter; in TEST() local
580 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry2, &ctx), 0); in TEST()
588 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
589 pthread_kill(emitter, SIGUSR1); in TEST()
590 pthread_join(emitter, NULL); in TEST()
609 pthread_t emitter; in TEST() local
629 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry2, &ctx), 0); in TEST()
637 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
638 pthread_kill(emitter, SIGUSR1); in TEST()
639 pthread_join(emitter, NULL); in TEST()
658 pthread_t emitter; in TEST() local
674 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
682 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
683 pthread_kill(emitter, SIGUSR1); in TEST()
684 pthread_join(emitter, NULL); in TEST()
701 pthread_t emitter; in TEST() local
717 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
725 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
726 pthread_kill(emitter, SIGUSR1); in TEST()
727 pthread_join(emitter, NULL); in TEST()
744 pthread_t emitter; in TEST() local
764 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry2, &ctx), 0); in TEST()
772 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
773 pthread_kill(emitter, SIGUSR1); in TEST()
774 pthread_join(emitter, NULL); in TEST()
793 pthread_t emitter; in TEST() local
813 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry2, &ctx), 0); in TEST()
821 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
822 pthread_kill(emitter, SIGUSR1); in TEST()
823 pthread_join(emitter, NULL); in TEST()
1196 pthread_t emitter; in TEST() local
1218 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
1226 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
1227 pthread_kill(emitter, SIGUSR1); in TEST()
1228 pthread_join(emitter, NULL); in TEST()
1248 pthread_t emitter; in TEST() local
1270 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
1278 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
1279 pthread_kill(emitter, SIGUSR1); in TEST()
1280 pthread_join(emitter, NULL); in TEST()
1300 pthread_t emitter; in TEST() local
1322 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
1330 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
1331 pthread_kill(emitter, SIGUSR1); in TEST()
1332 pthread_join(emitter, NULL); in TEST()
1352 pthread_t emitter; in TEST() local
1374 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
1382 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
1383 pthread_kill(emitter, SIGUSR1); in TEST()
1384 pthread_join(emitter, NULL); in TEST()
1404 pthread_t emitter; in TEST() local
1426 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
1434 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
1435 pthread_kill(emitter, SIGUSR1); in TEST()
1436 pthread_join(emitter, NULL); in TEST()
1455 pthread_t emitter; in TEST() local
1477 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
1485 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
1486 pthread_kill(emitter, SIGUSR1); in TEST()
1487 pthread_join(emitter, NULL); in TEST()
1506 pthread_t emitter; in TEST() local
1528 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
1536 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
1537 pthread_kill(emitter, SIGUSR1); in TEST()
1538 pthread_join(emitter, NULL); in TEST()
1557 pthread_t emitter; in TEST() local
1579 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
1587 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
1588 pthread_kill(emitter, SIGUSR1); in TEST()
1589 pthread_join(emitter, NULL); in TEST()
1608 pthread_t emitter; in TEST() local
1630 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
1638 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
1639 pthread_kill(emitter, SIGUSR1); in TEST()
1640 pthread_join(emitter, NULL); in TEST()
1660 pthread_t emitter; in TEST() local
1682 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
1690 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
1691 pthread_kill(emitter, SIGUSR1); in TEST()
1692 pthread_join(emitter, NULL); in TEST()
1712 pthread_t emitter; in TEST() local
1734 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
1742 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
1743 pthread_kill(emitter, SIGUSR1); in TEST()
1744 pthread_join(emitter, NULL); in TEST()
1764 pthread_t emitter; in TEST() local
1786 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
1794 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
1795 pthread_kill(emitter, SIGUSR1); in TEST()
1796 pthread_join(emitter, NULL); in TEST()
1816 pthread_t emitter; in TEST() local
1839 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
1851 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
1852 pthread_kill(emitter, SIGUSR1); in TEST()
1853 pthread_join(emitter, NULL); in TEST()
1873 pthread_t emitter; in TEST() local
1896 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
1908 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
1909 pthread_kill(emitter, SIGUSR1); in TEST()
1910 pthread_join(emitter, NULL); in TEST()
1930 pthread_t emitter; in TEST() local
1953 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
1965 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
1966 pthread_kill(emitter, SIGUSR1); in TEST()
1967 pthread_join(emitter, NULL); in TEST()
1987 pthread_t emitter; in TEST() local
2010 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
2022 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
2023 pthread_kill(emitter, SIGUSR1); in TEST()
2024 pthread_join(emitter, NULL); in TEST()
2044 pthread_t emitter; in TEST() local
2066 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
2074 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
2075 pthread_kill(emitter, SIGUSR1); in TEST()
2076 pthread_join(emitter, NULL); in TEST()
2096 pthread_t emitter; in TEST() local
2118 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
2126 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
2127 pthread_kill(emitter, SIGUSR1); in TEST()
2128 pthread_join(emitter, NULL); in TEST()
2148 pthread_t emitter; in TEST() local
2170 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
2178 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
2179 pthread_kill(emitter, SIGUSR1); in TEST()
2180 pthread_join(emitter, NULL); in TEST()
2200 pthread_t emitter; in TEST() local
2222 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
2230 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
2231 pthread_kill(emitter, SIGUSR1); in TEST()
2232 pthread_join(emitter, NULL); in TEST()
2252 pthread_t emitter; in TEST() local
2275 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
2287 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
2288 pthread_kill(emitter, SIGUSR1); in TEST()
2289 pthread_join(emitter, NULL); in TEST()
2309 pthread_t emitter; in TEST() local
2331 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
2339 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
2340 pthread_kill(emitter, SIGUSR1); in TEST()
2341 pthread_join(emitter, NULL); in TEST()
2361 pthread_t emitter; in TEST() local
2384 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
2396 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
2397 pthread_kill(emitter, SIGUSR1); in TEST()
2398 pthread_join(emitter, NULL); in TEST()
2418 pthread_t emitter; in TEST() local
2440 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry1, &ctx), 0); in TEST()
2448 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
2449 pthread_kill(emitter, SIGUSR1); in TEST()
2450 pthread_join(emitter, NULL); in TEST()
2702 pthread_t emitter; in TEST() local
2734 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry2, &ctx), 0); in TEST()
2742 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
2743 pthread_kill(emitter, SIGUSR1); in TEST()
2744 pthread_join(emitter, NULL); in TEST()
2767 pthread_t emitter; in TEST() local
2799 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry2, &ctx), 0); in TEST()
2807 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
2808 pthread_kill(emitter, SIGUSR1); in TEST()
2809 pthread_join(emitter, NULL); in TEST()
2832 pthread_t emitter; in TEST() local
2864 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry2, &ctx), 0); in TEST()
2872 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
2873 pthread_kill(emitter, SIGUSR1); in TEST()
2874 pthread_join(emitter, NULL); in TEST()
2897 pthread_t emitter; in TEST() local
2929 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry2, &ctx), 0); in TEST()
2937 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
2938 pthread_kill(emitter, SIGUSR1); in TEST()
2939 pthread_join(emitter, NULL); in TEST()
2962 pthread_t emitter; in TEST() local
2995 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry2, &ctx), 0); in TEST()
3007 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
3008 pthread_kill(emitter, SIGUSR1); in TEST()
3009 pthread_join(emitter, NULL); in TEST()
3032 pthread_t emitter; in TEST() local
3065 ASSERT_EQ(pthread_create(&emitter, NULL, emitter_entry2, &ctx), 0); in TEST()
3077 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
3078 pthread_kill(emitter, SIGUSR1); in TEST()
3079 pthread_join(emitter, NULL); in TEST()
3120 pthread_t emitter; in TEST() local
3137 ASSERT_EQ(pthread_create(&emitter, NULL, epoll59_thread, &ctx), 0); in TEST()
3147 if (pthread_tryjoin_np(emitter, NULL) < 0) { in TEST()
3148 pthread_kill(emitter, SIGUSR1); in TEST()
3149 pthread_join(emitter, NULL); in TEST()
3476 * main will act as the emitter once both waiter threads are in TEST()