/* $OpenBSD: t_pollts.c,v 1.1 2021/09/02 12:40:44 mbuhl Exp $ */ /* $NetBSD: t_pollts.c,v 1.1 2020/07/17 15:34:17 kamil Exp $ */ /*- * Copyright (c) 2011, 2020 The NetBSD Foundation, Inc. * All rights reserved. * * This code is derived from software contributed to The NetBSD Foundation * by Matthias Scheler. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY THE NETBSD FOUNDATION, INC. AND CONTRIBUTORS * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE FOUNDATION OR CONTRIBUTORS * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE * POSSIBILITY OF SUCH DAMAGE. */ #include "macros.h" #include #include #include "atf-c.h" #include #include #include #include #include #include #include #ifndef POLLTS #define POLLTS pollts #endif ATF_TC(basic); ATF_TC_HEAD(basic, tc) { atf_tc_set_md_var(tc, "timeout", "10"); atf_tc_set_md_var(tc, "descr", "Basis functionality test for ppoll(2)/pollts(2)"); } ATF_TC_BODY(basic, tc) { int fds[2]; struct pollfd pfds[2]; struct timespec timeout; int ret; ATF_REQUIRE_EQ(pipe(fds), 0); pfds[0].fd = fds[0]; pfds[0].events = POLLIN; pfds[1].fd = fds[1]; pfds[1].events = POLLOUT; /* Use a timeout of 1 second. */ timeout.tv_sec = 1; timeout.tv_nsec = 0; /* * Check that we get a timeout waiting for data on the read end * of our pipe. */ pfds[0].revents = -1; pfds[1].revents = -1; ATF_REQUIRE_EQ_MSG(ret = POLLTS(&pfds[0], 1, &timeout, NULL), 0, "got: %d", ret); ATF_REQUIRE_EQ_MSG(pfds[0].revents, 0, "got: %d", pfds[0].revents); ATF_REQUIRE_EQ_MSG(pfds[1].revents, -1, "got: %d", pfds[1].revents); /* Check that the write end of the pipe as reported as ready. */ pfds[0].revents = -1; pfds[1].revents = -1; ATF_REQUIRE_EQ_MSG(ret = POLLTS(&pfds[1], 1, &timeout, NULL), 1, "got: %d", ret); ATF_REQUIRE_EQ_MSG(pfds[0].revents, -1, "got: %d", pfds[0].revents); ATF_REQUIRE_EQ_MSG(pfds[1].revents, POLLOUT, "got: %d",\ pfds[1].revents); /* Check that only the write end of the pipe as reported as ready. */ pfds[0].revents = -1; pfds[1].revents = -1; ATF_REQUIRE_EQ_MSG(ret = POLLTS(pfds, 2, &timeout, NULL), 1, "got: %d", ret); ATF_REQUIRE_EQ_MSG(pfds[0].revents, 0, "got: %d", pfds[0].revents); ATF_REQUIRE_EQ_MSG(pfds[1].revents, POLLOUT, "got: %d", pfds[1].revents); /* Write data to our pipe. */ ATF_REQUIRE_EQ(write(fds[1], "", 1), 1); /* Check that both ends of our pipe are reported as ready. */ pfds[0].revents = -1; pfds[1].revents = -1; ATF_REQUIRE_EQ_MSG(ret = POLLTS(pfds, 2, &timeout, NULL), 2, "got: %d", ret); ATF_REQUIRE_EQ_MSG(pfds[0].revents, POLLIN, "got: %d", pfds[0].revents); ATF_REQUIRE_EQ_MSG(pfds[1].revents, POLLOUT, "got: %d", pfds[1].revents); ATF_REQUIRE_EQ(close(fds[0]), 0); ATF_REQUIRE_EQ(close(fds[1]), 0); } ATF_TC(err); ATF_TC_HEAD(err, tc) { atf_tc_set_md_var(tc, "descr", "Check errors from ppoll(2)/pollts(2)"); } ATF_TC_BODY(err, tc) { struct timespec timeout; struct pollfd pfd; int fd = 0; pfd.fd = fd; pfd.events = POLLIN; timeout.tv_sec = 1; timeout.tv_nsec = 0; errno = 0; ATF_REQUIRE_ERRNO(EFAULT, POLLTS((void *)-1, 1, &timeout, NULL) == -1); timeout.tv_sec = -1; timeout.tv_nsec = -1; errno = 0; ATF_REQUIRE_ERRNO(EINVAL, POLLTS(&pfd, 1, &timeout, NULL) == -1); } ATF_TC(sigmask); ATF_TC_HEAD(sigmask, tc) { atf_tc_set_md_var(tc, "timeout", "10"); atf_tc_set_md_var(tc, "descr", "Check that ppoll(2)/pollts(2) restores the signal mask (PR kern/44986)"); } ATF_TC_BODY(sigmask, tc) { int fd; struct pollfd pfd; struct timespec timeout; sigset_t mask; int ret; fd = open(_PATH_DEVNULL, O_RDONLY); ATF_REQUIRE(fd >= 0); pfd.fd = fd; pfd.events = POLLIN; /* Use a timeout of 1 second. */ timeout.tv_sec = 1; timeout.tv_nsec = 0; /* Unblock all signals. */ ATF_REQUIRE_EQ(sigfillset(&mask), 0); ATF_REQUIRE_EQ(sigprocmask(SIG_UNBLOCK, &mask, NULL), 0); /* * Check that ppoll(2)/pollts(2) immediately returns. We block *all* * signals during ppoll(2)/pollts(2). */ ATF_REQUIRE_EQ_MSG(ret = POLLTS(&pfd, 1, &timeout, &mask), 1, "got: %d", ret); /* Check that signals are now longer blocked. */ ATF_REQUIRE_EQ(sigprocmask(SIG_SETMASK, NULL, &mask), 0); ATF_REQUIRE_EQ_MSG(sigismember(&mask, SIGUSR1), 0, "signal mask was changed."); ATF_REQUIRE_EQ(close(fd), 0); } ATF_TP_ADD_TCS(tp) { ATF_TP_ADD_TC(tp, basic); ATF_TP_ADD_TC(tp, err); ATF_TP_ADD_TC(tp, sigmask); return atf_no_error(); }