Lines Matching refs:writer_fd
246 int i, reader_fd, writer_fd;
251 if (openfifo("testfifo", &reader_fd, &writer_fd)
261 len = write(writer_fd, (char *)buffer, sizeof(buffer));
264 cleanfifo2("testfifo", reader_fd, writer_fd);
270 cleanfifo2("testfifo", reader_fd, writer_fd);
277 cleanfifo2("testfifo", reader_fd, writer_fd);
283 cleanfifo2("testfifo", reader_fd, writer_fd);
291 cleanfifo2("testfifo", reader_fd, writer_fd);
295 cleanfifo2("testfifo", reader_fd, writer_fd);
405 int reader_fd, ret, timedout, writer_fd;
410 if (openfifo("testfifo", &reader_fd, &writer_fd)
422 cleanfifo2("testfifo", reader_fd, writer_fd);
431 cleanfifo2("testfifo", reader_fd, writer_fd);
436 cleanfifo2("testfifo", reader_fd, writer_fd);
445 cleanfifo2("testfifo", reader_fd, writer_fd);
454 cleanfifo2("testfifo", reader_fd, writer_fd);
459 cleanfifo2("testfifo", reader_fd, writer_fd);
463 cleanfifo2("testfifo", reader_fd, writer_fd);
474 int reader_fd, ret, timedout, writer_fd;
479 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) {
485 if (set_blocking(writer_fd, __func__) < 0) {
486 cleanfifo2("testfifo", reader_fd, writer_fd);
490 cleanfifo2("testfifo", reader_fd, writer_fd);
495 ret = timed_write(writer_fd, &ch, sizeof(ch), &len, 5, &timedout,
499 cleanfifo2("testfifo", reader_fd, writer_fd);
505 cleanfifo2("testfifo", reader_fd, writer_fd);
514 cleanfifo2("testfifo", reader_fd, writer_fd);
520 cleanfifo2("testfifo", reader_fd, writer_fd);
526 cleanfifo2("testfifo", reader_fd, writer_fd);
530 cleanfifo2("testfifo", reader_fd, writer_fd);
540 int reader_fd, ret, timedout, writer_fd;
545 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) {
552 cleanfifo2("testfifo", reader_fd, writer_fd);
557 ret = timed_write(writer_fd, &ch, sizeof(ch), &len, 5, &timedout,
561 cleanfifo2("testfifo", reader_fd, writer_fd);
567 cleanfifo2("testfifo", reader_fd, writer_fd);
576 cleanfifo2("testfifo", reader_fd, writer_fd);
582 cleanfifo2("testfifo", reader_fd, writer_fd);
588 cleanfifo2("testfifo", reader_fd, writer_fd);
592 cleanfifo2("testfifo", reader_fd, writer_fd);
604 int reader_fd, ret, timedout, writer_fd;
609 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) {
615 if (set_blocking(writer_fd, __func__) < 0) {
616 cleanfifo2("testfifo", reader_fd, writer_fd);
623 cleanfifo2("testfifo", reader_fd, writer_fd);
628 ret = timed_write(writer_fd, buffer, 512*1024, &len, 5, &timedout,
633 cleanfifo2("testfifo", reader_fd, writer_fd);
641 cleanfifo2("testfifo", reader_fd, writer_fd);
648 cleanfifo2("testfifo", reader_fd, writer_fd);
652 cleanfifo2("testfifo", reader_fd, writer_fd);
662 int reader_fd, ret, timedout, writer_fd;
667 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) {
673 if (set_nonblocking(writer_fd, __func__) < 0) {
674 cleanfifo2("testfifo", reader_fd, writer_fd);
681 cleanfifo2("testfifo", reader_fd, writer_fd);
686 ret = timed_write(writer_fd, buffer, 512*1024, &len, 5, &timedout,
691 cleanfifo2("testfifo", reader_fd, writer_fd);
699 cleanfifo2("testfifo", reader_fd, writer_fd);
707 cleanfifo2("testfifo", reader_fd, writer_fd);
714 cleanfifo2("testfifo", reader_fd, writer_fd);
718 cleanfifo2("testfifo", reader_fd, writer_fd);
729 int i, reader_fd, writer_fd;
734 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) {
744 len = write(writer_fd, buffer, 5);
747 cleanfifo2("testfifo", reader_fd, writer_fd);
752 cleanfifo2("testfifo", reader_fd, writer_fd);
756 len = write(writer_fd, buffer + 5, 5);
759 cleanfifo2("testfifo", reader_fd, writer_fd);
764 cleanfifo2("testfifo", reader_fd, writer_fd);
771 cleanfifo2("testfifo", reader_fd, writer_fd);
776 cleanfifo2("testfifo", reader_fd, writer_fd);
785 cleanfifo2("testfifo", reader_fd, writer_fd);
800 int i, reader_fd, writer_fd;
805 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) {
815 len = write(writer_fd, buffer, 10);
818 cleanfifo2("testfifo", reader_fd, writer_fd);
823 cleanfifo2("testfifo", reader_fd, writer_fd);
830 cleanfifo2("testfifo", reader_fd, writer_fd);
835 cleanfifo2("testfifo", reader_fd, writer_fd);
842 cleanfifo2("testfifo", reader_fd, writer_fd);
847 cleanfifo2("testfifo", reader_fd, writer_fd);
856 cleanfifo2("testfifo", reader_fd, writer_fd);
1071 int kqueue_fd, reader_fd, writer_fd;
1074 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) {
1083 cleanfifo2("testfifo", reader_fd, writer_fd);
1088 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1092 if (kqueue_setup(kqueue_fd, writer_fd, __func__) < 0) {
1093 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1105 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1111 * good initial states. The writer_fd should be ready to write.
1113 if (assert_status(writer_fd, kqueue_fd, NOT_READABLE, WRITABLE,
1114 NOT_EXCEPTION, __func__, "create", "writer_fd") < 0) {
1115 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1119 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1125 int kqueue_fd, reader_fd, writer_fd;
1130 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) {
1139 cleanfifo2("testfifo", reader_fd, writer_fd);
1144 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1148 if (kqueue_setup(kqueue_fd, writer_fd, __func__) < 0) {
1149 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1158 len = write(writer_fd, &ch, sizeof(ch));
1161 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1167 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1172 * the writer_fd should remain writable.
1174 if (assert_status(writer_fd, kqueue_fd, NOT_READABLE, WRITABLE,
1175 NOT_EXCEPTION, __func__, "write", "writer_fd") < 0) {
1176 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1187 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1193 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1198 * The writer_fd should remain writable.
1200 if (assert_status(writer_fd, kqueue_fd, NOT_READABLE, WRITABLE,
1201 NOT_EXCEPTION, __func__, "write+read", "writer_fd") < 0) {
1202 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1206 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1217 int kqueue_fd, reader_fd, writer_fd;
1222 if (openfifo("testfifo", &reader_fd, &writer_fd) < 0) {
1231 cleanfifo2("testfifo", reader_fd, writer_fd);
1236 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1240 if (kqueue_setup(kqueue_fd, writer_fd, __func__) < 0) {
1241 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1245 if (set_nonblocking(writer_fd, "test_events") < 0) {
1246 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1253 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1258 len = write(writer_fd, buffer, 512*1024);
1262 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1268 if (assert_status(writer_fd, kqueue_fd, NOT_READABLE, NOT_WRITABLE,
1269 NOT_EXCEPTION, __func__, "big write", "writer_fd") < 0) {
1270 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1275 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1280 * Test that the writer_fd has been restored to writable state after
1283 if (assert_status(writer_fd, kqueue_fd, NOT_READABLE, WRITABLE,
1284 NOT_EXCEPTION, __func__, "big write + drain", "writer_fd") < 0) {
1285 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);
1289 cleanfifo3("testfifo", reader_fd, writer_fd, kqueue_fd);