157718be8SEnji Cooper /* $NetBSD: t_file.c,v 1.4 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.
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_file.c,v 1.4 2017/01/13 21:30:41 christos Exp $");
3657718be8SEnji Cooper
3757718be8SEnji Cooper #include <sys/param.h>
3857718be8SEnji Cooper #include <sys/event.h>
3957718be8SEnji Cooper #include <sys/mount.h>
4057718be8SEnji Cooper #include <sys/wait.h>
4157718be8SEnji Cooper
4257718be8SEnji Cooper #include <err.h>
4357718be8SEnji Cooper #include <errno.h>
4457718be8SEnji Cooper #include <fcntl.h>
4557718be8SEnji Cooper #include <stdio.h>
4657718be8SEnji Cooper #include <stdlib.h>
4757718be8SEnji Cooper #include <string.h>
4857718be8SEnji Cooper #include <unistd.h>
4957718be8SEnji Cooper #include <inttypes.h>
5057718be8SEnji Cooper
5157718be8SEnji Cooper #include <atf-c.h>
5257718be8SEnji Cooper
5357718be8SEnji Cooper #include "h_macros.h"
5457718be8SEnji Cooper
5557718be8SEnji Cooper #define FILENAME "file"
5657718be8SEnji Cooper #define NLINES 5
5757718be8SEnji Cooper
5857718be8SEnji Cooper static void
child(void)5957718be8SEnji Cooper child(void)
6057718be8SEnji Cooper {
6157718be8SEnji Cooper int i, n, fd;
6257718be8SEnji Cooper
6357718be8SEnji Cooper (void)sleep(1);
6457718be8SEnji Cooper
6557718be8SEnji Cooper for (i = 0; i < NLINES; ++i) {
6657718be8SEnji Cooper fd = open(FILENAME, O_WRONLY|O_APPEND, 0644);
6757718be8SEnji Cooper if (fd < 0)
6857718be8SEnji Cooper err(EXIT_FAILURE, "open()");
6957718be8SEnji Cooper
7057718be8SEnji Cooper n = write(fd, "foo\n", 4);
7157718be8SEnji Cooper if (n < 0)
7257718be8SEnji Cooper err(EXIT_FAILURE, "write()");
7357718be8SEnji Cooper
7457718be8SEnji Cooper (void)close(fd);
7557718be8SEnji Cooper (void)sleep(1);
7657718be8SEnji Cooper }
7757718be8SEnji Cooper _exit(0);
7857718be8SEnji Cooper }
7957718be8SEnji Cooper
8057718be8SEnji Cooper ATF_TC(file);
ATF_TC_HEAD(file,tc)8157718be8SEnji Cooper ATF_TC_HEAD(file, tc)
8257718be8SEnji Cooper {
8357718be8SEnji Cooper atf_tc_set_md_var(tc, "descr", "Checks EVFILT_READ on regular file");
8457718be8SEnji Cooper }
ATF_TC_BODY(file,tc)8557718be8SEnji Cooper ATF_TC_BODY(file, tc)
8657718be8SEnji Cooper {
8757718be8SEnji Cooper char buffer[128];
8857718be8SEnji Cooper struct kevent event[1];
8957718be8SEnji Cooper pid_t pid;
9057718be8SEnji Cooper int fd, kq, n, num, status;
9157718be8SEnji Cooper
9257718be8SEnji Cooper RL(pid = fork());
9357718be8SEnji Cooper if (pid == 0) {
9457718be8SEnji Cooper child();
9557718be8SEnji Cooper /* NOTREACHED */
9657718be8SEnji Cooper }
9757718be8SEnji Cooper
9857718be8SEnji Cooper RL(fd = open(FILENAME, O_RDONLY|O_CREAT, 0644));
9957718be8SEnji Cooper
10057718be8SEnji Cooper #if 1 /* XXX: why was this disabled? */
10157718be8SEnji Cooper RL(lseek(fd, 0, SEEK_END));
10257718be8SEnji Cooper #endif
10357718be8SEnji Cooper
10457718be8SEnji Cooper RL(kq = kqueue());
10557718be8SEnji Cooper
10657718be8SEnji Cooper EV_SET(&event[0], fd, EVFILT_READ, EV_ADD|EV_ENABLE, 0, 0, 0);
10757718be8SEnji Cooper RL(kevent(kq, event, 1, NULL, 0, NULL));
10857718be8SEnji Cooper
10957718be8SEnji Cooper for (num = 0; num < NLINES;) {
11057718be8SEnji Cooper RL(n = kevent(kq, NULL, 0, event, 1, NULL));
11157718be8SEnji Cooper num += n;
11257718be8SEnji Cooper
11357718be8SEnji Cooper (void)printf("kevent num %d flags: %#x, fflags: %#x, data: "
1143d1eb084SEnji Cooper #ifdef __FreeBSD__
1153d1eb084SEnji Cooper "%" PRIdPTR "\n", n, event[0].flags, event[0].fflags,
1163d1eb084SEnji Cooper #else
11757718be8SEnji Cooper "%" PRId64 "\n", n, event[0].flags, event[0].fflags,
1183d1eb084SEnji Cooper #endif
11957718be8SEnji Cooper event[0].data);
12057718be8SEnji Cooper
12157718be8SEnji Cooper if (event[0].data < 0)
12257718be8SEnji Cooper #if 1 /* XXXLUKEM */
12357718be8SEnji Cooper RL(lseek(fd, 0, SEEK_END));
12457718be8SEnji Cooper #else
12557718be8SEnji Cooper RL(lseek(fd, event[0].data, SEEK_END));
12657718be8SEnji Cooper #endif
12757718be8SEnji Cooper
12857718be8SEnji Cooper RL(n = read(fd, buffer, 128));
12957718be8SEnji Cooper buffer[n] = '\0';
13057718be8SEnji Cooper (void)printf("file(%d): %s", num, buffer);
13157718be8SEnji Cooper }
13257718be8SEnji Cooper
13357718be8SEnji Cooper (void)waitpid(pid, &status, 0);
13457718be8SEnji Cooper
13557718be8SEnji Cooper (void)printf("read: successful end\n");
13657718be8SEnji Cooper }
13757718be8SEnji Cooper
ATF_TP_ADD_TCS(tp)13857718be8SEnji Cooper ATF_TP_ADD_TCS(tp)
13957718be8SEnji Cooper {
14057718be8SEnji Cooper ATF_TP_ADD_TC(tp, file);
14157718be8SEnji Cooper
14257718be8SEnji Cooper return atf_no_error();
14357718be8SEnji Cooper }
144