mirror of
https://github.com/darlinghq/darling-libkqueue.git
synced 2024-11-23 11:49:50 +00:00
b24deab5dc
git-svn-id: svn://svn.code.sf.net/p/libkqueue/code/trunk@172 fb4e3144-bc1c-4b72-a658-5bcd248dd7f7
146 lines
3.4 KiB
C
146 lines
3.4 KiB
C
/*
|
|
* Copyright (c) 2009 Mark Heily <mark@heily.com>
|
|
*
|
|
* Permission to use, copy, modify, and distribute this software for any
|
|
* purpose with or without fee is hereby granted, provided that the above
|
|
* copyright notice and this permission notice appear in all copies.
|
|
*
|
|
* THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
|
|
* WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
|
|
* MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
|
|
* ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
|
|
* WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
|
|
* ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
|
|
* OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
|
|
*/
|
|
|
|
#include <sys/types.h>
|
|
#include <poll.h>
|
|
|
|
#include "common.h"
|
|
|
|
|
|
/*
|
|
* Test the method for detecting when one end of a socketpair
|
|
* has been closed. This technique is used in kqueue_validate()
|
|
*/
|
|
static void
|
|
test_peer_close_detection(void)
|
|
{
|
|
int sockfd[2];
|
|
char buf[1];
|
|
struct pollfd pfd;
|
|
|
|
if (socketpair(AF_UNIX, SOCK_STREAM, 0, sockfd) < 0)
|
|
err(1, "socketpair");
|
|
|
|
pfd.fd = sockfd[0];
|
|
pfd.events = POLLIN | POLLHUP;
|
|
pfd.revents = 0;
|
|
|
|
if (poll(&pfd, 1, 0) > 0)
|
|
err(1, "unexpected data");
|
|
|
|
if (close(sockfd[1]) < 0)
|
|
err(1, "close");
|
|
|
|
if (poll(&pfd, 1, 0) > 0) {
|
|
if (recv(sockfd[0], buf, sizeof(buf), MSG_PEEK | MSG_DONTWAIT) != 0)
|
|
err(1, "failed to detect peer shutdown");
|
|
}
|
|
}
|
|
|
|
void
|
|
test_kqueue(void)
|
|
{
|
|
int kqfd;
|
|
|
|
if ((kqfd = kqueue()) < 0)
|
|
err(1, "kqueue()");
|
|
test_no_kevents(kqfd);
|
|
if (close(kqfd) < 0)
|
|
err(1, "close()");
|
|
}
|
|
|
|
void
|
|
test_ev_receipt(void)
|
|
{
|
|
int kq;
|
|
struct kevent kev;
|
|
|
|
if ((kq = kqueue()) < 0)
|
|
err(1, "kqueue()");
|
|
#if HAVE_EV_RECEIPT
|
|
|
|
EV_SET(&kev, SIGUSR2, EVFILT_SIGNAL, EV_ADD | EV_RECEIPT, 0, 0, NULL);
|
|
if (kevent(kq, &kev, 1, &kev, 1, NULL) < 0)
|
|
err(1, "%s", test_id);
|
|
|
|
/* TODO: check the receipt */
|
|
|
|
close(kq);
|
|
#else
|
|
memset(&kev, 0, sizeof(kev));
|
|
puts("Skipped -- EV_RECEIPT is not available");
|
|
#endif
|
|
}
|
|
|
|
int
|
|
main(int argc, char **argv)
|
|
{
|
|
int kqfd;
|
|
int test_proc = 0; /* XXX-FIXME */
|
|
int test_socket = 1;
|
|
int test_signal = 1;
|
|
int test_vnode = 1;
|
|
int test_timer = 1;
|
|
int test_user = 1;
|
|
|
|
while (argc) {
|
|
if (strcmp(argv[0], "--no-proc") == 0)
|
|
test_proc = 0;
|
|
if (strcmp(argv[0], "--no-socket") == 0)
|
|
test_socket = 0;
|
|
if (strcmp(argv[0], "--no-timer") == 0)
|
|
test_timer = 0;
|
|
if (strcmp(argv[0], "--no-signal") == 0)
|
|
test_signal = 0;
|
|
if (strcmp(argv[0], "--no-vnode") == 0)
|
|
test_vnode = 0;
|
|
if (strcmp(argv[0], "--no-user") == 0)
|
|
test_user = 0;
|
|
argv++;
|
|
argc--;
|
|
}
|
|
|
|
testing_begin();
|
|
|
|
test(peer_close_detection);
|
|
|
|
test(kqueue);
|
|
|
|
if ((kqfd = kqueue()) < 0)
|
|
err(1, "kqueue()");
|
|
|
|
if (test_socket)
|
|
test_evfilt_read(kqfd);
|
|
if (test_signal)
|
|
test_evfilt_signal(kqfd);
|
|
if (test_vnode)
|
|
test_evfilt_vnode(kqfd);
|
|
#if HAVE_EVFILT_USER
|
|
if (test_user)
|
|
test_evfilt_user(kqfd);
|
|
#endif
|
|
if (test_timer)
|
|
test_evfilt_timer(kqfd);
|
|
if (test_proc)
|
|
test_evfilt_proc(kqfd);
|
|
|
|
test(ev_receipt);
|
|
|
|
testing_end();
|
|
|
|
return (0);
|
|
}
|