1*63d1fd59SEnji Cooper /* $NetBSD: t_fifo.c,v 1.4 2017/01/13 21:30:41 christos Exp $ */ 257718be8SEnji Cooper 357718be8SEnji Cooper /*- 457718be8SEnji Cooper * Copyright (c) 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."); 35*63d1fd59SEnji Cooper __RCSID("$NetBSD: t_fifo.c,v 1.4 2017/01/13 21:30:41 christos Exp $"); 3657718be8SEnji Cooper 3757718be8SEnji Cooper #include <sys/event.h> 3857718be8SEnji Cooper #include <sys/stat.h> 3957718be8SEnji Cooper 4057718be8SEnji Cooper #include <fcntl.h> 4157718be8SEnji Cooper #include <stdio.h> 4257718be8SEnji Cooper #include <stdlib.h> 4357718be8SEnji Cooper #include <string.h> 4457718be8SEnji Cooper #include <unistd.h> 4557718be8SEnji Cooper #include <inttypes.h> 4657718be8SEnji Cooper 4757718be8SEnji Cooper #include <atf-c.h> 4857718be8SEnji Cooper 49*63d1fd59SEnji Cooper #include "h_macros.h" 5057718be8SEnji Cooper 5157718be8SEnji Cooper #define FIFONAME "fifo" 5257718be8SEnji Cooper 5357718be8SEnji Cooper ATF_TC(fifo); 5457718be8SEnji Cooper ATF_TC_HEAD(fifo, tc) 5557718be8SEnji Cooper { 5657718be8SEnji Cooper atf_tc_set_md_var(tc, "descr", "Checks EVFILT_READ on fifo"); 5757718be8SEnji Cooper } 5857718be8SEnji Cooper ATF_TC_BODY(fifo, tc) 5957718be8SEnji Cooper { 6057718be8SEnji Cooper int kq, n, fd; 6157718be8SEnji Cooper struct kevent event[1]; 6257718be8SEnji Cooper char buffer[128]; 6357718be8SEnji Cooper 6457718be8SEnji Cooper RL(mkfifo(FIFONAME, 0644)); 6557718be8SEnji Cooper RL(fd = open(FIFONAME, O_RDWR, 0644)); 6657718be8SEnji Cooper 6757718be8SEnji Cooper RL(kq = kqueue()); 6857718be8SEnji Cooper 6957718be8SEnji Cooper EV_SET(&event[0], fd, EVFILT_READ, EV_ADD|EV_ENABLE, 0, 0, 0); 7057718be8SEnji Cooper RL(kevent(kq, event, 1, NULL, 0, NULL)); 7157718be8SEnji Cooper 7257718be8SEnji Cooper /* make sure there is something in the fifo */ 7357718be8SEnji Cooper RL(write(fd, "foo", 3)); 7457718be8SEnji Cooper (void)printf("fifo: wrote 'foo'\n"); 7557718be8SEnji Cooper 7657718be8SEnji Cooper (void)memset(event, 0, sizeof(event)); 7757718be8SEnji Cooper 7857718be8SEnji Cooper RL(n = kevent(kq, NULL, 0, event, 1, NULL)); 7957718be8SEnji Cooper 8057718be8SEnji Cooper (void)printf("kevent num %d filt %d flags: %#x, fflags: %#x, " 813d1eb084SEnji Cooper #ifdef __FreeBSD__ 823d1eb084SEnji Cooper "data: %" PRIdPTR "\n", n, event[0].filter, event[0].flags, 833d1eb084SEnji Cooper #else 8457718be8SEnji Cooper "data: %" PRId64 "\n", n, event[0].filter, event[0].flags, 853d1eb084SEnji Cooper #endif 8657718be8SEnji Cooper event[0].fflags, event[0].data); 8757718be8SEnji Cooper 8857718be8SEnji Cooper ATF_REQUIRE_EQ(event[0].filter, EVFILT_READ); 8957718be8SEnji Cooper 9057718be8SEnji Cooper RL(n = read(fd, buffer, event[0].data)); 9157718be8SEnji Cooper buffer[n] = '\0'; 9257718be8SEnji Cooper (void)printf("fifo: read '%s'\n", buffer); 9357718be8SEnji Cooper 9457718be8SEnji Cooper RL(close(fd)); 9557718be8SEnji Cooper } 9657718be8SEnji Cooper 9757718be8SEnji Cooper ATF_TP_ADD_TCS(tp) 9857718be8SEnji Cooper { 9957718be8SEnji Cooper ATF_TP_ADD_TC(tp, fifo); 10057718be8SEnji Cooper 10157718be8SEnji Cooper return atf_no_error(); 10257718be8SEnji Cooper } 103