Lines Matching refs:kqueue_fd

914 kqueue_setup(int kqueue_fd, int fd, const char *testname)  in kqueue_setup()  argument
929 ret = kevent(kqueue_fd, kevent_changelist, 2, kevent_eventlist, in kqueue_setup()
953 kqueue_status(int kqueue_fd, int fd, int *readable, int *writable, in kqueue_status() argument
963 ret = kevent(kqueue_fd, NULL, 0, kevent_eventlist, KQUEUE_MAX_EVENT, in kqueue_status()
1010 assert_status(int fd, int kqueue_fd, int assert_readable, in assert_status() argument
1036 if (kqueue_status(kqueue_fd, fd, &readable, &writable, &exception, in assert_status()
1071 int kqueue_fd, reader_fd, writer_fd; in test_events_outofbox() local
1080 kqueue_fd = kqueue(); in test_events_outofbox()
1081 if (kqueue_fd < 0) { in test_events_outofbox()
1087 if (kqueue_setup(kqueue_fd, reader_fd, __func__) < 0) { in test_events_outofbox()
1088 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_outofbox()
1092 if (kqueue_setup(kqueue_fd, writer_fd, __func__) < 0) { in test_events_outofbox()
1093 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_outofbox()
1103 if (assert_status(reader_fd, kqueue_fd, NOT_READABLE, NOT_WRITABLE, in test_events_outofbox()
1105 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_outofbox()
1113 if (assert_status(writer_fd, kqueue_fd, NOT_READABLE, WRITABLE, in test_events_outofbox()
1115 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_outofbox()
1119 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_outofbox()
1125 int kqueue_fd, reader_fd, writer_fd; in test_events_write_read_byte() local
1136 kqueue_fd = kqueue(); in test_events_write_read_byte()
1137 if (kqueue_fd < 0) { in test_events_write_read_byte()
1143 if (kqueue_setup(kqueue_fd, reader_fd, __func__) < 0) { in test_events_write_read_byte()
1144 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1148 if (kqueue_setup(kqueue_fd, writer_fd, __func__) < 0) { in test_events_write_read_byte()
1149 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1161 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1165 if (assert_status(reader_fd, kqueue_fd, READABLE, NOT_WRITABLE, in test_events_write_read_byte()
1167 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1174 if (assert_status(writer_fd, kqueue_fd, NOT_READABLE, WRITABLE, in test_events_write_read_byte()
1176 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1187 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1191 if (assert_status(reader_fd, kqueue_fd, NOT_READABLE, NOT_WRITABLE, in test_events_write_read_byte()
1193 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1200 if (assert_status(writer_fd, kqueue_fd, NOT_READABLE, WRITABLE, in test_events_write_read_byte()
1202 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1206 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1217 int kqueue_fd, reader_fd, writer_fd; in test_events_partial_write() local
1228 kqueue_fd = kqueue(); in test_events_partial_write()
1229 if (kqueue_fd < 0) { in test_events_partial_write()
1235 if (kqueue_setup(kqueue_fd, reader_fd, __func__) < 0) { in test_events_partial_write()
1236 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1240 if (kqueue_setup(kqueue_fd, writer_fd, __func__) < 0) { in test_events_partial_write()
1241 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1246 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1253 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1262 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1268 if (assert_status(writer_fd, kqueue_fd, NOT_READABLE, NOT_WRITABLE, in test_events_partial_write()
1270 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1275 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1283 if (assert_status(writer_fd, kqueue_fd, NOT_READABLE, WRITABLE, in test_events_partial_write()
1285 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1289 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1302 int fd, kqueue_fd; in test_events_rdwr() local
1313 kqueue_fd = kqueue(); in test_events_rdwr()
1314 if (kqueue_fd < 0) { in test_events_rdwr()
1320 if (kqueue_setup(kqueue_fd, fd, __func__) < 0) { in test_events_rdwr()
1321 cleanfifo2("testfifo", fd, kqueue_fd); in test_events_rdwr()
1329 if (assert_status(fd, kqueue_fd, NOT_READABLE, WRITABLE, in test_events_rdwr()
1331 cleanfifo2("testfifo", fd, kqueue_fd); in test_events_rdwr()
1343 cleanfifo2("testfifo", fd, kqueue_fd); in test_events_rdwr()
1347 if (assert_status(fd, kqueue_fd, READABLE, WRITABLE, NOT_EXCEPTION, in test_events_rdwr()
1349 cleanfifo2("testfifo", fd, kqueue_fd); in test_events_rdwr()
1360 cleanfifo2("testfifo", fd, kqueue_fd); in test_events_rdwr()
1364 if (assert_status(fd, kqueue_fd, NOT_READABLE, WRITABLE, in test_events_rdwr()
1366 cleanfifo2("testfifo", fd, kqueue_fd); in test_events_rdwr()
1370 cleanfifo2("testfifo", fd, kqueue_fd); in test_events_rdwr()