filesystems/epoll/epoll_wakeup_test.c

23 	pthread_t waiter;
47 	pthread_kill(ctx->waiter, SIGUSR1);
489 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1a, &ctx), 0);
495 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
532 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1a, &ctx), 0);
538 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
579 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry2a, &ctx), 0);
585 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
628 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1a, &ctx), 0);
634 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
673 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1ap, &ctx), 0);
679 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
716 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1ap, &ctx), 0);
722 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
763 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry2ap, &ctx), 0);
769 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
812 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1ap, &ctx), 0);
818 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
1217 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1a, &ctx), 0);
1223 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
1269 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1a, &ctx), 0);
1275 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
1321 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1a, &ctx), 0);
1327 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
1373 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1a, &ctx), 0);
1379 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
1425 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1ap, &ctx), 0);
1431 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
1476 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1ap, &ctx), 0);
1482 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
1527 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1ap, &ctx), 0);
1533 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
1578 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1ap, &ctx), 0);
1584 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
1629 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1a, &ctx), 0);
1635 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
1681 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1o, &ctx), 0);
1687 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
1733 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1a, &ctx), 0);
1739 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
1785 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1o, &ctx), 0);
1791 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
1838 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1a, &ctx), 0);
1848 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
1895 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1o, &ctx), 0);
1905 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
1952 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1a, &ctx), 0);
1962 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
2009 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1o, &ctx), 0);
2019 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
2065 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1ap, &ctx), 0);
2071 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
2117 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1op, &ctx), 0);
2123 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
2169 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1ap, &ctx), 0);
2175 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
2221 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1op, &ctx), 0);
2227 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
2274 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1ap, &ctx), 0);
2284 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
2330 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1op, &ctx), 0);
2336 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
2383 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1ap, &ctx), 0);
2393 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
2439 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1op, &ctx), 0);
2445 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
2733 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1a, &ctx), 0);
2739 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
2798 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1a, &ctx), 0);
2804 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
2863 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1ap, &ctx), 0);
2869 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
2928 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1ap, &ctx), 0);
2934 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
2994 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1ap, &ctx), 0);
3004 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
3064 	ASSERT_EQ(pthread_create(&ctx.waiter, NULL, waiter_entry1ap, &ctx), 0);
3074 	ASSERT_EQ(pthread_join(ctx.waiter, NULL), 0);
3191 		/* Account this waiter */
3251 	/* Create waiter threads */
3461 	pthread_t waiter[2];
3476 	 * main will act as the emitter once both waiter threads are
3480 	ASSERT_EQ(pthread_create(&waiter[0], NULL, waiter_entry1a, &ctx), 0);
3481 	ASSERT_EQ(pthread_create(&waiter[1], NULL, waiter_entry1a, &ctx), 0);
3486 	ASSERT_EQ(pthread_join(waiter[0], NULL), 0);
3487 	ASSERT_EQ(pthread_join(waiter[1], NULL), 0);