mirror/freebsd
1
0
Fork 0
mirror of https://git.FreeBSD.org/src.git synced 2024-12-13 10:02:38 +00:00
Code Issues Releases Activity

Comment test_lseek().

Browse Source 
Add test_kqueue(), which registers and unregisters various kqueue filter
types on a fifo in order to make sure that EVFILT_READ, EVFILT_WRITE can
be registered, and that EVFILT_NETDEV can't be registered.  For now, we
don't test that EVFILT_VNODE can be registered on fifos, as that has been
broken at some point.
This commit is contained in:
Robert Watson 2005-09-12 19:31:16 +00:00
parent 0a53be4671
commit 456068c703
Notes: svn2git 2020-12-20 02:59:44 +00:00 
svn path=/head/; revision=150064
1 changed files with 117 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

117
tools/regression/fifo/fifo_misc/fifo_misc.c
View File

@ -26,12 +26,16 @@
* $FreeBSD$
*/
#include <sys/types.h>
#include <sys/event.h>
#include <sys/stat.h>
#include <sys/time.h>
#include <err.h>
#include <errno.h>
#include <fcntl.h>
#include <limits.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
@ -94,6 +98,9 @@ openfifo(const char *fifoname, const char *testname, int *reader_fdp,
return (0);
}
/*
* POSIX does not allow lseek(2) on fifos, so we expect ESPIPE as a result.
*/
static void
test_lseek(void)
{
@ -122,6 +129,115 @@ test_lseek(void)
cleanfifo("testfifo", reader_fd, writer_fd);
}
struct filter_entry {
int fe_filter;
const char *fe_name;
int fe_error;
const char *fe_errorname;
};
static const struct filter_entry good_filter_types[] = {
{ EVFILT_READ, "EVFILT_READ", 0, "0" },
{ EVFILT_WRITE, "EVFILT_WRITE", 0, "0" },
#if WORKING_EVFILT_VNODE_ON_FIFOS
{ EVFILT_VNODE, "EVFILT_VNODE", EINVAL, "EINVAL" },
#endif
};
static const int good_filter_types_len = sizeof(good_filter_types) /
sizeof(good_filter_types[0]);
static const struct filter_entry bad_filter_types[] = {
{ EVFILT_NETDEV, "EVFILT_NETDEV", EINVAL, "EINVAL" },
};
static const int bad_filter_types_len = sizeof(bad_filter_types) /
sizeof(bad_filter_types[0]);
/*
* kqueue event-related tests are in fifo_io.c; however, that tests only
* valid invocations of kqueue. Check to make sure that some invalid filters
* that are generally allowed on file descriptors are not allowed to be
* registered with kqueue, and that if attempts are made, we get the right
* error.
*/
static void
test_kqueue(void)
{
int kqueue_fd, reader_fd, writer_fd;
struct kevent kev_set;
struct timespec timeout;
int i, ret;
makefifo("testfifo", __func__);
if (openfifo("testfifo", __func__, &reader_fd, &writer_fd) < 0) {
warn("%s: openfifo", __func__);
cleanfifo("testfifo", -1, -1);
exit(-1);
}
kqueue_fd = kqueue();
if (kqueue_fd < 0) {
warn("%s: kqueue", __func__);
cleanfifo("testfifo", reader_fd, writer_fd);
exit(-1);
}
timeout.tv_sec = 0;
timeout.tv_nsec = 0;
for (i = 0; i < good_filter_types_len; i++) {
bzero(&kev_set, sizeof(kev_set));
EV_SET(&kev_set, reader_fd, good_filter_types[i].fe_filter,
EV_ADD, 0, 0, 0);
ret = kevent(kqueue_fd, &kev_set, 1, NULL, 0, &timeout);
if (ret < 0) {
warn("%s: kevent: adding good filter %s", __func__,
good_filter_types[i].fe_name);
close(kqueue_fd);
cleanfifo("testfifo", reader_fd, writer_fd);
exit(-1);
}
bzero(&kev_set, sizeof(kev_set));
EV_SET(&kev_set, reader_fd, good_filter_types[i].fe_filter,
EV_DELETE, 0, 0, 0);
ret = kevent(kqueue_fd, &kev_set, 1, NULL, 0, &timeout);
if (ret < 0) {
warn("%s: kevent: deleting good filter %s", __func__,
good_filter_types[i].fe_name);
close(kqueue_fd);
cleanfifo("testfifo", reader_fd, writer_fd);
exit(-1);
}
}
for (i = 0; i < bad_filter_types_len; i++) {
bzero(&kev_set, sizeof(kev_set));
printf("Trying %s\n", bad_filter_types[i].fe_name);
EV_SET(&kev_set, reader_fd, bad_filter_types[i].fe_filter,
EV_ADD, 0, 0, 0);
ret = kevent(kqueue_fd, &kev_set, 1, NULL, 0, &timeout);
if (ret >= 0) {
warnx("%s: kevent: bad filter %s succeeded, expected "
"EINVAL", __func__, bad_filter_types[i].fe_name);
close(kqueue_fd);
cleanfifo("testfifo", reader_fd, writer_fd);
exit(-1);
}
if (errno != bad_filter_types[i].fe_error) {
warn("%s: kevent: bad filter %s failed with error "
"not %s", __func__,
bad_filter_types[i].fe_name,
bad_filter_types[i].fe_errorname);
close(kqueue_fd);
cleanfifo("testfifo", reader_fd, writer_fd);
exit(-1);
}
}
close(kqueue_fd);
cleanfifo("testfifo", reader_fd, writer_fd);
}
int
main(int argc, char *argv[])
{
@ -135,6 +251,7 @@ main(int argc, char *argv[])
err(-1, "chdir %s", temp_dir);
test_lseek();
test_kqueue();
return (0);
}