Lines Matching full:sfd
19 int sfd[4]; member
136 write(ctx->sfd[1], "w", 1); in emitter_entry1()
148 write(ctx->sfd[1], "w", 1); in emitter_entry2()
149 write(ctx->sfd[3], "w", 1); in emitter_entry2()
166 int sfd[2]; in TEST() local
169 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, sfd), 0); in TEST()
175 ASSERT_EQ(epoll_ctl(efd, EPOLL_CTL_ADD, sfd[0], &e), 0); in TEST()
177 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
183 close(sfd[0]); in TEST()
184 close(sfd[1]); in TEST()
197 int sfd[2]; in TEST() local
200 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, sfd), 0); in TEST()
206 ASSERT_EQ(epoll_ctl(efd, EPOLL_CTL_ADD, sfd[0], &e), 0); in TEST()
208 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
214 close(sfd[0]); in TEST()
215 close(sfd[1]); in TEST()
228 int sfd[4]; in TEST() local
231 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[0]), 0); in TEST()
232 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[2]), 0); in TEST()
238 ASSERT_EQ(epoll_ctl(efd, EPOLL_CTL_ADD, sfd[0], events), 0); in TEST()
241 ASSERT_EQ(epoll_ctl(efd, EPOLL_CTL_ADD, sfd[2], events), 0); in TEST()
243 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
244 ASSERT_EQ(write(sfd[3], "w", 1), 1); in TEST()
250 close(sfd[0]); in TEST()
251 close(sfd[1]); in TEST()
252 close(sfd[2]); in TEST()
253 close(sfd[3]); in TEST()
266 int sfd[4]; in TEST() local
269 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[0]), 0); in TEST()
270 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[2]), 0); in TEST()
276 ASSERT_EQ(epoll_ctl(efd, EPOLL_CTL_ADD, sfd[0], events), 0); in TEST()
279 ASSERT_EQ(epoll_ctl(efd, EPOLL_CTL_ADD, sfd[2], events), 0); in TEST()
281 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
282 ASSERT_EQ(write(sfd[3], "w", 1), 1); in TEST()
288 close(sfd[0]); in TEST()
289 close(sfd[1]); in TEST()
290 close(sfd[2]); in TEST()
291 close(sfd[3]); in TEST()
304 int sfd[2]; in TEST() local
308 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[0]), 0); in TEST()
314 ASSERT_EQ(epoll_ctl(efd, EPOLL_CTL_ADD, sfd[0], &e), 0); in TEST()
316 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
329 close(sfd[0]); in TEST()
330 close(sfd[1]); in TEST()
343 int sfd[2]; in TEST() local
347 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[0]), 0); in TEST()
353 ASSERT_EQ(epoll_ctl(efd, EPOLL_CTL_ADD, sfd[0], &e), 0); in TEST()
355 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
368 close(sfd[0]); in TEST()
369 close(sfd[1]); in TEST()
383 int sfd[4]; in TEST() local
387 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[0]), 0); in TEST()
388 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[2]), 0); in TEST()
394 ASSERT_EQ(epoll_ctl(efd, EPOLL_CTL_ADD, sfd[0], events), 0); in TEST()
397 ASSERT_EQ(epoll_ctl(efd, EPOLL_CTL_ADD, sfd[2], events), 0); in TEST()
399 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
400 ASSERT_EQ(write(sfd[3], "w", 1), 1); in TEST()
413 close(sfd[0]); in TEST()
414 close(sfd[1]); in TEST()
415 close(sfd[2]); in TEST()
416 close(sfd[3]); in TEST()
429 int sfd[4]; in TEST() local
433 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[0]), 0); in TEST()
434 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[2]), 0); in TEST()
440 ASSERT_EQ(epoll_ctl(efd, EPOLL_CTL_ADD, sfd[0], events), 0); in TEST()
443 ASSERT_EQ(epoll_ctl(efd, EPOLL_CTL_ADD, sfd[2], events), 0); in TEST()
445 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
446 ASSERT_EQ(write(sfd[3], "w", 1), 1); in TEST()
459 close(sfd[0]); in TEST()
460 close(sfd[1]); in TEST()
461 close(sfd[2]); in TEST()
462 close(sfd[3]); in TEST()
480 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
486 ASSERT_EQ(epoll_ctl(ctx.efd[0], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
504 close(ctx.sfd[0]); in TEST()
505 close(ctx.sfd[1]); in TEST()
523 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
529 ASSERT_EQ(epoll_ctl(ctx.efd[0], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
547 close(ctx.sfd[0]); in TEST()
548 close(ctx.sfd[1]); in TEST()
566 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[0]), 0); in TEST()
567 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[2]), 0); in TEST()
573 ASSERT_EQ(epoll_ctl(ctx.efd[0], EPOLL_CTL_ADD, ctx.sfd[0], events), 0); in TEST()
576 ASSERT_EQ(epoll_ctl(ctx.efd[0], EPOLL_CTL_ADD, ctx.sfd[2], events), 0); in TEST()
594 close(ctx.sfd[0]); in TEST()
595 close(ctx.sfd[1]); in TEST()
596 close(ctx.sfd[2]); in TEST()
597 close(ctx.sfd[3]); in TEST()
615 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[0]), 0); in TEST()
616 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[2]), 0); in TEST()
622 ASSERT_EQ(epoll_ctl(ctx.efd[0], EPOLL_CTL_ADD, ctx.sfd[0], events), 0); in TEST()
625 ASSERT_EQ(epoll_ctl(ctx.efd[0], EPOLL_CTL_ADD, ctx.sfd[2], events), 0); in TEST()
643 close(ctx.sfd[0]); in TEST()
644 close(ctx.sfd[1]); in TEST()
645 close(ctx.sfd[2]); in TEST()
646 close(ctx.sfd[3]); in TEST()
664 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
670 ASSERT_EQ(epoll_ctl(ctx.efd[0], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
688 close(ctx.sfd[0]); in TEST()
689 close(ctx.sfd[1]); in TEST()
707 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
713 ASSERT_EQ(epoll_ctl(ctx.efd[0], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
731 close(ctx.sfd[0]); in TEST()
732 close(ctx.sfd[1]); in TEST()
750 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[0]), 0); in TEST()
751 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[2]), 0); in TEST()
757 ASSERT_EQ(epoll_ctl(ctx.efd[0], EPOLL_CTL_ADD, ctx.sfd[0], events), 0); in TEST()
760 ASSERT_EQ(epoll_ctl(ctx.efd[0], EPOLL_CTL_ADD, ctx.sfd[2], events), 0); in TEST()
778 close(ctx.sfd[0]); in TEST()
779 close(ctx.sfd[1]); in TEST()
780 close(ctx.sfd[2]); in TEST()
781 close(ctx.sfd[3]); in TEST()
799 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[0]), 0); in TEST()
800 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[2]), 0); in TEST()
806 ASSERT_EQ(epoll_ctl(ctx.efd[0], EPOLL_CTL_ADD, ctx.sfd[0], events), 0); in TEST()
809 ASSERT_EQ(epoll_ctl(ctx.efd[0], EPOLL_CTL_ADD, ctx.sfd[2], events), 0); in TEST()
827 close(ctx.sfd[0]); in TEST()
828 close(ctx.sfd[1]); in TEST()
829 close(ctx.sfd[2]); in TEST()
830 close(ctx.sfd[3]); in TEST()
845 int sfd[2]; in TEST() local
848 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, sfd), 0); in TEST()
857 ASSERT_EQ(epoll_ctl(efd[1], EPOLL_CTL_ADD, sfd[0], &e), 0); in TEST()
862 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
869 close(sfd[0]); in TEST()
870 close(sfd[1]); in TEST()
885 int sfd[2]; in TEST() local
888 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, sfd), 0); in TEST()
897 ASSERT_EQ(epoll_ctl(efd[1], EPOLL_CTL_ADD, sfd[0], &e), 0); in TEST()
902 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
909 close(sfd[0]); in TEST()
910 close(sfd[1]); in TEST()
925 int sfd[2]; in TEST() local
928 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, sfd), 0); in TEST()
937 ASSERT_EQ(epoll_ctl(efd[1], EPOLL_CTL_ADD, sfd[0], &e), 0); in TEST()
942 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
949 close(sfd[0]); in TEST()
950 close(sfd[1]); in TEST()
965 int sfd[2]; in TEST() local
968 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, sfd), 0); in TEST()
977 ASSERT_EQ(epoll_ctl(efd[1], EPOLL_CTL_ADD, sfd[0], &e), 0); in TEST()
982 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
989 close(sfd[0]); in TEST()
990 close(sfd[1]); in TEST()
1005 int sfd[2]; in TEST() local
1009 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, sfd), 0); in TEST()
1018 ASSERT_EQ(epoll_ctl(efd[1], EPOLL_CTL_ADD, sfd[0], &e), 0); in TEST()
1023 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
1037 close(sfd[0]); in TEST()
1038 close(sfd[1]); in TEST()
1053 int sfd[2]; in TEST() local
1057 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, sfd), 0); in TEST()
1066 ASSERT_EQ(epoll_ctl(efd[1], EPOLL_CTL_ADD, sfd[0], &e), 0); in TEST()
1071 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
1085 close(sfd[0]); in TEST()
1086 close(sfd[1]); in TEST()
1101 int sfd[2]; in TEST() local
1105 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, sfd), 0); in TEST()
1114 ASSERT_EQ(epoll_ctl(efd[1], EPOLL_CTL_ADD, sfd[0], &e), 0); in TEST()
1119 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
1133 close(sfd[0]); in TEST()
1134 close(sfd[1]); in TEST()
1149 int sfd[2]; in TEST() local
1153 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, sfd), 0); in TEST()
1162 ASSERT_EQ(epoll_ctl(efd[1], EPOLL_CTL_ADD, sfd[0], &e), 0); in TEST()
1167 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
1181 close(sfd[0]); in TEST()
1182 close(sfd[1]); in TEST()
1202 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
1211 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
1233 close(ctx.sfd[0]); in TEST()
1234 close(ctx.sfd[1]); in TEST()
1254 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
1263 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
1285 close(ctx.sfd[0]); in TEST()
1286 close(ctx.sfd[1]); in TEST()
1306 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
1315 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
1337 close(ctx.sfd[0]); in TEST()
1338 close(ctx.sfd[1]); in TEST()
1358 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
1367 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
1389 close(ctx.sfd[0]); in TEST()
1390 close(ctx.sfd[1]); in TEST()
1410 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
1419 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
1440 close(ctx.sfd[0]); in TEST()
1441 close(ctx.sfd[1]); in TEST()
1461 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
1470 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
1491 close(ctx.sfd[0]); in TEST()
1492 close(ctx.sfd[1]); in TEST()
1512 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
1521 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
1542 close(ctx.sfd[0]); in TEST()
1543 close(ctx.sfd[1]); in TEST()
1563 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
1572 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
1593 close(ctx.sfd[0]); in TEST()
1594 close(ctx.sfd[1]); in TEST()
1614 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
1623 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
1645 close(ctx.sfd[0]); in TEST()
1646 close(ctx.sfd[1]); in TEST()
1666 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
1675 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
1697 close(ctx.sfd[0]); in TEST()
1698 close(ctx.sfd[1]); in TEST()
1718 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
1727 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
1749 close(ctx.sfd[0]); in TEST()
1750 close(ctx.sfd[1]); in TEST()
1770 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
1779 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
1801 close(ctx.sfd[0]); in TEST()
1802 close(ctx.sfd[1]); in TEST()
1823 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
1832 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
1858 close(ctx.sfd[0]); in TEST()
1859 close(ctx.sfd[1]); in TEST()
1880 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
1889 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
1915 close(ctx.sfd[0]); in TEST()
1916 close(ctx.sfd[1]); in TEST()
1937 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
1946 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
1972 close(ctx.sfd[0]); in TEST()
1973 close(ctx.sfd[1]); in TEST()
1994 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
2003 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
2029 close(ctx.sfd[0]); in TEST()
2030 close(ctx.sfd[1]); in TEST()
2050 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
2059 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
2081 close(ctx.sfd[0]); in TEST()
2082 close(ctx.sfd[1]); in TEST()
2102 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
2111 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
2133 close(ctx.sfd[0]); in TEST()
2134 close(ctx.sfd[1]); in TEST()
2154 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
2163 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
2185 close(ctx.sfd[0]); in TEST()
2186 close(ctx.sfd[1]); in TEST()
2206 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
2215 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
2237 close(ctx.sfd[0]); in TEST()
2238 close(ctx.sfd[1]); in TEST()
2259 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
2268 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
2294 close(ctx.sfd[0]); in TEST()
2295 close(ctx.sfd[1]); in TEST()
2315 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
2324 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
2346 close(ctx.sfd[0]); in TEST()
2347 close(ctx.sfd[1]); in TEST()
2368 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
2377 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
2403 close(ctx.sfd[0]); in TEST()
2404 close(ctx.sfd[1]); in TEST()
2424 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
2433 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
2455 close(ctx.sfd[0]); in TEST()
2456 close(ctx.sfd[1]); in TEST()
2471 int sfd[4]; in TEST() local
2474 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[0]), 0); in TEST()
2475 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[2]), 0); in TEST()
2487 ASSERT_EQ(epoll_ctl(efd[1], EPOLL_CTL_ADD, sfd[0], events), 0); in TEST()
2490 ASSERT_EQ(epoll_ctl(efd[2], EPOLL_CTL_ADD, sfd[2], events), 0); in TEST()
2498 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
2499 ASSERT_EQ(write(sfd[3], "w", 1), 1); in TEST()
2507 close(sfd[0]); in TEST()
2508 close(sfd[1]); in TEST()
2509 close(sfd[2]); in TEST()
2510 close(sfd[3]); in TEST()
2525 int sfd[4]; in TEST() local
2528 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[0]), 0); in TEST()
2529 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[2]), 0); in TEST()
2541 ASSERT_EQ(epoll_ctl(efd[1], EPOLL_CTL_ADD, sfd[0], events), 0); in TEST()
2544 ASSERT_EQ(epoll_ctl(efd[2], EPOLL_CTL_ADD, sfd[2], events), 0); in TEST()
2552 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
2553 ASSERT_EQ(write(sfd[3], "w", 1), 1); in TEST()
2561 close(sfd[0]); in TEST()
2562 close(sfd[1]); in TEST()
2563 close(sfd[2]); in TEST()
2564 close(sfd[3]); in TEST()
2579 int sfd[4]; in TEST() local
2583 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[0]), 0); in TEST()
2584 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[2]), 0); in TEST()
2596 ASSERT_EQ(epoll_ctl(efd[1], EPOLL_CTL_ADD, sfd[0], events), 0); in TEST()
2599 ASSERT_EQ(epoll_ctl(efd[2], EPOLL_CTL_ADD, sfd[2], events), 0); in TEST()
2607 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
2608 ASSERT_EQ(write(sfd[3], "w", 1), 1); in TEST()
2623 close(sfd[0]); in TEST()
2624 close(sfd[1]); in TEST()
2625 close(sfd[2]); in TEST()
2626 close(sfd[3]); in TEST()
2641 int sfd[4]; in TEST() local
2645 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[0]), 0); in TEST()
2646 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &sfd[2]), 0); in TEST()
2658 ASSERT_EQ(epoll_ctl(efd[1], EPOLL_CTL_ADD, sfd[0], events), 0); in TEST()
2661 ASSERT_EQ(epoll_ctl(efd[2], EPOLL_CTL_ADD, sfd[2], events), 0); in TEST()
2669 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
2670 ASSERT_EQ(write(sfd[3], "w", 1), 1); in TEST()
2685 close(sfd[0]); in TEST()
2686 close(sfd[1]); in TEST()
2687 close(sfd[2]); in TEST()
2688 close(sfd[3]); in TEST()
2708 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[0]), 0); in TEST()
2709 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[2]), 0); in TEST()
2721 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
2724 ASSERT_EQ(epoll_ctl(ctx.efd[2], EPOLL_CTL_ADD, ctx.sfd[2], &e), 0); in TEST()
2750 close(ctx.sfd[0]); in TEST()
2751 close(ctx.sfd[1]); in TEST()
2752 close(ctx.sfd[2]); in TEST()
2753 close(ctx.sfd[3]); in TEST()
2773 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[0]), 0); in TEST()
2774 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[2]), 0); in TEST()
2786 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
2789 ASSERT_EQ(epoll_ctl(ctx.efd[2], EPOLL_CTL_ADD, ctx.sfd[2], &e), 0); in TEST()
2815 close(ctx.sfd[0]); in TEST()
2816 close(ctx.sfd[1]); in TEST()
2817 close(ctx.sfd[2]); in TEST()
2818 close(ctx.sfd[3]); in TEST()
2838 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[0]), 0); in TEST()
2839 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[2]), 0); in TEST()
2851 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
2854 ASSERT_EQ(epoll_ctl(ctx.efd[2], EPOLL_CTL_ADD, ctx.sfd[2], &e), 0); in TEST()
2880 close(ctx.sfd[0]); in TEST()
2881 close(ctx.sfd[1]); in TEST()
2882 close(ctx.sfd[2]); in TEST()
2883 close(ctx.sfd[3]); in TEST()
2903 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[0]), 0); in TEST()
2904 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[2]), 0); in TEST()
2916 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
2919 ASSERT_EQ(epoll_ctl(ctx.efd[2], EPOLL_CTL_ADD, ctx.sfd[2], &e), 0); in TEST()
2945 close(ctx.sfd[0]); in TEST()
2946 close(ctx.sfd[1]); in TEST()
2947 close(ctx.sfd[2]); in TEST()
2948 close(ctx.sfd[3]); in TEST()
2969 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[0]), 0); in TEST()
2970 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[2]), 0); in TEST()
2982 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
2985 ASSERT_EQ(epoll_ctl(ctx.efd[2], EPOLL_CTL_ADD, ctx.sfd[2], &e), 0); in TEST()
3015 close(ctx.sfd[0]); in TEST()
3016 close(ctx.sfd[1]); in TEST()
3017 close(ctx.sfd[2]); in TEST()
3018 close(ctx.sfd[3]); in TEST()
3039 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[0]), 0); in TEST()
3040 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, &ctx.sfd[2]), 0); in TEST()
3052 ASSERT_EQ(epoll_ctl(ctx.efd[1], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
3055 ASSERT_EQ(epoll_ctl(ctx.efd[2], EPOLL_CTL_ADD, ctx.sfd[2], &e), 0); in TEST()
3085 close(ctx.sfd[0]); in TEST()
3086 close(ctx.sfd[1]); in TEST()
3087 close(ctx.sfd[2]); in TEST()
3088 close(ctx.sfd[3]); in TEST()
3102 epoll_ctl(ctx->efd[0], EPOLL_CTL_MOD, ctx->sfd[0], &e); in epoll59_thread()
3131 ctx.sfd[0] = eventfd(1, 0); in TEST()
3132 ASSERT_GE(ctx.sfd[0], 0); in TEST()
3135 ASSERT_EQ(epoll_ctl(ctx.efd[0], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
3152 close(ctx.sfd[0]); in TEST()
3399 int sfd[2]; in TEST() local
3402 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, sfd), 0); in TEST()
3408 ASSERT_EQ(epoll_ctl(efd, EPOLL_CTL_ADD, sfd[0], &e), 0); in TEST()
3410 ASSERT_EQ(write(sfd[1], "w", 1), 1); in TEST()
3416 close(sfd[0]); in TEST()
3417 close(sfd[1]); in TEST()
3427 int sfd[2]; in TEST() local
3430 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, sfd), 0); in TEST()
3436 ASSERT_EQ(epoll_ctl(efd, EPOLL_CTL_ADD, sfd[0], &e), 0); in TEST()
3448 close(sfd[0]); in TEST()
3449 close(sfd[1]); in TEST()
3467 ASSERT_EQ(socketpair(AF_UNIX, SOCK_STREAM, 0, ctx.sfd), 0); in TEST()
3473 ASSERT_EQ(epoll_ctl(ctx.efd[0], EPOLL_CTL_ADD, ctx.sfd[0], &e), 0); in TEST()
3484 ASSERT_EQ(write(ctx.sfd[1], "w", 1), 1); in TEST()
3492 close(ctx.sfd[0]); in TEST()
3493 close(ctx.sfd[1]); in TEST()