#include #include #include #include #include #include #include #include #include int main() { int sock[2]; struct kevent kc; int kq; char foo[1024]; if (socketpair(PF_LOCAL, SOCK_STREAM, 0, sock) < 0) err(EX_TEMPFAIL, "socketpair"); if (write(sock[0], foo, sizeof(foo)) < 0) err(EX_TEMPFAIL, "write"); close(sock[0]); EV_SET(&kc, sock[1], EVFILT_READ, EV_ADD | EV_CLEAR, 0, 0, 0); kq = kqueue(); if (kevent(kq, &kc, 1, NULL, 0, NULL) < 0) err(EX_TEMPFAIL, "kqueue"); if (kevent(kq, NULL, 0, &kc, 1, NULL) < 0) err(EX_TEMPFAIL, "kevent1"); printf("kevent1 done, flags: %04x\n", kc.flags); if (kc.flags & EV_EOF) { printf("kevent1 reported EOF, exiting\n"); exit(0); } if (kevent(kq, NULL, 0, &kc, 1, NULL) < 0) err(EX_TEMPFAIL, "kevent2"); printf("kevent2 done, flags: %04x\n", kc.flags); exit(0); }