Lines Matching refs:kqueue_fd
912 kqueue_setup(int kqueue_fd, int fd, const char *testname) in kqueue_setup() argument
927 ret = kevent(kqueue_fd, kevent_changelist, 2, kevent_eventlist, in kqueue_setup()
951 kqueue_status(int kqueue_fd, int fd, int *readable, int *writable, in kqueue_status() argument
961 ret = kevent(kqueue_fd, NULL, 0, kevent_eventlist, KQUEUE_MAX_EVENT, in kqueue_status()
1008 assert_status(int fd, int kqueue_fd, int assert_readable, in assert_status() argument
1034 if (kqueue_status(kqueue_fd, fd, &readable, &writable, &exception, in assert_status()
1069 int kqueue_fd, reader_fd, writer_fd; in test_events_outofbox() local
1078 kqueue_fd = kqueue(); in test_events_outofbox()
1079 if (kqueue_fd < 0) { in test_events_outofbox()
1085 if (kqueue_setup(kqueue_fd, reader_fd, __func__) < 0) { in test_events_outofbox()
1086 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_outofbox()
1090 if (kqueue_setup(kqueue_fd, writer_fd, __func__) < 0) { in test_events_outofbox()
1091 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_outofbox()
1101 if (assert_status(reader_fd, kqueue_fd, NOT_READABLE, NOT_WRITABLE, in test_events_outofbox()
1103 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_outofbox()
1111 if (assert_status(writer_fd, kqueue_fd, NOT_READABLE, WRITABLE, in test_events_outofbox()
1113 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_outofbox()
1117 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_outofbox()
1123 int kqueue_fd, reader_fd, writer_fd; in test_events_write_read_byte() local
1134 kqueue_fd = kqueue(); in test_events_write_read_byte()
1135 if (kqueue_fd < 0) { in test_events_write_read_byte()
1141 if (kqueue_setup(kqueue_fd, reader_fd, __func__) < 0) { in test_events_write_read_byte()
1142 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1146 if (kqueue_setup(kqueue_fd, writer_fd, __func__) < 0) { in test_events_write_read_byte()
1147 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1159 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1163 if (assert_status(reader_fd, kqueue_fd, READABLE, NOT_WRITABLE, in test_events_write_read_byte()
1165 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1172 if (assert_status(writer_fd, kqueue_fd, NOT_READABLE, WRITABLE, in test_events_write_read_byte()
1174 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1185 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1189 if (assert_status(reader_fd, kqueue_fd, NOT_READABLE, NOT_WRITABLE, in test_events_write_read_byte()
1191 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1198 if (assert_status(writer_fd, kqueue_fd, NOT_READABLE, WRITABLE, in test_events_write_read_byte()
1200 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1204 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1215 int kqueue_fd, reader_fd, writer_fd; in test_events_partial_write() local
1226 kqueue_fd = kqueue(); in test_events_partial_write()
1227 if (kqueue_fd < 0) { in test_events_partial_write()
1233 if (kqueue_setup(kqueue_fd, reader_fd, __func__) < 0) { in test_events_partial_write()
1234 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1238 if (kqueue_setup(kqueue_fd, writer_fd, __func__) < 0) { in test_events_partial_write()
1239 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1244 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1251 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1260 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1266 if (assert_status(writer_fd, kqueue_fd, NOT_READABLE, NOT_WRITABLE, in test_events_partial_write()
1268 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1273 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1281 if (assert_status(writer_fd, kqueue_fd, NOT_READABLE, WRITABLE, in test_events_partial_write()
1283 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1287 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1300 int fd, kqueue_fd; in test_events_rdwr() local
1311 kqueue_fd = kqueue(); in test_events_rdwr()
1312 if (kqueue_fd < 0) { in test_events_rdwr()
1318 if (kqueue_setup(kqueue_fd, fd, __func__) < 0) { in test_events_rdwr()
1319 cleanfifo2("testfifo", fd, kqueue_fd); in test_events_rdwr()
1327 if (assert_status(fd, kqueue_fd, NOT_READABLE, WRITABLE, in test_events_rdwr()
1329 cleanfifo2("testfifo", fd, kqueue_fd); in test_events_rdwr()
1341 cleanfifo2("testfifo", fd, kqueue_fd); in test_events_rdwr()
1345 if (assert_status(fd, kqueue_fd, READABLE, WRITABLE, NOT_EXCEPTION, in test_events_rdwr()
1347 cleanfifo2("testfifo", fd, kqueue_fd); in test_events_rdwr()
1358 cleanfifo2("testfifo", fd, kqueue_fd); in test_events_rdwr()
1362 if (assert_status(fd, kqueue_fd, NOT_READABLE, WRITABLE, in test_events_rdwr()
1364 cleanfifo2("testfifo", fd, kqueue_fd); in test_events_rdwr()
1368 cleanfifo2("testfifo", fd, kqueue_fd); in test_events_rdwr()