Lines Matching refs:reader_fd
244 int i, reader_fd, writer_fd; in test_simpleio() local
249 if (openfifo("testfifo", &reader_fd, &writer_fd) in test_simpleio()
262 cleanfifo2("testfifo", reader_fd, writer_fd); in test_simpleio()
268 cleanfifo2("testfifo", reader_fd, writer_fd); in test_simpleio()
272 len = read(reader_fd, (char *)buffer, sizeof(buffer)); in test_simpleio()
275 cleanfifo2("testfifo", reader_fd, writer_fd); in test_simpleio()
281 cleanfifo2("testfifo", reader_fd, writer_fd); in test_simpleio()
289 cleanfifo2("testfifo", reader_fd, writer_fd); in test_simpleio()
293 cleanfifo2("testfifo", reader_fd, writer_fd); in test_simpleio()
403 int reader_fd, ret, timedout, writer_fd; in test_blocking_read_empty() local
408 if (openfifo("testfifo", &reader_fd, &writer_fd) in test_blocking_read_empty()
419 if (set_blocking(reader_fd, __func__) < 0) { in test_blocking_read_empty()
420 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_read_empty()
424 ret = timed_read(reader_fd, &ch, sizeof(ch), &len, 5, &timedout, in test_blocking_read_empty()
429 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_read_empty()
434 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_read_empty()
442 if (set_nonblocking(reader_fd, __func__) < 0) { in test_blocking_read_empty()
443 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_read_empty()
447 ret = timed_read(reader_fd, &ch, sizeof(ch), &len, 5, &timedout, in test_blocking_read_empty()
452 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_read_empty()
457 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_read_empty()
461 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_read_empty()
472 int reader_fd, ret, timedout, writer_fd; in test_blocking_one_byte() local
477 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) { in test_blocking_one_byte()
484 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_one_byte()
487 if (set_blocking(reader_fd, __func__) < 0) { in test_blocking_one_byte()
488 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_one_byte()
497 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_one_byte()
503 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_one_byte()
508 ret = timed_read(reader_fd, &ch, sizeof(ch), &len, 5, &timedout, in test_blocking_one_byte()
512 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_one_byte()
518 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_one_byte()
524 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_one_byte()
528 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_one_byte()
538 int reader_fd, ret, timedout, writer_fd; in test_nonblocking_one_byte() local
543 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) { in test_nonblocking_one_byte()
549 if (set_nonblocking(reader_fd, __func__) < 0) { in test_nonblocking_one_byte()
550 cleanfifo2("testfifo", reader_fd, writer_fd); in test_nonblocking_one_byte()
559 cleanfifo2("testfifo", reader_fd, writer_fd); in test_nonblocking_one_byte()
565 cleanfifo2("testfifo", reader_fd, writer_fd); in test_nonblocking_one_byte()
570 ret = timed_read(reader_fd, &ch, sizeof(ch), &len, 5, &timedout, in test_nonblocking_one_byte()
574 cleanfifo2("testfifo", reader_fd, writer_fd); in test_nonblocking_one_byte()
580 cleanfifo2("testfifo", reader_fd, writer_fd); in test_nonblocking_one_byte()
586 cleanfifo2("testfifo", reader_fd, writer_fd); in test_nonblocking_one_byte()
590 cleanfifo2("testfifo", reader_fd, writer_fd); in test_nonblocking_one_byte()
602 int reader_fd, ret, timedout, writer_fd; in test_blocking_partial_write() local
607 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) { in test_blocking_partial_write()
614 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_partial_write()
621 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_partial_write()
631 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_partial_write()
639 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_partial_write()
645 if (drain_fd(reader_fd, __func__) < 0) { in test_blocking_partial_write()
646 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_partial_write()
650 cleanfifo2("testfifo", reader_fd, writer_fd); in test_blocking_partial_write()
660 int reader_fd, ret, timedout, writer_fd; in test_nonblocking_partial_write() local
665 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) { in test_nonblocking_partial_write()
672 cleanfifo2("testfifo", reader_fd, writer_fd); in test_nonblocking_partial_write()
679 cleanfifo2("testfifo", reader_fd, writer_fd); in test_nonblocking_partial_write()
689 cleanfifo2("testfifo", reader_fd, writer_fd); in test_nonblocking_partial_write()
697 cleanfifo2("testfifo", reader_fd, writer_fd); in test_nonblocking_partial_write()
705 cleanfifo2("testfifo", reader_fd, writer_fd); in test_nonblocking_partial_write()
711 if (drain_fd(reader_fd, __func__) < 0) { in test_nonblocking_partial_write()
712 cleanfifo2("testfifo", reader_fd, writer_fd); in test_nonblocking_partial_write()
716 cleanfifo2("testfifo", reader_fd, writer_fd); in test_nonblocking_partial_write()
727 int i, reader_fd, writer_fd; in test_coalesce_big_read() local
732 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) { in test_coalesce_big_read()
745 cleanfifo2("testfifo", reader_fd, writer_fd); in test_coalesce_big_read()
750 cleanfifo2("testfifo", reader_fd, writer_fd); in test_coalesce_big_read()
757 cleanfifo2("testfifo", reader_fd, writer_fd); in test_coalesce_big_read()
762 cleanfifo2("testfifo", reader_fd, writer_fd); in test_coalesce_big_read()
766 len = read(reader_fd, buffer, 10); in test_coalesce_big_read()
769 cleanfifo2("testfifo", reader_fd, writer_fd); in test_coalesce_big_read()
774 cleanfifo2("testfifo", reader_fd, writer_fd); in test_coalesce_big_read()
783 cleanfifo2("testfifo", reader_fd, writer_fd); in test_coalesce_big_read()
798 int i, reader_fd, writer_fd; in test_coalesce_big_write() local
803 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) { in test_coalesce_big_write()
816 cleanfifo2("testfifo", reader_fd, writer_fd); in test_coalesce_big_write()
821 cleanfifo2("testfifo", reader_fd, writer_fd); in test_coalesce_big_write()
825 len = read(reader_fd, buffer, 5); in test_coalesce_big_write()
828 cleanfifo2("testfifo", reader_fd, writer_fd); in test_coalesce_big_write()
833 cleanfifo2("testfifo", reader_fd, writer_fd); in test_coalesce_big_write()
837 len = read(reader_fd, buffer + 5, 5); in test_coalesce_big_write()
840 cleanfifo2("testfifo", reader_fd, writer_fd); in test_coalesce_big_write()
845 cleanfifo2("testfifo", reader_fd, writer_fd); in test_coalesce_big_write()
854 cleanfifo2("testfifo", reader_fd, writer_fd); in test_coalesce_big_write()
1069 int kqueue_fd, reader_fd, writer_fd; in test_events_outofbox() local
1072 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) { in test_events_outofbox()
1081 cleanfifo2("testfifo", reader_fd, writer_fd); 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()
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()
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
1128 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) { in test_events_write_read_byte()
1137 cleanfifo2("testfifo", reader_fd, writer_fd); 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()
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()
1174 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_write_read_byte()
1182 len = read(reader_fd, &ch, sizeof(ch)); 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()
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
1220 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) { in test_events_partial_write()
1229 cleanfifo2("testfifo", reader_fd, writer_fd); 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()
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()
1268 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); in test_events_partial_write()
1272 if (drain_fd(reader_fd, "test_events") < 0) { in test_events_partial_write()
1273 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd); 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()