157718be8SEnji Cooper /* $NetBSD: t_pipe.c,v 1.2 2017/01/13 21:30:41 christos Exp $ */
257718be8SEnji Cooper
357718be8SEnji Cooper /*-
457718be8SEnji Cooper * Copyright (c) 2002, 2008 The NetBSD Foundation, Inc.
557718be8SEnji Cooper * All rights reserved.
657718be8SEnji Cooper *
757718be8SEnji Cooper * This code is derived from software contributed to The NetBSD Foundation
857718be8SEnji Cooper * by Luke Mewburn and Jaromir Dolecek.
957718be8SEnji Cooper *
1057718be8SEnji Cooper * Redistribution and use in source and binary forms, with or without
1157718be8SEnji Cooper * modification, are permitted provided that the following conditions
1257718be8SEnji Cooper * are met:
1357718be8SEnji Cooper * 1. Redistributions of source code must retain the above copyright
1457718be8SEnji Cooper * notice, this list of conditions and the following disclaimer.
1557718be8SEnji Cooper * 2. Redistributions in binary form must reproduce the above copyright
1657718be8SEnji Cooper * notice, this list of conditions and the following disclaimer in the
1757718be8SEnji Cooper * documentation and/or other materials provided with the distribution.
1857718be8SEnji Cooper *
1957718be8SEnji Cooper * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS
2057718be8SEnji Cooper * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
2157718be8SEnji Cooper * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
2257718be8SEnji Cooper * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS
2357718be8SEnji Cooper * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
2457718be8SEnji Cooper * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
2557718be8SEnji Cooper * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
2657718be8SEnji Cooper * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
2757718be8SEnji Cooper * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
2857718be8SEnji Cooper * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
2957718be8SEnji Cooper * POSSIBILITY OF SUCH DAMAGE.
3057718be8SEnji Cooper */
3157718be8SEnji Cooper
3257718be8SEnji Cooper #include <sys/cdefs.h>
3357718be8SEnji Cooper __COPYRIGHT("@(#) Copyright (c) 2008\
3457718be8SEnji Cooper The NetBSD Foundation, inc. All rights reserved.");
3557718be8SEnji Cooper __RCSID("$NetBSD: t_pipe.c,v 1.2 2017/01/13 21:30:41 christos Exp $");
3657718be8SEnji Cooper
3757718be8SEnji Cooper #include <sys/event.h>
3857718be8SEnji Cooper
3957718be8SEnji Cooper #include <stdio.h>
4057718be8SEnji Cooper #include <unistd.h>
4157718be8SEnji Cooper
4257718be8SEnji Cooper #include <atf-c.h>
4357718be8SEnji Cooper
4457718be8SEnji Cooper #include "h_macros.h"
4557718be8SEnji Cooper
4657718be8SEnji Cooper ATF_TC(pipe);
ATF_TC_HEAD(pipe,tc)4757718be8SEnji Cooper ATF_TC_HEAD(pipe, tc)
4857718be8SEnji Cooper {
4957718be8SEnji Cooper atf_tc_set_md_var(tc, "descr", "Checks EVFILT_READ for pipes");
5057718be8SEnji Cooper }
ATF_TC_BODY(pipe,tc)5157718be8SEnji Cooper ATF_TC_BODY(pipe, tc)
5257718be8SEnji Cooper {
5357718be8SEnji Cooper struct kevent event[1];
5457718be8SEnji Cooper char buffer[128];
5557718be8SEnji Cooper int fds[2];
5657718be8SEnji Cooper int kq, n;
5757718be8SEnji Cooper
5857718be8SEnji Cooper RL(pipe(fds));
5957718be8SEnji Cooper RL(kq = kqueue());
6057718be8SEnji Cooper
6157718be8SEnji Cooper EV_SET(&event[0], fds[0], EVFILT_READ, EV_ADD|EV_ENABLE, 0, 0, 0);
6257718be8SEnji Cooper RL(kevent(kq, event, 1, NULL, 0, NULL));
6357718be8SEnji Cooper
6457718be8SEnji Cooper /* make sure there is something in the pipe */
6557718be8SEnji Cooper RL(write(fds[1], "foo", 3));
6657718be8SEnji Cooper (void)printf("pipe: wrote 'foo' to pipe\n");
6757718be8SEnji Cooper
6857718be8SEnji Cooper RL(n = kevent(kq, NULL, 0, event, 1, NULL));
6957718be8SEnji Cooper (void)printf("kevent num %d flags: %#x, fflags: %#x, data: "
703d1eb084SEnji Cooper #ifdef __FreeBSD__
713d1eb084SEnji Cooper "%" PRIdPTR "\n", n, event[0].flags, event[0].fflags, event[0].data);
723d1eb084SEnji Cooper #else
7357718be8SEnji Cooper "%" PRId64 "\n", n, event[0].flags, event[0].fflags, event[0].data);
743d1eb084SEnji Cooper #endif
7557718be8SEnji Cooper
7657718be8SEnji Cooper RL(n = read(fds[0], buffer, event[0].data));
7757718be8SEnji Cooper buffer[n] = '\0';
7857718be8SEnji Cooper
7957718be8SEnji Cooper (void)printf("pipe: read '%s'\n", buffer);
8057718be8SEnji Cooper (void)printf("pipe: successful end\n");
8157718be8SEnji Cooper }
8257718be8SEnji Cooper
ATF_TP_ADD_TCS(tp)8357718be8SEnji Cooper ATF_TP_ADD_TCS(tp)
8457718be8SEnji Cooper {
8557718be8SEnji Cooper ATF_TP_ADD_TC(tp, pipe);
8657718be8SEnji Cooper
8757718be8SEnji Cooper return atf_no_error();
8857718be8SEnji Cooper }
89